Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Merge commit '045db1657e870c721be490b411868f4181a12ced' into surf++
[simgrid.git] / src / surf / cpu_ti.hpp
1 #include "cpu.hpp"
2 #include "trace_mgr_private.h"
3 #include "surf/surf_routing.h"
4
5 /* Epsilon */
6 #define EPSILON 0.000000001
7
8 /***********
9  * Classes *
10  ***********/
11 class CpuTiTrace;
12 typedef CpuTiTrace *CpuTiTracePtr;
13
14 class CpuTiTgmr;
15 typedef CpuTiTgmr *CpuTiTgmrPtr;
16
17 class CpuTiModel;
18 typedef CpuTiModel *CpuTiModelPtr;
19
20 class CpuTi;
21 typedef CpuTi *CpuTiPtr;
22
23 class CpuTiAction;
24 typedef CpuTiAction *CpuTiActionPtr;
25
26 /*********
27  * Trace *
28  *********/
29 class CpuTiTrace {
30 public:
31   CpuTiTrace(tmgr_trace_t powerTrace);
32   ~CpuTiTrace();
33
34   double integrateSimple(double a, double b);
35   double integrateSimplePoint(double a);
36   double solveSimple(double a, double amount);
37
38   double *p_timePoints;
39   double *p_integral;
40   int m_nbPoints;
41   int binarySearch(double *array, double a, int low, int high);
42
43 private:
44 };
45
46 enum trace_type {
47   
48   TRACE_FIXED,                /*< Trace fixed, no availability file */
49   TRACE_DYNAMIC               /*< Dynamic, availability file disponible */
50 };
51
52 class CpuTiTgmr {
53 public:
54   CpuTiTgmr(trace_type type, double value): m_type(type), m_value(value){};
55   CpuTiTgmr(tmgr_trace_t power_trace, double value);
56   ~CpuTiTgmr();
57
58   double integrate(double a, double b);
59   double solve(double a, double amount);
60   double solveSomewhatSimple(double a, double amount);
61   double getPowerScale(double a);
62
63   trace_type m_type;
64   double m_value;                 /*< Percentage of cpu power disponible. Value fixed between 0 and 1 */
65
66   /* Dynamic */
67   double m_lastTime;             /*< Integral interval last point (discret time) */
68   double m_total;                 /*< Integral total between 0 and last_pointn */
69
70   CpuTiTracePtr p_trace;
71   tmgr_trace_t p_powerTrace;
72 };
73
74
75 /*********
76  * Model *
77  *********/
78 class CpuTiModel : public CpuModel {
79 public:
80   CpuTiModel();
81   ~CpuTiModel();
82
83   void parseInit(sg_platf_host_cbarg_t host);
84   CpuTiPtr createResource(const char *name,  xbt_dynar_t powerPeak,
85                           int pstate, double power_scale,
86                           tmgr_trace_t power_trace, int core,
87                           e_surf_resource_state_t state_initial,
88                           tmgr_trace_t state_trace,
89                           xbt_dict_t cpu_properties);
90   CpuTiActionPtr createAction(double cost, bool failed);
91   double shareResources(double now);
92   void updateActionsState(double now, double delta);
93   void addTraces();
94
95 protected:
96   void NotifyResourceTurnedOn(ResourcePtr r){};
97   void NotifyResourceTurnedOff(ResourcePtr r){};
98
99   void NotifyActionCancel(ActionPtr a){};
100   void NotifyActionResume(ActionPtr a){};
101   void NotifyActionSuspend(ActionPtr a){};
102 };
103
104 /************
105  * Resource *
106  ************/
107 class CpuTi : public Cpu {
108 public:
109   CpuTi() {};
110   CpuTi(CpuTiModelPtr model, const char *name, xbt_dynar_t powerPeak,
111         int pstate, double powerScale, tmgr_trace_t powerTrace, int core,
112         e_surf_resource_state_t stateInitial, tmgr_trace_t stateTrace,
113         xbt_dict_t properties) ;
114   ~CpuTi() {};
115
116   void updateState(tmgr_trace_event_t event_type, double value, double date);  
117   void updateActionFinishDate(double now);
118   bool isUsed();
119   void printCpuTiModel();
120   CpuActionPtr execute(double size);
121   CpuTiActionPtr _execute(double size);
122   CpuActionPtr sleep(double duration);
123   double getAvailableSpeed();
124
125   xbt_dynar_t getWattsRangeList() {};
126   double getCurrentWattsValue(double cpu_load) {};
127   void updateEnergy(double cpu_load) {};
128
129   double getCurrentPowerPeak() {};
130   double getPowerPeakAt(int pstate_index) {};
131   int getNbPstates() {};
132   void setPowerPeakAt(int pstate_index) {};
133   double getConsumedEnergy() {};
134
135   CpuTiTgmrPtr p_availTrace;       /*< Structure with data needed to integrate trace file */
136   tmgr_trace_event_t p_stateEvent;       /*< trace file with states events (ON or OFF) */
137   tmgr_trace_event_t p_powerEvent;       /*< trace file with availability events */
138   xbt_swag_t p_actionSet;        /*< set with all actions running on cpu */
139   s_xbt_swag_hookup_t p_modifiedCpuHookup;      /*< hookup to swag that indicates whether share resources must be recalculated or not */
140   double m_sumPriority;          /*< the sum of actions' priority that are running on cpu */
141   double m_lastUpdate;           /*< last update of actions' remaining amount done */
142
143   int m_pstate;                                                         /*< Current pstate (index in the power_peak_list)*/
144   double current_frequency;
145
146   void updateRemainingAmount(double now);
147 };
148
149 /**********
150  * Action *
151  **********/
152
153 class CpuTiAction: public CpuAction {
154 public:
155   CpuTiAction() {};
156   CpuTiAction(CpuTiModelPtr model, double cost, bool failed)
157   : Action(model, cost, failed), CpuAction(model, cost, failed) {
158         p_cpuListHookup.next = 0;
159         p_cpuListHookup.prev = 0;
160   };
161
162   void setState(e_surf_action_state_t state);
163   int unref();
164   void cancel();
165   void recycle();
166   void updateIndexHeap(int i);
167   void suspend();
168   void resume();
169   bool isSuspended();
170   void setMaxDuration(double duration);
171   void setPriority(double priority);
172   double getRemains();
173   CpuTiPtr p_cpu;
174   int m_indexHeap;
175   s_xbt_swag_hookup_t p_cpuListHookup;
176   int m_suspended;
177 private:
178 };