src/surf/network_interface.cpp

   1 /* Copyright (c) 2013-2014. The SimGrid Team.
   2  * All rights reserved.                                                     */
   3
   4 /* This program is free software; you can redistribute it and/or modify it
   5  * under the terms of the license (GNU LGPL) which comes with this package. */
   6
   7 #include "network_interface.hpp"
   8 #include "simgrid/sg_config.h"
   9
  10 #ifndef NETWORK_INTERFACE_CPP_
  11 #define NETWORK_INTERFACE_CPP_
  12
  13 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(surf_network, surf,
  14                                 "Logging specific to the SURF network module");
  15
  16 /*************
  17  * Callbacks *
  18  *************/
  19
  20 surf_callback(void, NetworkLinkPtr) networkLinkCreatedCallbacks;
  21 surf_callback(void, NetworkLinkPtr) networkLinkDestructedCallbacks;
  22 surf_callback(void, NetworkLinkPtr, e_surf_resource_state_t, e_surf_resource_state_t) networkLinkStateChangedCallbacks;
  23 surf_callback(void, NetworkActionPtr, e_surf_action_state_t, e_surf_action_state_t) networkActionStateChangedCallbacks;
  24 surf_callback(void, NetworkActionPtr, RoutingEdgePtr src, RoutingEdgePtr dst, double size, double rate) networkCommunicateCallbacks;
  25
  26 /*********
  27  * Model *
  28  *********/
  29
  30 NetworkModelPtr surf_network_model = NULL;
  31
  32 double NetworkModel::latencyFactor(double /*size*/) {
  33   return sg_latency_factor;
  34 }
  35
  36 double NetworkModel::bandwidthFactor(double /*size*/) {
  37   return sg_bandwidth_factor;
  38 }
  39
  40 double NetworkModel::bandwidthConstraint(double rate, double /*bound*/, double /*size*/) {
  41   return rate;
  42 }
  43
  44 /************
  45  * Resource *
  46  ************/
  47
  48 NetworkLink::NetworkLink(NetworkModelPtr model, const char *name, xbt_dict_t props)
  49 : Resource(model, name, props)
  50 , p_latEvent(NULL)
  51 {
  52   surf_callback_emit(networkLinkCreatedCallbacks, this);
  53 }
  54
  55 NetworkLink::NetworkLink(NetworkModelPtr model, const char *name, xbt_dict_t props,
  56                                  lmm_constraint_t constraint,
  57                              tmgr_history_t history,
  58                              tmgr_trace_t state_trace)
  59 : Resource(model, name, props, constraint),
  60   p_latEvent(NULL)
  61 {
  62   surf_callback_emit(networkLinkCreatedCallbacks, this);
  63   if (state_trace)
  64     p_stateEvent = tmgr_history_add_trace(history, state_trace, 0.0, 0, static_cast<ResourcePtr>(this));
  65 }
  66
  67 NetworkLink::~NetworkLink()
  68 {
  69   surf_callback_emit(networkLinkDestructedCallbacks, this);
  70 }
  71
  72 bool NetworkLink::isUsed()
  73 {
  74   return lmm_constraint_used(getModel()->getMaxminSystem(), getConstraint());
  75 }
  76
  77 double NetworkLink::getLatency()
  78 {
  79   return m_latCurrent;
  80 }
  81
  82 double NetworkLink::getBandwidth()
  83 {
  84   return p_power.peak * p_power.scale;
  85 }
  86
  87 bool NetworkLink::isShared()
  88 {
  89   return lmm_constraint_is_shared(getConstraint());
  90 }
  91
  92 void NetworkLink::setState(e_surf_resource_state_t state){
  93   e_surf_resource_state_t old = Resource::getState();
  94   Resource::setState(state);
  95   surf_callback_emit(networkLinkStateChangedCallbacks, this, old, state);
  96 }
  97
  98 /**********
  99  * Action *
 100  **********/
 101
 102 void NetworkAction::setState(e_surf_action_state_t state){
 103   e_surf_action_state_t old = getState();
 104   Action::setState(state);
 105   surf_callback_emit(networkActionStateChangedCallbacks, this, old, state);
 106 }
 107
 108 #endif /* NETWORK_INTERFACE_CPP_ */