diff --git a/fairmq/shmem/Manager.h b/fairmq/shmem/Manager.h index 08e63fec..c6608603 100644 --- a/fairmq/shmem/Manager.h +++ b/fairmq/shmem/Manager.h @@ -105,6 +105,8 @@ class Manager StartMonitor(fShmId); } + fHeartbeatThread = std::thread(&Manager::SendHeartbeats, this); + { std::stringstream ss; boost::interprocess::scoped_lock lock(fShmMtx); @@ -200,8 +202,6 @@ class Manager fShmMsgCounters = fManagementSegment.find_or_construct(unique_instance)(fShmVoidAlloc); #endif } - - fHeartbeatThread = std::thread(&Manager::SendHeartbeats, this); } Manager() = delete;