X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5b3677b425b9cc6949c1573d59ac772540cbf4b2..29cedcb0af274d0dd82224451767e8d01162d734:/src/surf/network_constant.hpp diff --git a/src/surf/network_constant.hpp b/src/surf/network_constant.hpp index 46ac808b14..214993de62 100644 --- a/src/surf/network_constant.hpp +++ b/src/surf/network_constant.hpp @@ -1,82 +1,64 @@ -/* Copyright (c) 2013-2014. The SimGrid Team. +/* Copyright (c) 2013-2015. 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_cm02.hpp" - #ifndef NETWORK_CONSTANT_HPP_ #define NETWORK_CONSTANT_HPP_ -/*********** - * Classes * - ***********/ -class NetworkConstantModel; -typedef NetworkConstantModel *NetworkConstantModelPtr; +#include + +#include "network_interface.hpp" + +namespace simgrid { + namespace surf { + + /*********** + * Classes * + ***********/ + + class XBT_PRIVATE NetworkConstantModel; + class XBT_PRIVATE NetworkConstantAction; -class NetworkConstantLink; -typedef NetworkConstantLink *NetworkConstantLinkPtr; + /********* + * Model * + *********/ + class NetworkConstantModel : public NetworkModel { + public: + NetworkConstantModel() : NetworkModel() { }; + ~NetworkConstantModel() { } -class NetworkConstantAction; -typedef NetworkConstantAction *NetworkConstantActionPtr; + Action *communicate(NetCard *src, NetCard *dst, double size, double rate) override; + double next_occuring_event(double now) override; + bool next_occuring_event_isIdempotent() override {return true;} + void updateActionsState(double now, double delta) override; -/********* - * Model * - *********/ -class NetworkConstantModel : public NetworkCm02Model { -public: - NetworkConstantModel() - : NetworkCm02Model("constant time network") - { - p_updateMechanism = UM_UNDEFINED; - }; - double shareResources(double now); - void updateActionsState(double now, double delta); - ActionPtr communicate(RoutingEdgePtr src, RoutingEdgePtr dst, - double size, double rate); - void gapRemove(ActionPtr action); - //FIXME:virtual void addTraces() =0; -}; + Link* createLink(const char *name, double bw, double lat, e_surf_link_sharing_policy_t policy, xbt_dict_t properties) override; + }; -/************ - * Resource * - ************/ -class NetworkConstantLink : public NetworkCm02Link { -public: - NetworkConstantLink(NetworkCm02ModelPtr model, const char* name, xbt_dict_t properties); - bool isUsed(); - void updateState(tmgr_trace_event_t event_type, double value, double date); - double getBandwidth(); - double getLatency(); - bool isShared(); -}; + /********** + * Action * + **********/ + class NetworkConstantAction : public NetworkAction { + public: + NetworkConstantAction(NetworkConstantModel *model_, double size, double latency) + : NetworkAction(model_, size, false) + , m_latInit(latency) + { + latency_ = latency; + if (latency_ <= 0.0) { + p_stateSet = getModel()->getDoneActionSet(); + p_stateSet->push_back(*this); + } + p_variable = NULL; + }; + int unref() override; + void cancel() override; + double m_latInit; + }; -/********** - * Action * - **********/ -class NetworkConstantAction : public NetworkCm02Action { -public: - NetworkConstantAction(NetworkConstantModelPtr model_, double size, double latency) - : NetworkCm02Action(model_, size, false) - , m_latInit(latency) - { - m_latency = latency; - if (m_latency <= 0.0) { - p_stateSet = getModel()->getDoneActionSet(); - p_stateSet->push_back(*this); - } - p_variable = NULL; - }; - int unref(); - void recycle(); - void cancel(); - void setCategory(const char *category); - void suspend(); - void resume(); - bool isSuspended(); - double m_latInit; - int m_suspended; -}; + } +} #endif /* NETWORK_CONSTANT_HPP_ */