X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/54e35ebda7e4ffacd769653b8ebb8ba93c7298bf..af1adb0177f8402c6fe071f6043d64e009d2b439:/src/surf/network_ns3.hpp diff --git a/src/surf/network_ns3.hpp b/src/surf/network_ns3.hpp index b296eb2347..d7ff3ceffe 100644 --- a/src/surf/network_ns3.hpp +++ b/src/surf/network_ns3.hpp @@ -1,96 +1,66 @@ -/* Copyright (c) 2004-2014. The SimGrid Team. - * All rights reserved. */ +/* Copyright (c) 2004-2017. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ -#include "network_interface.hpp" -#include "surf/ns3/ns3_interface.h" - #ifndef NETWORK_NS3_HPP_ #define NETWORK_NS3_HPP_ -/*********** - * Classes * - ***********/ -class NetworkNS3Model; -class NetworkNS3Action; - -/********* - * Tools * - *********/ +#include "xbt/base.h" -void net_define_callbacks(void); +#include "network_interface.hpp" +#include "src/surf/ns3/ns3_interface.h" -/********* - * Model * - *********/ +namespace simgrid { +namespace surf { class 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;} + LinkImpl* createLink(const char* name, double bandwidth, double latency, + e_surf_link_sharing_policy_t policy) override; + Action* communicate(s4u::Host* src, s4u::Host* dst, double size, double rate) override; + double nextOccuringEvent(double now) override; + bool nextOccuringEventIsIdempotent() {return false;} + void updateActionsState(double now, double delta) override; }; /************ * Resource * ************/ -class NetworkNS3Link : public Link { +class LinkNS3 : public LinkImpl { 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; + explicit LinkNS3(NetworkNS3Model* model, const char* name, double bandwidth, double latency); + ~LinkNS3(); + + void apply_event(tmgr_trace_event_t event, double value) override; + void setBandwidth(double value) override { THROW_UNIMPLEMENTED; } + void setLatency(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; + NetworkNS3Action(Model* model, double cost, s4u::Host* src, s4u::Host* dst); + + bool isSuspended(); + int unref() override; + void suspend() override; + void resume() override; + std::list links() override; + + // private: + double lastSent_ = 0; + s4u::Host* src_; + s4u::Host* dst_; }; +} +} #endif /* NETWORK_NS3_HPP_ */