src/smpi/internals/SmpiHost.cpp

   1 /* Copyright (c) 2017. The SimGrid Team. All rights reserved.               */
   2
   3 /* This program is free software; you can redistribute it and/or modify it
   4  * under the terms of the license (GNU LGPL) which comes with this package. */
   5
   6 #include "SmpiHost.hpp"
   7 #include "simgrid/s4u/VirtualMachine.hpp"
   8 #include "smpi_utils.hpp"
   9
  10 #include <string>
  11 #include <vector>
  12 #include <xbt/log.h>
  13
  14 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(smpi_host, smpi, "Logging specific to SMPI (host)");
  15
  16 namespace simgrid {
  17 namespace smpi {
  18
  19 simgrid::xbt::Extension<simgrid::s4u::Host, SmpiHost> SmpiHost::EXTENSION_ID;
  20
  21 double SmpiHost::orecv(size_t size)
  22 {
  23   double current = orecv_parsed_values.empty() ? 0.0 : orecv_parsed_values.front().values[0] +
  24                                                            orecv_parsed_values.front().values[1] * size;
  25
  26   // Iterate over all the sections that were specified and find the right value. (fact.factor represents the interval
  27   // sizes; we want to find the section that has fact.factor <= size and no other such fact.factor <= size)
  28   // Note: parse_factor() (used before) already sorts the vector we iterate over!
  29   for (auto const& fact : orecv_parsed_values) {
  30     if (size <= fact.factor) { // Values already too large, use the previously computed value of current!
  31       XBT_DEBUG("or : %zu <= %zu return %.10f", size, fact.factor, current);
  32       return current;
  33     } else {
  34       // If the next section is too large, the current section must be used.
  35       // Hence, save the cost, as we might have to use it.
  36       current=fact.values[0]+fact.values[1]*size;
  37     }
  38   }
  39   XBT_DEBUG("smpi_or: %zu is larger than largest boundary, return %.10f", size, current);
  40
  41   return current;
  42 }
  43
  44 double SmpiHost::osend(size_t size)
  45 {
  46   double current =
  47       osend_parsed_values.empty() ? 0.0 : osend_parsed_values[0].values[0] + osend_parsed_values[0].values[1] * size;
  48   // Iterate over all the sections that were specified and find the right
  49   // value. (fact.factor represents the interval sizes; we want to find the
  50   // section that has fact.factor <= size and no other such fact.factor <= size)
  51   // Note: parse_factor() (used before) already sorts the vector we iterate over!
  52   for (auto const& fact : osend_parsed_values) {
  53     if (size <= fact.factor) { // Values already too large, use the previously computed value of current!
  54       XBT_DEBUG("os : %zu <= %zu return %.10f", size, fact.factor, current);
  55       return current;
  56     } else {
  57       // If the next section is too large, the current section must be used.
  58       // Hence, save the cost, as we might have to use it.
  59       current = fact.values[0] + fact.values[1] * size;
  60     }
  61   }
  62   XBT_DEBUG("Searching for smpi/os: %zu is larger than the largest boundary, return %.10f", size, current);
  63
  64   return current;
  65 }
  66
  67 double SmpiHost::oisend(size_t size)
  68 {
  69   double current =
  70       oisend_parsed_values.empty() ? 0.0 : oisend_parsed_values[0].values[0] + oisend_parsed_values[0].values[1] * size;
  71
  72   // Iterate over all the sections that were specified and find the right value. (fact.factor represents the interval
  73   // sizes; we want to find the section that has fact.factor <= size and no other such fact.factor <= size)
  74   // Note: parse_factor() (used before) already sorts the vector we iterate over!
  75   for (auto const& fact : oisend_parsed_values) {
  76     if (size <= fact.factor) { // Values already too large, use the previously  computed value of current!
  77       XBT_DEBUG("ois : %zu <= %zu return %.10f", size, fact.factor, current);
  78       return current;
  79     } else {
  80       // If the next section is too large, the current section must be used.
  81       // Hence, save the cost, as we might have to use it.
  82       current = fact.values[0] + fact.values[1] * size;
  83     }
  84   }
  85   XBT_DEBUG("Searching for smpi/ois: %zu is larger than the largest boundary, return %.10f", size, current);
  86
  87   return current;
  88 }
  89
  90 SmpiHost::SmpiHost(simgrid::s4u::Host *ptr) : host(ptr)
  91 {
  92   if (not SmpiHost::EXTENSION_ID.valid())
  93     SmpiHost::EXTENSION_ID = simgrid::s4u::Host::extension_create<SmpiHost>();
  94
  95   const char* orecv_string = host->getProperty("smpi/or");
  96   if (orecv_string != nullptr) {
  97     orecv_parsed_values = parse_factor(orecv_string);
  98   } else {
  99     orecv_parsed_values = parse_factor(xbt_cfg_get_string("smpi/or"));
 100   }
 101
 102   const char* osend_string = host->getProperty("smpi/os");
 103   if (osend_string != nullptr) {
 104     osend_parsed_values = parse_factor(osend_string);
 105   } else {
 106     osend_parsed_values = parse_factor(xbt_cfg_get_string("smpi/os"));
 107   }
 108
 109   const char* oisend_string = host->getProperty("smpi/ois");
 110   if (oisend_string != nullptr) {
 111     oisend_parsed_values = parse_factor(oisend_string);
 112   } else {
 113     oisend_parsed_values = parse_factor(xbt_cfg_get_string("smpi/ois"));
 114   }
 115 }
 116
 117 SmpiHost::~SmpiHost()=default;
 118 }
 119 }