X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/772fbe2c6395ac920d8e7907dc39749d458f02b6..9451efc97c14403a6f030ce37a2269b2b9491b7e:/src/surf/surf_interface.hpp diff --git a/src/surf/surf_interface.hpp b/src/surf/surf_interface.hpp index 5a2a7d9bf4..8ab050fd83 100644 --- a/src/surf/surf_interface.hpp +++ b/src/surf/surf_interface.hpp @@ -10,11 +10,12 @@ #include "src/surf/surf_private.h" #include "surf/surf.h" -#include "surf/surf_routing.h" #include "xbt/str.h" #include +#include #include +#include #define NO_MAX_DURATION -1.0 @@ -29,10 +30,12 @@ extern XBT_PRIVATE double sg_latency_factor; extern XBT_PRIVATE double sg_bandwidth_factor; extern XBT_PRIVATE double sg_weight_S_parameter; extern XBT_PRIVATE int sg_network_crosstraffic; -extern XBT_PRIVATE xbt_dynar_t surf_path; +extern XBT_PRIVATE std::vector surf_path; +extern XBT_PRIVATE std::unordered_map traces_set_list; +extern XBT_PRIVATE std::set watched_hosts; extern "C" { -XBT_PUBLIC(double) surf_get_clock(void); +XBT_PUBLIC(double) surf_get_clock(); } /** \ingroup SURF_simulation * \brief List of hosts that have just restarted and whose autorestart process should be restarted. @@ -45,17 +48,12 @@ extern XBT_PRIVATE double sg_sender_gap; namespace simgrid { namespace surf { -extern XBT_PRIVATE simgrid::xbt::signal surfExitCallbacks; - +extern XBT_PRIVATE simgrid::xbt::signal surfExitCallbacks; } } int XBT_PRIVATE __surf_is_absolute_file_path(const char *file_path); -static inline char* sg_storage_name(sg_storage_t storage) { - return storage->key; -} - /*********** * Classes * ***********/ @@ -67,12 +65,6 @@ enum heap_action_type{ NOTSET }; -/********* - * Trace * - *********/ -/* For the trace and trace:connect tag (store their content till the end of the parsing) */ -XBT_PUBLIC_DATA(xbt_dict_t) traces_set_list; - /********** * Action * **********/ @@ -206,9 +198,9 @@ public: void setCategory(const char *category); /** @brief Get the priority of the current Action */ - double getPriority() {return priority_;}; + double getPriority() { return sharingWeight_; }; /** @brief Set the priority of the current Action */ - virtual void setPriority(double priority); + virtual void setSharingWeight(double priority); /** @brief Get the state set in which the action is */ ActionList* getStateSet() {return stateSet_;}; @@ -219,7 +211,7 @@ public: protected: ActionList* stateSet_; - double priority_ = 1.0; /**< priority (1.0 by default) */ + double sharingWeight_ = 1.0; /**< priority (1.0 by default) */ int refcount_ = 1; double remains_; /**< How much of that cost remains to be done in the currently running task */ double maxDuration_ = NO_MAX_DURATION; /*< max_duration (may fluctuate until the task is completed) */ @@ -239,13 +231,12 @@ public: void heapInsert(xbt_heap_t heap, double key, enum heap_action_type hat); void heapRemove(xbt_heap_t heap); void heapUpdate(xbt_heap_t heap, double key, enum heap_action_type hat); - void updateIndexHeap(int i); + virtual void updateIndexHeap(int i); lmm_variable_t getVariable() {return variable_;} double getLastUpdate() {return lastUpdate_;} void refreshLastUpdate() {lastUpdate_ = surf_get_clock();} enum heap_action_type getHat() {return hat_;} bool is_linked() {return action_lmm_hook.is_linked();} - void gapRemove(); protected: lmm_variable_t variable_ = nullptr; @@ -357,7 +348,7 @@ private: typedef struct { double peak; /**< The peak of the metric, ie its max value */ double scale; /**< Current availability of the metric according to the traces, in [0,1] */ - tmgr_trace_iterator_t event; /**< The associated trace event associated to the metric */ + tmgr_trace_event_t event; /**< The associated trace event associated to the metric */ } s_surf_metric_t; namespace simgrid { @@ -394,7 +385,7 @@ public: * @param event What happened * @param value [TODO] */ - virtual void apply_event(tmgr_trace_iterator_t event, double value)=0; + virtual void apply_event(tmgr_trace_event_t event, double value) = 0; /** @brief Check if the current Resource is used (if it currently serves an action) */ virtual bool isUsed()=0;