src/surf/network.hpp

   1 #include "surf.hpp"
   2 #include "xbt/fifo.h"
   3 #include "xbt/graph.h"
   4 #include "surf_routing.hpp"
   5
   6 #ifndef SURF_MODEL_NETWORK_H_
   7 #define SURF_MODEL_NETWORK_H_
   8
   9 /***********
  10  * Classes *
  11  ***********/
  12 class NetworkCm02Model;
  13 typedef NetworkCm02Model *NetworkCm02ModelPtr;
  14
  15 class NetworkCm02Link;
  16 typedef NetworkCm02Link *NetworkCm02LinkPtr;
  17
  18 class NetworkCm02LinkLmm;
  19 typedef NetworkCm02LinkLmm *NetworkCm02LinkLmmPtr;
  20
  21 class NetworkCm02Action;
  22 typedef NetworkCm02Action *NetworkCm02ActionPtr;
  23
  24 class NetworkCm02ActionLmm;
  25 typedef NetworkCm02ActionLmm *NetworkCm02ActionLmmPtr;
  26
  27 /*********
  28  * Tools *
  29  *********/
  30 extern NetworkCm02ModelPtr surf_network_model;
  31
  32
  33
  34 /*********
  35  * Model *
  36  *********/
  37 class NetworkCm02Model : public Model {
  38 public:
  39   NetworkCm02Model(string name);
  40   NetworkCm02Model();
  41   //FIXME:NetworkCm02LinkPtr createResource(string name);
  42   NetworkCm02LinkLmmPtr createResource(const char *name,
  43                                    double bw_initial,
  44                                    tmgr_trace_t bw_trace,
  45                                    double lat_initial,
  46                                    tmgr_trace_t lat_trace,
  47                                    e_surf_resource_state_t state_initial,
  48                                    tmgr_trace_t state_trace,
  49                                    e_surf_link_sharing_policy_t policy,
  50                                    xbt_dict_t properties);
  51   void updateActionsStateLazy(double now, double delta);
  52   virtual void gapAppend(double size, const NetworkCm02LinkLmmPtr link, NetworkCm02ActionLmmPtr action) {};
  53   NetworkCm02ActionPtr communicate(RoutingEdgePtr src, RoutingEdgePtr dst,
  54                                            double size, double rate);
  55   xbt_dynar_t getRoute(RoutingEdgePtr src, RoutingEdgePtr dst); //FIXME: kill field? That is done by the routing nowadays
  56   //FIXME: virtual void addTraces() =0;
  57   void (*f_networkSolve)(lmm_system_t) = lmm_solve;
  58   double latencyFactor(double size);
  59   double bandwidthFactor(double size);
  60   double bandwidthConstraint(double rate, double bound, double size);
  61   bool m_haveGap = false;
  62 };
  63
  64 /************
  65  * Resource *
  66  ************/
  67
  68 class NetworkCm02Link : virtual public Resource {
  69 public:
  70   NetworkCm02Link(){};
  71   NetworkCm02Link(NetworkCm02ModelPtr model, const char* name, xbt_dict_t properties) : Resource(model, name, properties) {};
  72   virtual double getBandwidth()=0;
  73   double getLatency();
  74   virtual bool isShared()=0;
  75   /* Using this object with the public part of
  76     model does not make sense */
  77   double m_latCurrent;
  78   tmgr_trace_event_t p_latEvent;
  79 };
  80
  81 class NetworkCm02LinkLmm : public ResourceLmm, public NetworkCm02Link {
  82 public:
  83   NetworkCm02LinkLmm(NetworkCm02ModelPtr model, const char *name, xbt_dict_t props,
  84                                    lmm_system_t system,
  85                                    double constraint_value,
  86                                    tmgr_history_t history,
  87                                    e_surf_resource_state_t state_init,
  88                                    tmgr_trace_t state_trace,
  89                                    double metric_peak,
  90                                    tmgr_trace_t metric_trace,
  91                                    double lat_initial,
  92                                    tmgr_trace_t lat_trace,
  93                                e_surf_link_sharing_policy_t policy);
  94   bool isShared();
  95   bool isUsed();
  96   double getBandwidth();
  97   void updateState(tmgr_trace_event_t event_type, double value, double date);
  98 };
  99
 100
 101 /**********
 102  * Action *
 103  **********/
 104 class NetworkCm02Action : virtual public Action {
 105 public:
 106   NetworkCm02Action(ModelPtr model, double cost, bool failed)
 107  : Action(model, cost, failed) {};
 108   double m_latency;
 109   double m_latCurrent;
 110   double m_weight;
 111   double m_rate;
 112   const char* p_senderLinkName;
 113   double m_senderGap;
 114   double m_senderSize;
 115   xbt_fifo_item_t p_senderFifoItem;
 116 #ifdef HAVE_LATENCY_BOUND_TRACKING
 117   int m_latencyLimited;
 118 #endif
 119
 120 };
 121
 122 class NetworkCm02ActionLmm : public ActionLmm, public NetworkCm02Action {
 123 public:
 124   NetworkCm02ActionLmm(ModelPtr model, double cost, bool failed)
 125  : Action(model, cost, failed),
 126    ActionLmm(model, cost, failed),
 127    NetworkCm02Action(model, cost, failed) {};
 128   void updateRemainingLazy(double now);
 129   void recycle();
 130 };
 131
 132 #endif /* SURF_MODEL_NETWORK_H_ */