Logo AND Algorithmique Numérique Distribuée

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