From 46e568c55e0faceecc0b57397a03be6df2615f96 Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Fri, 9 Sep 2022 13:50:56 +0200 Subject: [PATCH] shm: add some debug output --- fairmq/shmem/Monitor.cxx | 2 +- fairmq/shmem/UnmanagedRegion.h | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/fairmq/shmem/Monitor.cxx b/fairmq/shmem/Monitor.cxx index 1dffd977..35b23c59 100644 --- a/fairmq/shmem/Monitor.cxx +++ b/fairmq/shmem/Monitor.cxx @@ -670,7 +670,7 @@ std::vector> Monitor::Cleanup(const ShmId& shmIdT, string path = info.fPath.c_str(); int flags = info.fCreationFlags; if (verbose) { - LOG(info) << "Found RegionInfo with path: '" << path << "', flags: " << flags << ", fDestroyed: " << info.fDestroyed << "."; + LOG(info) << "Found UnmanagedRegion with id: " << id << ", path: '" << path << "', flags: " << flags << ", fDestroyed: " << info.fDestroyed << "."; } if (!path.empty()) { result.emplace_back(Remove(path + "fmq_" + shmId + "_rg_" + to_string(id), verbose)); diff --git a/fairmq/shmem/UnmanagedRegion.h b/fairmq/shmem/UnmanagedRegion.h index 9b81dba5..21ac1225 100644 --- a/fairmq/shmem/UnmanagedRegion.h +++ b/fairmq/shmem/UnmanagedRegion.h @@ -74,6 +74,8 @@ struct UnmanagedRegion // TODO: refactor this cfg.size = size; + LOG(debug) << "UnmanagedRegion(): " << fName << " | remote: " << remote << "."; + if (!cfg.path.empty()) { fName = std::string(cfg.path + fName); @@ -171,6 +173,7 @@ struct UnmanagedRegion ~UnmanagedRegion() { + LOG(debug) << "~UnmanagedRegion(): " << fName << " | remote: " << fRemote << "."; fStopAcks = true; if (fAcksSender.joinable()) {