Skip to content

Commit

Permalink
refactor(lci pp log): add destination rank to the profiling log outpu…
Browse files Browse the repository at this point in the history
…t; remove one log output
  • Loading branch information
JiakunYan committed Jan 11, 2024
1 parent 0c5aad1 commit 9b1c5c9
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 6 deletions.
3 changes: 0 additions & 3 deletions libs/full/parcelport_lci/src/parcelport_lci.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -461,9 +461,6 @@ namespace hpx::parcelset::policies::lci {
hpx::threads::get_self_id() == hpx::threads::invalid_thread_id))
{
static thread_local unsigned int tls_rand_seed = rand();
util::lci_environment::log(
util::lci_environment::log_level_t::debug, "device",
"Rank %d unusual phase\n", LCI_RANK);
return devices[rand_r(&tls_rand_seed) % devices.size()];
}
if (tls_device_idx == std::size_t(-1))
Expand Down
6 changes: 3 additions & 3 deletions libs/full/parcelport_lci/src/sender_connection_base.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -117,10 +117,10 @@ namespace hpx::parcelset::policies::lci {
char buf[1024];
size_t consumed = 0;
consumed += snprintf(buf + consumed, sizeof(buf) - consumed,
"%d:%lf:send_connection(%p) start:%d:%d:%d:[", LCI_RANK,
"%d:%lf:send_connection(%p) start:%d:%d:%d:%d:[", LCI_RANK,
hpx::chrono::high_resolution_clock::now() / 1e9, (void*) this,
header_.numbytes_nonzero_copy(), header_.numbytes_tchunk(),
header_.num_zero_copy_chunks());
dst_rank, header_.numbytes_nonzero_copy(),
header_.numbytes_tchunk(), header_.num_zero_copy_chunks());
HPX_ASSERT(sizeof(buf) > consumed);
for (int i = 0; i < header_.num_zero_copy_chunks(); ++i)
{
Expand Down

0 comments on commit 9b1c5c9

Please sign in to comment.