src/s4u/s4u_link.cpp

   1 /* Copyright (c) 2013-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 <algorithm>
   7
   8 #include "simgrid/s4u/Link.hpp"
   9 #include "simgrid/sg_config.h"
  10 #include "simgrid/simix.hpp"
  11 #include "src/surf/network_interface.hpp"
  12 #include "xbt/log.h"
  13
  14 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(s4u_link, s4u, "Logging specific to the S4U links");
  15
  16 /*********
  17  * C API *
  18  *********/
  19
  20 extern "C" {
  21
  22 const char* sg_link_name(sg_link_t link)
  23 {
  24   return link->getCname();
  25 }
  26 sg_link_t sg_link_by_name(const char* name)
  27 {
  28   return simgrid::s4u::Link::byName(name);
  29 }
  30
  31 int sg_link_is_shared(sg_link_t link)
  32 {
  33   return link->sharingPolicy();
  34 }
  35 double sg_link_bandwidth(sg_link_t link)
  36 {
  37   return link->bandwidth();
  38 }
  39 double sg_link_latency(sg_link_t link)
  40 {
  41   return link->latency();
  42 }
  43 void* sg_link_data(sg_link_t link)
  44 {
  45   return link->getData();
  46 }
  47 void sg_link_data_set(sg_link_t link, void* data)
  48 {
  49   link->setData(data);
  50 }
  51 int sg_link_count()
  52 {
  53   return simgrid::surf::LinkImpl::linksCount();
  54 }
  55 sg_link_t* sg_link_list()
  56 {
  57   simgrid::surf::LinkImpl** list = simgrid::surf::LinkImpl::linksList();
  58   sg_link_t* res                 = (sg_link_t*)list; // Use the same memory area
  59
  60   int size = sg_link_count();
  61   for (int i = 0; i < size; i++)
  62     res[i] = &(list[i]->piface_); // Convert each entry into its interface
  63
  64   return res;
  65 }
  66 void sg_link_exit()
  67 {
  68   simgrid::surf::LinkImpl::linksExit();
  69 }
  70 }
  71
  72 /***********
  73  * C++ API *
  74  ***********/
  75
  76 namespace simgrid {
  77 namespace s4u {
  78 Link* Link::byName(const char* name)
  79 {
  80   surf::LinkImpl* res = surf::LinkImpl::byName(name);
  81   if (res == nullptr)
  82     return nullptr;
  83   return &res->piface_;
  84 }
  85 const std::string& Link::getName() const
  86 {
  87   return this->pimpl_->getName();
  88 }
  89 const char* Link::getCname() const
  90 {
  91   return this->pimpl_->getCname();
  92 }
  93 bool Link::isUsed()
  94 {
  95   return this->pimpl_->isUsed();
  96 }
  97
  98 double Link::latency()
  99 {
 100   return this->pimpl_->latency();
 101 }
 102
 103 double Link::bandwidth()
 104 {
 105   return this->pimpl_->bandwidth();
 106 }
 107
 108 int Link::sharingPolicy()
 109 {
 110   return this->pimpl_->sharingPolicy();
 111 }
 112
 113 void Link::turnOn()
 114 {
 115   simgrid::simix::kernelImmediate([this]() {
 116     this->pimpl_->turnOn();
 117   });
 118 }
 119 void Link::turnOff()
 120 {
 121   simgrid::simix::kernelImmediate([this]() {
 122     this->pimpl_->turnOff();
 123   });
 124 }
 125
 126 void* Link::getData()
 127 {
 128   return this->pimpl_->getData();
 129 }
 130 void Link::setData(void* d)
 131 {
 132   simgrid::simix::kernelImmediate([this, d]() {
 133     this->pimpl_->setData(d);
 134   });
 135 }
 136
 137 void Link::setStateTrace(tmgr_trace_t trace)
 138 {
 139   simgrid::simix::kernelImmediate([this, trace]() {
 140     this->pimpl_->setStateTrace(trace);
 141   });
 142 }
 143 void Link::setBandwidthTrace(tmgr_trace_t trace)
 144 {
 145   simgrid::simix::kernelImmediate([this, trace]() {
 146     this->pimpl_->setBandwidthTrace(trace);
 147   });
 148 }
 149 void Link::setLatencyTrace(tmgr_trace_t trace)
 150 {
 151   simgrid::simix::kernelImmediate([this, trace]() {
 152     this->pimpl_->setLatencyTrace(trace);
 153   });
 154 }
 155
 156 /*************
 157  * Callbacks *
 158  *************/
 159 simgrid::xbt::signal<void(s4u::Link&)> Link::onCreation;
 160 simgrid::xbt::signal<void(s4u::Link&)> Link::onDestruction;
 161 simgrid::xbt::signal<void(s4u::Link&)> Link::onStateChange;
 162 simgrid::xbt::signal<void(surf::NetworkAction*, s4u::Host* src, s4u::Host* dst)> Link::onCommunicate;
 163 simgrid::xbt::signal<void(surf::NetworkAction*)> Link::onCommunicationStateChange;
 164 }
 165 }