X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/7da2926d0733ff0683f31aeea176ce71e127264f..e597737e01b6ac76d6e9ccdf67a85c03c53de7c3:/src/surf/network_ns3.hpp diff --git a/src/surf/network_ns3.hpp b/src/surf/network_ns3.hpp index f452d94d9e..6059c2df83 100644 --- a/src/surf/network_ns3.hpp +++ b/src/surf/network_ns3.hpp @@ -7,93 +7,60 @@ #include #include "network_interface.hpp" -#include "surf/ns3/ns3_interface.h" +#include "src/surf/ns3/ns3_interface.h" #ifndef NETWORK_NS3_HPP_ #define NETWORK_NS3_HPP_ -/*********** - * Classes * - ***********/ -class XBT_PRIVATE NetworkNS3Model; -class XBT_PRIVATE NetworkNS3Action; +namespace simgrid { +namespace surf { -/********* - * Tools * - *********/ - -XBT_PRIVATE void net_define_callbacks(void); - -/********* - * Model * - *********/ - -class NetworkNS3Model : public NetworkModel { +class XBT_PRIVATE NetworkNS3Model : public NetworkModel { public: NetworkNS3Model(); - ~NetworkNS3Model(); - Link* createLink(const char *name, - double bw_initial, - tmgr_trace_t bw_trace, - double lat_initial, - tmgr_trace_t lat_trace, - e_surf_resource_state_t state_initial, - tmgr_trace_t state_trace, - e_surf_link_sharing_policy_t policy, - xbt_dict_t properties); - xbt_dynar_t getRoute(RoutingEdge *src, RoutingEdge *dst); - Action *communicate(RoutingEdge *src, RoutingEdge *dst, - double size, double rate); - double shareResources(double now); - void updateActionsState(double now, double delta); - void addTraces(){DIE_IMPOSSIBLE;} - bool shareResourcesIsIdempotent() {return false;} + Link* createLink(const char *name, double bandwidth, double latency, + e_surf_link_sharing_policy_t policy, xbt_dict_t properties) override; + Action *communicate(NetCard *src, NetCard *dst, double size, double rate); + double next_occuring_event(double now) override; + bool next_occuring_event_isIdempotent() {return false;} + void updateActionsState(double now, double delta) override; }; /************ * Resource * ************/ -class NetworkNS3Link : public Link { +class LinkNS3 : public Link { public: - NetworkNS3Link(NetworkNS3Model *model, const char *name, xbt_dict_t props, - double bw_initial, double lat_initial); - ~NetworkNS3Link(); - - void updateState(tmgr_trace_event_t event_type, double value, double date); - double getLatency(){THROW_UNIMPLEMENTED;} - double getBandwidth(){THROW_UNIMPLEMENTED;} - void updateBandwidth(double value, double date=surf_get_clock()){THROW_UNIMPLEMENTED;} - void updateLatency(double value, double date=surf_get_clock()){THROW_UNIMPLEMENTED;} - -//private: - char *p_id; - char *p_lat; - char *p_bdw; - int m_created; + LinkNS3(NetworkNS3Model *model, const char *name, xbt_dict_t props, double bandwidth, double latency); + ~LinkNS3(); + + void apply_event(tmgr_trace_iterator_t event, double value) override; + void updateBandwidth(double value) override {THROW_UNIMPLEMENTED;} + void updateLatency(double value) override {THROW_UNIMPLEMENTED;} + void setBandwidthTrace(tmgr_trace_t trace) override; + void setLatencyTrace(tmgr_trace_t trace) override; }; /********** * Action * **********/ -class NetworkNS3Action : public NetworkAction { +class XBT_PRIVATE NetworkNS3Action : public NetworkAction { public: NetworkNS3Action(Model *model, double cost, bool failed); -#ifdef HAVE_LATENCY_BOUND_TRACKING - int getLatencyLimited(); -#endif - bool isSuspended(); int unref(); void suspend(); void resume(); //private: - double m_lastSent; - RoutingEdge *p_srcElm; - RoutingEdge *p_dstElm; + double m_lastSent = 0; + NetCard *p_srcElm; + NetCard *p_dstElm; }; +} +} #endif /* NETWORK_NS3_HPP_ */