X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ca9df46902847c5f7d0bf959efa930bbbe585764..84862a5ed2d967524594c4fee1369b3a91c490e3:/src/smpi/internals/instr_smpi.cpp diff --git a/src/smpi/internals/instr_smpi.cpp b/src/smpi/internals/instr_smpi.cpp index b55f098116..3f7fcd3fed 100644 --- a/src/smpi/internals/instr_smpi.cpp +++ b/src/smpi/internals/instr_smpi.cpp @@ -19,7 +19,7 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(instr_smpi, instr, "Tracing SMPI"); -static std::unordered_map*> keys; +static std::unordered_map> keys; static std::map smpi_colors = {{"recv", "1 0 0"}, {"irecv", "1 0.52 0.52"}, @@ -102,18 +102,6 @@ XBT_PRIVATE container_t smpi_container(int rank) static std::string TRACE_smpi_put_key(int src, int dst, int tag, int send) { - // get the deque for src#dst - std::string aux = - std::to_string(src) + "#" + std::to_string(dst) + "#" + std::to_string(tag) + "#" + std::to_string(send); - auto it = keys.find(aux); - std::deque* d; - - if (it == keys.end()) { - d = new std::deque; - keys[aux] = d; - } else - d = it->second; - //generate the key static unsigned long long counter = 0; counter++; @@ -121,7 +109,9 @@ static std::string TRACE_smpi_put_key(int src, int dst, int tag, int send) std::to_string(src) + "_" + std::to_string(dst) + "_" + std::to_string(tag) + "_" + std::to_string(counter); //push it - d->push_back(key); + std::string aux = + std::to_string(src) + "#" + std::to_string(dst) + "#" + std::to_string(tag) + "#" + std::to_string(send); + keys[aux].push_back(key); return key; } @@ -136,9 +126,9 @@ static std::string TRACE_smpi_get_key(int src, int dst, int tag, int send) // first posted key = TRACE_smpi_put_key(src, dst, tag, send); } else { - key = it->second->front(); - it->second->pop_front(); - if (it->second->empty()) + key = it->second.front(); + it->second.pop_front(); + if (it->second.empty()) keys.erase(it); } return key; @@ -146,31 +136,25 @@ static std::string TRACE_smpi_get_key(int src, int dst, int tag, int send) static std::unordered_map process_category; -void TRACE_internal_smpi_set_category (const char *category) +void TRACE_internal_smpi_set_category(std::string category) { if (not TRACE_smpi_is_enabled()) return; //declare category - TRACE_category (category); + TRACE_category(category.c_str()); - if (category != nullptr) + if (not category.empty()) process_category[SIMIX_process_self()] = category; } -const char *TRACE_internal_smpi_get_category () +std::string TRACE_internal_smpi_get_category() { if (not TRACE_smpi_is_enabled()) - return nullptr; + return ""; auto it = process_category.find(SIMIX_process_self()); - return (it == process_category.end()) ? nullptr : it->second.c_str(); -} - -void TRACE_smpi_release() -{ - for (auto const& elm : keys) - delete elm.second; + return (it == process_category.end()) ? "" : it->second.c_str(); } void TRACE_smpi_setup_container(int rank, sg_host_t host) @@ -312,7 +296,7 @@ void TRACE_smpi_send_process_data_out(int rank) void TRACE_smpi_process_change_host(int rank, sg_host_t new_host) { - if (!TRACE_smpi_is_enabled()) return; + if (not TRACE_smpi_is_enabled()) return; /** The key is (most likely) used to match the events in the trace */ static long long int counter = 0;