4 #include "surf_routing.hpp"
6 #ifndef SURF_MODEL_NETWORK_H_
7 #define SURF_MODEL_NETWORK_H_
12 class NetworkCm02Model;
13 typedef NetworkCm02Model *NetworkCm02ModelPtr;
15 class NetworkCm02Link;
16 typedef NetworkCm02Link *NetworkCm02LinkPtr;
18 class NetworkCm02LinkLmm;
19 typedef NetworkCm02LinkLmm *NetworkCm02LinkLmmPtr;
21 class NetworkCm02Action;
22 typedef NetworkCm02Action *NetworkCm02ActionPtr;
24 class NetworkCm02ActionLmm;
25 typedef NetworkCm02ActionLmm *NetworkCm02ActionLmmPtr;
30 extern NetworkCm02ModelPtr surf_network_model;
32 void net_define_callbacks(void);
37 class NetworkCm02Model : public Model {
41 NetworkCm02Model(int /*i*/) : Model("network") {
42 f_networkSolve = lmm_solve;
44 };//FIXME: add network clean interface
45 NetworkCm02Model(string name) : Model(name) {
48 NetworkCm02Model() : Model("network") {
52 lmm_system_free(p_maxminSystem);
54 xbt_heap_free(p_actionHeap);
56 xbt_swag_free(p_modifiedSet);
58 //FIXME:NetworkCm02LinkPtr createResource(string name);
59 NetworkCm02LinkLmmPtr createResource(const char *name,
61 tmgr_trace_t bw_trace,
63 tmgr_trace_t lat_trace,
64 e_surf_resource_state_t state_initial,
65 tmgr_trace_t state_trace,
66 e_surf_link_sharing_policy_t policy,
67 xbt_dict_t properties);
68 void updateActionsStateLazy(double now, double delta);
69 virtual void gapAppend(double /*size*/, const NetworkCm02LinkLmmPtr /*link*/, NetworkCm02ActionLmmPtr /*action*/) {};
70 virtual ActionPtr communicate(RoutingEdgePtr src, RoutingEdgePtr dst,
71 double size, double rate);
72 xbt_dynar_t getRoute(RoutingEdgePtr src, RoutingEdgePtr dst); //FIXME: kill field? That is done by the routing nowadays
73 //FIXME: virtual void addTraces() =0;
74 void (*f_networkSolve)(lmm_system_t);
75 virtual double latencyFactor(double size);
76 virtual double bandwidthFactor(double size);
77 virtual double bandwidthConstraint(double rate, double bound, double size);
85 class NetworkCm02Link : virtual public Resource {
87 NetworkCm02Link() : p_latEvent(NULL) {};
88 NetworkCm02Link(NetworkCm02ModelPtr model, const char* name, xbt_dict_t properties)
89 : Resource(model, name, properties), p_latEvent(NULL) {};
90 virtual double getBandwidth()=0;
91 virtual double getLatency();
92 virtual bool isShared()=0;
93 /* Using this object with the public part of
94 model does not make sense */
96 tmgr_trace_event_t p_latEvent;
99 class NetworkCm02LinkLmm : public ResourceLmm, public NetworkCm02Link {
101 NetworkCm02LinkLmm(NetworkCm02ModelPtr model, const char* name, xbt_dict_t properties)
102 : ResourceLmm(), NetworkCm02Link(model, name, properties) {};
103 NetworkCm02LinkLmm(NetworkCm02ModelPtr model, const char *name, xbt_dict_t props,
105 double constraint_value,
106 tmgr_history_t history,
107 e_surf_resource_state_t state_init,
108 tmgr_trace_t state_trace,
110 tmgr_trace_t metric_trace,
112 tmgr_trace_t lat_trace,
113 e_surf_link_sharing_policy_t policy);
116 double getBandwidth();
117 void updateState(tmgr_trace_event_t event_type, double value, double date);
124 class NetworkCm02Action : virtual public Action {
126 NetworkCm02Action(ModelPtr model, double cost, bool failed)
127 : Action(model, cost, failed) {};
132 const char* p_senderLinkName;
135 xbt_fifo_item_t p_senderFifoItem;
136 #ifdef HAVE_LATENCY_BOUND_TRACKING
137 int m_latencyLimited;
142 class NetworkCm02ActionLmm : public ActionLmm, public NetworkCm02Action {
144 NetworkCm02ActionLmm(ModelPtr model, double cost, bool failed)
145 : Action(model, cost, failed),
146 ActionLmm(model, cost, failed),
147 NetworkCm02Action(model, cost, failed) {};
148 void updateRemainingLazy(double now);
152 #endif /* SURF_MODEL_NETWORK_H_ */