Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
CpuCas01 in C++
[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, double power_peak, double power_scale,
85                           tmgr_trace_t power_trace, int core,
86                           e_surf_resource_state_t state_initial,
87                           tmgr_trace_t state_trace,
88                           xbt_dict_t cpu_properties);
89   CpuTiActionPtr createAction(double cost, bool failed);
90   double shareResources(double now);
91   void updateActionsState(double now, double delta);
92   void addTraces();
93
94 protected:
95   void NotifyResourceTurnedOn(ResourcePtr r){};
96   void NotifyResourceTurnedOff(ResourcePtr r){};
97
98   void NotifyActionCancel(ActionPtr a){};
99   void NotifyActionResume(ActionPtr a){};
100   void NotifyActionSuspend(ActionPtr a){};
101 };
102
103 /************
104  * Resource *
105  ************/
106 class CpuTi : public Cpu {
107 public:
108   CpuTi() {};
109   CpuTi(CpuTiModelPtr model, const char *name, double powerPeak,
110         double powerScale, tmgr_trace_t powerTrace, int core,
111         e_surf_resource_state_t stateInitial, tmgr_trace_t stateTrace,
112         xbt_dict_t properties) ;
113   ~CpuTi() {};
114
115   void updateState(tmgr_trace_event_t event_type, double value, double date);  
116   void updateActionFinishDate(double now);
117   bool isUsed();  
118   void printCpuTiModel();
119   CpuTiModelPtr getModel();
120   CpuActionPtr execute(double size);
121   CpuActionPtr sleep(double duration);
122   double getAvailableSpeed();
123
124   CpuTiTgmrPtr p_availTrace;       /*< Structure with data needed to integrate trace file */
125   e_surf_resource_state_t p_stateCurrent;        /*< CPU current state (ON or OFF) */
126   tmgr_trace_event_t p_stateEvent;       /*< trace file with states events (ON or OFF) */
127   tmgr_trace_event_t p_powerEvent;       /*< trace file with availabitly events */
128   xbt_swag_t p_actionSet;        /*< set with all actions running on cpu */
129   s_xbt_swag_hookup_t p_modifiedCpuHookup;      /*< hookup to swag that indicacates whether share resources must be recalculated or not */
130   double m_sumPriority;          /*< the sum of actions' priority that are running on cpu */
131   double m_lastUpdate;           /*< last update of actions' remaining amount done */
132   void updateRemainingAmount(double now);
133 };
134
135 /**********
136  * Action *
137  **********/
138 class CpuTiAction: public CpuAction {
139 public:
140   CpuTiAction() {};
141   CpuTiAction(CpuTiModelPtr model, double cost, bool failed): CpuAction(model, cost, failed) {};
142
143   void setState(e_surf_action_state_t state);
144   int unref();
145   void cancel();
146   void recycle();
147   void updateIndexHeap(int i);
148   void suspend();
149   void resume();
150   bool isSuspended();
151   void setMaxDuration(double duration);
152   void setPriority(double priority);
153   double getRemains();
154   CpuTiPtr p_cpu;
155   int m_indexHeap;
156
157 private:
158 };