Skip to content

Commit

Permalink
shm: add some debug output
Browse files Browse the repository at this point in the history
  • Loading branch information
rbx committed Sep 9, 2022
1 parent f5c46ce commit 072d7cb
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 1 deletion.
2 changes: 1 addition & 1 deletion fairmq/shmem/Monitor.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -670,7 +670,7 @@ std::vector<std::pair<std::string, bool>> 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<bipc::file_mapping>(path + "fmq_" + shmId + "_rg_" + to_string(id), verbose));
Expand Down
3 changes: 3 additions & 0 deletions fairmq/shmem/UnmanagedRegion.h
Original file line number Diff line number Diff line change
Expand Up @@ -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);

Expand Down Expand Up @@ -171,6 +173,7 @@ struct UnmanagedRegion

~UnmanagedRegion()
{
LOG(debug) << "~UnmanagedRegion(): " << fName << " | remote: " << fRemote << ".";
fStopAcks = true;

if (fAcksSender.joinable()) {
Expand Down

0 comments on commit 072d7cb

Please sign in to comment.