Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
126757d4bf626be7011d48f90f9912cd397e57fd
[simgrid.git] / src / surf / workstation.hpp
1 #include "surf.hpp"
2 #include "storage.hpp"
3 #include "cpu.hpp"
4 #include "network.hpp"
5
6 #ifndef WORKSTATION_HPP_
7 #define WORKSTATION_HPP_
8
9 /***********
10  * Classes *
11  ***********/
12
13 class WorkstationModel;
14 typedef WorkstationModel *WorkstationModelPtr;
15
16 class WorkstationCLM03;
17 typedef WorkstationCLM03 *WorkstationCLM03Ptr;
18
19 class WorkstationCLM03Lmm;
20 typedef WorkstationCLM03Lmm *WorkstationCLM03LmmPtr;
21
22 class WorkstationAction;
23 typedef WorkstationAction *WorkstationActionPtr;
24
25 /*FIXME:class WorkstationActionLmm;
26 typedef WorkstationActionLmm *WorkstationActionLmmPtr;*/
27
28 /*********
29  * Tools *
30  *********/
31 extern WorkstationModelPtr surf_workstation_model;
32
33 /*********
34  * Model *
35  *********/
36 class WorkstationModel : public Model {
37 public:
38   WorkstationModel(string name): Model(name) {};
39   WorkstationModel();
40   ~WorkstationModel();
41   virtual void parseInit(sg_platf_host_cbarg_t host);
42   WorkstationCLM03Ptr createResource(string name);
43   double shareResources(double now);
44   virtual void adjustWeightOfDummyCpuActions();
45
46   void updateActionsState(double now, double delta);
47
48   virtual ActionPtr executeParallelTask(int workstation_nb,
49                                         void **workstation_list,
50                                         double *computation_amount,
51                                         double *communication_amount,
52                                         double rate);
53  virtual xbt_dynar_t getRoute(WorkstationCLM03Ptr src, WorkstationCLM03Ptr dst);
54  virtual ActionPtr communicate(WorkstationCLM03Ptr src, WorkstationCLM03Ptr dst, double size, double rate);
55  CpuModelPtr p_cpuModel;
56 };
57
58 /************
59  * Resource *
60  ************/
61
62 class WorkstationCLM03 : virtual public Resource {
63 public:
64   WorkstationCLM03(WorkstationModelPtr model, const char* name, xbt_dict_t properties, xbt_dynar_t storage, RoutingEdgePtr netElm, CpuPtr cpu);
65
66   void updateState(tmgr_trace_event_t event_type, double value, double date);
67
68   virtual ActionPtr execute(double size);
69   virtual ActionPtr sleep(double duration);
70   e_surf_resource_state_t getState();
71
72   virtual int getCore();
73   virtual double getSpeed(double load);
74   virtual double getAvailableSpeed();
75   virtual double getCurrentPowerPeak();
76   virtual double getPowerPeakAt(int pstate_index);
77   virtual int getNbPstates();
78   virtual void setPowerPeakAt(int pstate_index);
79   virtual double getConsumedEnergy();
80
81   xbt_dict_t getProperties();
82
83   StoragePtr findStorageOnMountList(const char* storage);
84   xbt_dict_t getStorageList();
85   ActionPtr open(const char* mount, const char* path);
86   ActionPtr close(surf_file_t fd);
87   int unlink(surf_file_t fd);
88   ActionPtr ls(const char* mount, const char *path);
89   sg_size_t getSize(surf_file_t fd);
90   ActionPtr read(surf_file_t fd, sg_size_t size);
91   ActionPtr write(surf_file_t fd, sg_size_t size);
92   xbt_dynar_t getInfo( surf_file_t fd);
93   sg_size_t getFreeSize(const char* name);
94   sg_size_t getUsedSize(const char* name);
95
96   bool isUsed();
97   //bool isShared();
98   xbt_dynar_t p_storage;
99   RoutingEdgePtr p_netElm;
100   CpuPtr p_cpu;
101   NetworkCm02LinkPtr p_network;
102
103   xbt_dynar_t getVms();
104
105   /* common with vm */
106   void getParams(ws_params_t params);
107   void setParams(ws_params_t params);
108   s_ws_params_t p_params;
109 };
110
111 class WorkstationCLM03Lmm : virtual public WorkstationCLM03, public ResourceLmm {
112 public:
113   WorkstationCLM03Lmm(WorkstationModelPtr model, const char* name, xbt_dict_t props, xbt_dynar_t storage, RoutingEdgePtr netElm, CpuPtr cpu):
114           WorkstationCLM03(model, name, props, storage, netElm, cpu){};
115   e_surf_resource_state_t getState();
116 };
117
118 /**********
119  * Action *
120  **********/
121 class WorkstationAction : virtual public Action {
122 public:
123   WorkstationAction(ModelPtr model, double cost, bool failed): Action(model, cost, failed) {};
124 };
125
126 class WorkstationActionLmm : public ActionLmm, public WorkstationAction {
127 public:
128   WorkstationActionLmm(ModelPtr model, double cost, bool failed): ActionLmm(model, cost, failed), WorkstationAction(model, cost, failed) {};
129 };
130
131
132 #endif /* WORKSTATION_HPP_ */