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) networkLinkStateChangedCallbacks;
  23 surf_callback(void, NetworkActionPtr) networkActionStateChangedCallbacks;
  24
  25 /*********
  26  * Model *
  27  *********/
  28
  29 NetworkModelPtr surf_network_model = NULL;
  30
  31 double NetworkModel::latencyFactor(double /*size*/) {
  32   return sg_latency_factor;
  33 }
  34
  35 double NetworkModel::bandwidthFactor(double /*size*/) {
  36   return sg_bandwidth_factor;
  37 }
  38
  39 double NetworkModel::bandwidthConstraint(double rate, double /*bound*/, double /*size*/) {
  40   return rate;
  41 }
  42
  43 /************
  44  * Resource *
  45  ************/
  46
  47 NetworkLink::NetworkLink(NetworkModelPtr model, const char *name, xbt_dict_t props)
  48 : Resource(model, name, props)
  49 , p_latEvent(NULL)
  50 {
  51   surf_callback_emit(networkLinkCreatedCallbacks, this);
  52 }
  53
  54 NetworkLink::NetworkLink(NetworkModelPtr model, const char *name, xbt_dict_t props,
  55                                  lmm_constraint_t constraint,
  56                              tmgr_history_t history,
  57                              tmgr_trace_t state_trace)
  58 : Resource(model, name, props, constraint),
  59   p_latEvent(NULL)
  60 {
  61   surf_callback_emit(networkLinkCreatedCallbacks, this);
  62   if (state_trace)
  63     p_stateEvent = tmgr_history_add_trace(history, state_trace, 0.0, 0, static_cast<ResourcePtr>(this));
  64 }
  65
  66 NetworkLink::~NetworkLink()
  67 {
  68   surf_callback_emit(networkLinkDestructedCallbacks, this);
  69 }
  70
  71 bool NetworkLink::isUsed()
  72 {
  73   return lmm_constraint_used(getModel()->getMaxminSystem(), getConstraint());
  74 }
  75
  76 double NetworkLink::getLatency()
  77 {
  78   return m_latCurrent;
  79 }
  80
  81 double NetworkLink::getBandwidth()
  82 {
  83   return p_power.peak * p_power.scale;
  84 }
  85
  86 bool NetworkLink::isShared()
  87 {
  88   return lmm_constraint_is_shared(getConstraint());
  89 }
  90
  91 void NetworkLink::setState(e_surf_resource_state_t state){
  92   Resource::setState(state);
  93   surf_callback_emit(networkLinkStateChangedCallbacks, this);
  94 }
  95
  96 /**********
  97  * Action *
  98  **********/
  99
 100 void NetworkAction::setState(e_surf_action_state_t state){
 101   Action::setState(state);
 102   surf_callback_emit(networkActionStateChangedCallbacks, this);
 103 }
 104
 105 #endif /* NETWORK_INTERFACE_CPP_ */