From 4218c185a4018c36a5fbc32d7c845b1dc811a567 Mon Sep 17 00:00:00 2001
From: Alexey Rybalchenko <alexryba@gmail.com>
Date: Mon, 4 May 2020 09:53:13 +0200
Subject: [PATCH] Shmem: Send acks also for local regions

---
 fairmq/shmem/Manager.cxx | 1 -
 fairmq/shmem/Region.cxx  | 1 +
 2 files changed, 1 insertion(+), 1 deletion(-)

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<Region>(*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;
 }