Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Use const reference for std::string parameters.
[simgrid.git] / src / instr / instr_paje_trace.cpp
1 /* Copyright (c) 2010-2020. The SimGrid Team.
2  * All rights reserved.                                                     */
3
4 /* This program is free software; you can redistribute it and/or modify it
5  * under the terms of the license (GNU LGPL) which comes with this package. */
6
7 #include "simgrid/Exception.hpp"
8 #include "simgrid/sg_config.hpp"
9 #include "src/instr/instr_private.hpp"
10 #include "src/instr/instr_smpi.hpp"
11 #include "src/smpi/include/private.hpp"
12 #include "typeinfo"
13 #include <fstream>
14
15 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(instr_paje_trace, instr, "tracing event system");
16
17 namespace simgrid {
18 namespace instr {
19 static std::vector<PajeEvent*> buffer;
20
21 double last_timestamp_to_dump = 0;
22 // dumps the trace file until the last_timestamp_to_dump
23 void dump_buffer(bool force)
24 {
25   if (not TRACE_is_enabled())
26     return;
27   XBT_DEBUG("%s: dump until %f. starts", __func__, last_timestamp_to_dump);
28   if (force){
29     for (auto const& event : buffer) {
30       event->print();
31       delete event;
32     }
33     buffer.clear();
34   } else {
35     std::vector<PajeEvent*>::iterator i = buffer.begin();
36     for (auto const& event : buffer) {
37       double head_timestamp = event->timestamp_;
38       if (head_timestamp > last_timestamp_to_dump)
39         break;
40       event->print();
41       delete event;
42       ++i;
43     }
44     buffer.erase(buffer.begin(), i);
45   }
46   XBT_DEBUG("%s: ends", __func__);
47 }
48
49 /* internal do the instrumentation module */
50 void PajeEvent::insert_into_buffer()
51 {
52   XBT_DEBUG("%s: insert event_type=%u, timestamp=%f, buffersize=%zu)", __func__, eventType_, timestamp_, buffer.size());
53   std::vector<PajeEvent*>::reverse_iterator i;
54   for (i = buffer.rbegin(); i != buffer.rend(); ++i) {
55     PajeEvent* e1 = *i;
56     XBT_DEBUG("compare to %p is of type %u; timestamp:%f", e1, e1->eventType_, e1->timestamp_);
57     if (e1->timestamp_ <= timestamp_)
58       break;
59   }
60   if (i == buffer.rend())
61     XBT_DEBUG("%s: inserted at beginning", __func__);
62   else if (i == buffer.rbegin())
63     XBT_DEBUG("%s: inserted at end", __func__);
64   else
65     XBT_DEBUG("%s: inserted at pos= %zd from its end", __func__, std::distance(buffer.rbegin(), i));
66   buffer.insert(i.base(), this);
67 }
68
69 } // namespace instr
70 } // namespace simgrid