Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
cosmetics
authorFrederic Suter <frederic.suter@cc.in2p3.fr>
Tue, 15 May 2018 07:30:24 +0000 (09:30 +0200)
committerFrederic Suter <frederic.suter@cc.in2p3.fr>
Tue, 15 May 2018 07:30:24 +0000 (09:30 +0200)
src/instr/instr_config.cpp
src/instr/instr_paje_events.cpp
src/instr/instr_paje_events.hpp
src/instr/instr_paje_header.cpp
src/instr/instr_paje_trace.cpp
src/instr/instr_private.hpp
src/instr/instr_resource_utilization.cpp
src/surf/network_ns3.cpp

index b271e71..a1fe6b2 100644 (file)
@@ -119,10 +119,10 @@ static void TRACE_start()
     }
 
     /* output one line comment */
-    dump_comment(TRACE_get_comment());
+    dump_comment(simgrid::config::get_value<std::string>(OPT_TRACING_COMMENT));
 
     /* output comment file */
-    dump_comment_file(TRACE_get_comment_file());
+    dump_comment_file(simgrid::config::get_value<std::string>(OPT_TRACING_COMMENT_FILE));
 
     if (format == "Paje") {
       /* output Paj√© header */
@@ -255,16 +255,6 @@ bool TRACE_display_sizes ()
   return trace_display_sizes && trace_smpi_enabled && trace_enabled;
 }
 
-std::string TRACE_get_comment()
-{
-  return simgrid::config::get_value<std::string>(OPT_TRACING_COMMENT);
-}
-
-std::string TRACE_get_comment_file()
-{
-  return simgrid::config::get_value<std::string>(OPT_TRACING_COMMENT_FILE);
-}
-
 int TRACE_precision ()
 {
   return simgrid::config::get_value<int>(OPT_TRACING_PRECISION);
index 45fafca..626fba2 100644 (file)
@@ -77,7 +77,7 @@ void VariableEvent::print()
   if (trace_format != simgrid::instr::TraceFormat::Paje)
     return;
 
-  stream_ << " " << value;
+  stream_ << " " << value_;
 
   XBT_DEBUG("Dump %s", stream_.str().c_str());
   tracing_file << stream_.str() << std::endl;
index eb4041e..87ed434 100644 (file)
@@ -53,11 +53,11 @@ public:
 };
 
 class VariableEvent : public PajeEvent {
-  double value;
+  double value_;
 
 public:
   VariableEvent(double timestamp, Container* container, Type* type, e_event_type event_type, double value)
-      : PajeEvent::PajeEvent(container, type, timestamp, event_type), value(value)
+      : PajeEvent::PajeEvent(container, type, timestamp, event_type), value_(value)
   {
   }
   void print() override;
index b3472d0..ee4c602 100644 (file)
@@ -7,8 +7,6 @@
 #include "simgrid/sg_config.hpp"
 #include "src/instr/instr_private.hpp"
 
-XBT_LOG_NEW_DEFAULT_SUBCATEGORY(instr_paje_header, instr, "Paje tracing event system (header)");
-
 extern std::ofstream tracing_file;
 
 static void TRACE_header_PajeDefineContainerType(bool basic)
@@ -244,7 +242,6 @@ static void TRACE_header_PajeNewEvent()
 
 void TRACE_header(bool basic, int size)
 {
-  XBT_DEBUG ("Define paje header");
   TRACE_header_PajeDefineContainerType(basic);
   TRACE_header_PajeDefineVariableType(basic);
   TRACE_header_PajeDefineStateType(basic);
index 04445d2..49aa668 100644 (file)
@@ -27,19 +27,17 @@ void dump_comment_file(std::string filename)
 {
   if (filename.empty())
     return;
-  std::ifstream* fs = new std::ifstream();
-  fs->open(filename.c_str(), std::ifstream::in);
+  std::ifstream fs(filename.c_str(), std::ifstream::in);
 
-  if (fs->fail()) {
+  if (fs.fail())
     THROWF(system_error, 1, "Comment file %s could not be opened for reading.", filename.c_str());
-  }
-  while (not fs->eof()) {
+
+  while (not fs.eof()) {
     std::string line;
-    tracing_file << "# ";
-    std::getline(*fs, line);
-    tracing_file << line;
+    std::getline(fs, line);
+    tracing_file << "# " << line;
   }
-  fs->close();
+  fs.close();
 }
 
 double TRACE_last_timestamp_to_dump = 0;
@@ -55,7 +53,7 @@ void TRACE_paje_dump_buffer(bool force)
       delete event;
     }
     buffer.clear();
-  }else{
+  } else {
     std::vector<simgrid::instr::PajeEvent*>::iterator i = buffer.begin();
     for (auto const& event : buffer) {
       double head_timestamp = event->timestamp_;
index 4e69e78..e83b762 100644 (file)
@@ -236,11 +236,8 @@ XBT_PUBLIC bool TRACE_smpi_is_computing();
 XBT_PUBLIC bool TRACE_smpi_is_sleeping();
 XBT_PUBLIC bool TRACE_smpi_view_internals();
 
-/* from resource_utilization.c */
 XBT_PRIVATE void TRACE_surf_resource_set_utilization(const char* type, const char* name, const char* resource,
                                                      const char* category, double value, double now, double delta);
-XBT_PRIVATE void TRACE_surf_link_set_utilization(const char* resource, const char* category, double value, double now,
-                                                 double delta);
 
 /* instr_paje.c */
 extern XBT_PRIVATE std::set<std::string> trivaNodeTypes;
@@ -259,8 +256,6 @@ XBT_PRIVATE void TRACE_paje_dump_buffer(bool force);
 XBT_PRIVATE void dump_comment_file(std::string filename);
 XBT_PRIVATE void dump_comment(std::string comment);
 
-XBT_PRIVATE std::string TRACE_get_comment();
-XBT_PRIVATE std::string TRACE_get_comment_file();
 XBT_PRIVATE std::string TRACE_get_filename();
 
 #endif
index 699541d..ace1ff0 100644 (file)
@@ -30,9 +30,3 @@ void TRACE_surf_resource_set_utilization(const char* type, const char* name, con
     container->get_variable(name)->instr_event(now, delta, resource, value);
   }
 }
-
-/* TRACE_surf_link_set_utilization: entry point from SimGrid */
-void TRACE_surf_link_set_utilization(const char* resource, const char* category, double value, double now, double delta)
-{
-  TRACE_surf_resource_set_utilization("LINK", "bandwidth_used", resource, category, value, now, delta);
-}
index 6a56dbd..ce78407 100644 (file)
@@ -234,8 +234,8 @@ void NetworkNS3Model::update_actions_state(double now, double delta)
 
       action->src_->routeTo(action->dst_, route, nullptr);
       for (auto const& link : route)
-        TRACE_surf_link_set_utilization(link->get_cname(), action->get_category(), (data_delta_sent) / delta,
-                                        now - delta, delta);
+        TRACE_surf_resource_set_utilization("LINK", "bandwidth_used", link->get_cname(), action->get_category(),
+                                            (data_delta_sent) / delta, now - delta, delta);
 
       action->lastSent_ = sgFlow->sentBytes_;
     }