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->name();
  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 char* Link::name()
  86 {
  87   return this->pimpl_->cname();
  88 }
  89 bool Link::isUsed()
  90 {
  91   return this->pimpl_->isUsed();
  92 }
  93
  94 double Link::latency()
  95 {
  96   return this->pimpl_->latency();
  97 }
  98
  99 double Link::bandwidth()
 100 {
 101   return this->pimpl_->bandwidth();
 102 }
 103
 104 int Link::sharingPolicy()
 105 {
 106   return this->pimpl_->sharingPolicy();
 107 }
 108
 109 void Link::turnOn()
 110 {
 111   simgrid::simix::kernelImmediate([this]() {
 112     this->pimpl_->turnOn();
 113   });
 114 }
 115 void Link::turnOff()
 116 {
 117   simgrid::simix::kernelImmediate([this]() {
 118     this->pimpl_->turnOff();
 119   });
 120 }
 121
 122 void* Link::getData()
 123 {
 124   return this->pimpl_->getData();
 125 }
 126 void Link::setData(void* d)
 127 {
 128   simgrid::simix::kernelImmediate([this, d]() {
 129     this->pimpl_->setData(d);
 130   });
 131 }
 132
 133 void Link::setStateTrace(tmgr_trace_t trace)
 134 {
 135   simgrid::simix::kernelImmediate([this, trace]() {
 136     this->pimpl_->setStateTrace(trace);
 137   });
 138 }
 139 void Link::setBandwidthTrace(tmgr_trace_t trace)
 140 {
 141   simgrid::simix::kernelImmediate([this, trace]() {
 142     this->pimpl_->setBandwidthTrace(trace);
 143   });
 144 }
 145 void Link::setLatencyTrace(tmgr_trace_t trace)
 146 {
 147   simgrid::simix::kernelImmediate([this, trace]() {
 148     this->pimpl_->setLatencyTrace(trace);
 149   });
 150 }
 151
 152 /*************
 153  * Callbacks *
 154  *************/
 155 simgrid::xbt::signal<void(s4u::Link&)> Link::onCreation;
 156 simgrid::xbt::signal<void(s4u::Link&)> Link::onDestruction;
 157 simgrid::xbt::signal<void(s4u::Link&)> Link::onStateChange;
 158 simgrid::xbt::signal<void(surf::NetworkAction*, s4u::Host* src, s4u::Host* dst)> Link::onCommunicate;
 159 simgrid::xbt::signal<void(surf::NetworkAction*)> Link::onCommunicationStateChange;
 160 }
 161 }