1 /* Copyright (c) 2017-2021. The SimGrid Team. All rights reserved. */
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. */
6 #include "smpi_host.hpp"
7 #include "simgrid/s4u/VirtualMachine.hpp"
8 #include "smpi_utils.hpp"
9 #include "xbt/config.hpp"
15 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(smpi_host, smpi, "Logging specific to SMPI (host)");
20 xbt::Extension<s4u::Host, smpi::Host> Host::EXTENSION_ID;
22 double Host::orecv(size_t size)
24 double current = orecv_parsed_values.empty() ? 0.0 : orecv_parsed_values.front().values[0] +
25 orecv_parsed_values.front().values[1] * size;
27 // Iterate over all the sections that were specified and find the right value. (fact.factor represents the interval
28 // sizes; we want to find the section that has fact.factor <= size and no other such fact.factor <= size)
29 // Note: parse_factor() (used before) already sorts the vector we iterate over!
30 for (auto const& fact : orecv_parsed_values) {
31 if (size <= fact.factor) { // Values already too large, use the previously computed value of current!
32 XBT_DEBUG("or : %zu <= %zu return %.10f", size, fact.factor, current);
35 // If the next section is too large, the current section must be used.
36 // Hence, save the cost, as we might have to use it.
37 current=fact.values[0]+fact.values[1]*size;
40 XBT_DEBUG("smpi_or: %zu is larger than largest boundary, return %.10f", size, current);
45 double Host::osend(size_t size)
48 osend_parsed_values.empty() ? 0.0 : osend_parsed_values[0].values[0] + osend_parsed_values[0].values[1] * size;
49 // Iterate over all the sections that were specified and find the right value. (fact.factor represents the interval
50 // sizes; we want to find the 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);
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;
62 XBT_DEBUG("Searching for smpi/os: %zu is larger than the largest boundary, return %.10f", size, current);
67 double Host::oisend(size_t size)
70 oisend_parsed_values.empty() ? 0.0 : oisend_parsed_values[0].values[0] + oisend_parsed_values[0].values[1] * size;
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);
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;
85 XBT_DEBUG("Searching for smpi/ois: %zu is larger than the largest boundary, return %.10f", size, current);
90 Host::Host(s4u::Host* ptr) : host(ptr)
92 if (not smpi::Host::EXTENSION_ID.valid())
93 smpi::Host::EXTENSION_ID = s4u::Host::extension_create<Host>();
95 const char* orecv_string = host->get_property("smpi/or");
96 if (orecv_string != nullptr) {
97 orecv_parsed_values = simgrid::smpi::utils::parse_factor(orecv_string);
99 orecv_parsed_values = simgrid::smpi::utils::parse_factor(config::get_value<std::string>("smpi/or"));
102 const char* osend_string = host->get_property("smpi/os");
103 if (osend_string != nullptr) {
104 osend_parsed_values = simgrid::smpi::utils::parse_factor(osend_string);
106 osend_parsed_values = simgrid::smpi::utils::parse_factor(config::get_value<std::string>("smpi/os"));
109 const char* oisend_string = host->get_property("smpi/ois");
110 if (oisend_string != nullptr) {
111 oisend_parsed_values = simgrid::smpi::utils::parse_factor(oisend_string);
113 oisend_parsed_values = simgrid::smpi::utils::parse_factor(config::get_value<std::string>("smpi/ois"));
118 } // namespace simgrid