diff --git a/fairmq/shmem/Manager.cxx b/fairmq/shmem/Manager.cxx index 741e14f7..12f5274a 100644 --- a/fairmq/shmem/Manager.cxx +++ b/fairmq/shmem/Manager.cxx @@ -183,7 +183,6 @@ Region* Manager::GetRegionUnsafe(const uint64_t id) // LOG(debug) << "Located remote region with id '" << id << "', path: '" << path << "', flags: '" << flags << "'"; auto r = fRegions.emplace(id, tools::make_unique(*this, id, 0, true, nullptr, path, flags)); - r.first->second->StartSendingAcks(); return r.first->second.get(); } catch (bie& e) { LOG(warn) << "Could not get remote region for id: " << id; diff --git a/fairmq/shmem/Region.cxx b/fairmq/shmem/Region.cxx index 1132bb94..7735cdad 100644 --- a/fairmq/shmem/Region.cxx +++ b/fairmq/shmem/Region.cxx @@ -81,6 +81,7 @@ Region::Region(Manager& manager, uint64_t id, uint64_t size, bool remote, Region } InitializeQueues(); + StartSendingAcks(); LOG(debug) << "shmem: initialized region: " << fName; }