X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/cdf6a962eb4e88efbed3df9c41343adabcf09e6c..4f967cc6bcb00b163c629b10ddde682f30bf830e:/src/instr/instr_paje_trace.cpp diff --git a/src/instr/instr_paje_trace.cpp b/src/instr/instr_paje_trace.cpp index 927a8dbfe8..99d73f814e 100644 --- a/src/instr/instr_paje_trace.cpp +++ b/src/instr/instr_paje_trace.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2010-2019. The SimGrid Team. +/* Copyright (c) 2010-2021. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -14,42 +14,17 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(instr_paje_trace, instr, "tracing event system"); -extern std::ofstream tracing_file; +namespace simgrid { +namespace instr { +static std::vector buffer; -static std::vector buffer; - -void dump_comment(const std::string& comment) -{ - if (not comment.empty()) - tracing_file << "# " << comment << std::endl; -} - -void dump_comment_file(const std::string& filename) -{ - if (filename.empty()) - return; - std::ifstream fs(filename.c_str(), std::ifstream::in); - - if (fs.fail()) - throw simgrid::TracingError( - XBT_THROW_POINT, - simgrid::xbt::string_printf("Comment file %s could not be opened for reading.", filename.c_str())); - - while (not fs.eof()) { - std::string line; - std::getline(fs, line); - tracing_file << "# " << line; - } - fs.close(); -} - -double TRACE_last_timestamp_to_dump = 0; -//dumps the trace file until the timestamp TRACE_last_timestamp_to_dump -void TRACE_paje_dump_buffer(bool force) +double last_timestamp_to_dump = 0; +// dumps the trace file until the last_timestamp_to_dump +void dump_buffer(bool force) { if (not TRACE_is_enabled()) return; - XBT_DEBUG("%s: dump until %f. starts", __func__, TRACE_last_timestamp_to_dump); + XBT_DEBUG("%s: dump until %f. starts", __func__, last_timestamp_to_dump); if (force){ for (auto const& event : buffer) { event->print(); @@ -57,10 +32,10 @@ void TRACE_paje_dump_buffer(bool force) } buffer.clear(); } else { - std::vector::iterator i = buffer.begin(); + auto i = buffer.begin(); for (auto const& event : buffer) { double head_timestamp = event->timestamp_; - if (head_timestamp > TRACE_last_timestamp_to_dump) + if (head_timestamp > last_timestamp_to_dump) break; event->print(); delete event; @@ -72,13 +47,14 @@ void TRACE_paje_dump_buffer(bool force) } /* internal do the instrumentation module */ -void simgrid::instr::PajeEvent::insert_into_buffer() +void PajeEvent::insert_into_buffer() { - XBT_DEBUG("%s: insert event_type=%u, timestamp=%f, buffersize=%zu)", __func__, eventType_, timestamp_, buffer.size()); - std::vector::reverse_iterator i; + XBT_DEBUG("%s: insert event_type=%u, timestamp=%f, buffersize=%zu)", __func__, static_cast(eventType_), + timestamp_, buffer.size()); + std::vector::reverse_iterator i; for (i = buffer.rbegin(); i != buffer.rend(); ++i) { - simgrid::instr::PajeEvent* e1 = *i; - XBT_DEBUG("compare to %p is of type %u; timestamp:%f", e1, e1->eventType_, e1->timestamp_); + PajeEvent* e1 = *i; + XBT_DEBUG("compare to %p is of type %u; timestamp:%f", e1, static_cast(e1->eventType_), e1->timestamp_); if (e1->timestamp_ <= timestamp_) break; } @@ -90,3 +66,6 @@ void simgrid::instr::PajeEvent::insert_into_buffer() XBT_DEBUG("%s: inserted at pos= %zd from its end", __func__, std::distance(buffer.rbegin(), i)); buffer.insert(i.base(), this); } + +} // namespace instr +} // namespace simgrid