Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Merge commit '045db1657e870c721be490b411868f4181a12ced' into surf++
[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   void updateActionsState(double now, double delta);
45
46   virtual ActionPtr executeParallelTask(int workstation_nb,
47                                         void **workstation_list,
48                                         double *computation_amount,
49                                         double *communication_amount,
50                                         double rate);
51  virtual xbt_dynar_t getRoute(WorkstationCLM03Ptr src, WorkstationCLM03Ptr dst);
52  virtual ActionPtr communicate(WorkstationCLM03Ptr src, WorkstationCLM03Ptr dst, double size, double rate);
53 };
54
55 /************
56  * Resource *
57  ************/
58
59 class WorkstationCLM03 : virtual public Resource {
60 public:
61   WorkstationCLM03(WorkstationModelPtr model, const char* name, xbt_dict_t properties, xbt_dynar_t storage, RoutingEdgePtr netElm, CpuPtr cpu);
62
63   void updateState(tmgr_trace_event_t event_type, double value, double date);
64
65   virtual ActionPtr execute(double size);
66   virtual ActionPtr sleep(double duration);
67   e_surf_resource_state_t getState();
68
69   virtual int getCore();
70   virtual double getSpeed(double load);
71   virtual double getAvailableSpeed();
72   virtual double getCurrentPowerPeak();
73   virtual double getPowerPeakAt(int pstate_index);
74   virtual int getNbPstates();
75   virtual void setPowerPeakAt(int pstate_index);
76   virtual double getConsumedEnergy();
77
78   xbt_dict_t getProperties();
79
80   StoragePtr findStorageOnMountList(const char* storage);
81   xbt_dict_t getStorageList();
82   ActionPtr open(const char* mount, const char* path);
83   ActionPtr close(surf_file_t fd);
84   int unlink(surf_file_t fd);
85   ActionPtr ls(const char* mount, const char *path);
86   sg_storage_size_t getSize(surf_file_t fd);
87   ActionPtr read(surf_file_t fd, sg_storage_size_t size);
88   ActionPtr write(surf_file_t fd, sg_storage_size_t size);
89   xbt_dynar_t getInfo( surf_file_t fd);
90   sg_storage_size_t getFreeSize(const char* name);
91   sg_storage_size_t getUsedSize(const char* name);
92
93   bool isUsed();
94   //bool isShared();
95   xbt_dynar_t p_storage;
96   RoutingEdgePtr p_netElm;
97   CpuPtr p_cpu;
98   NetworkCm02LinkPtr p_network;
99 };
100
101 class WorkstationCLM03Lmm : public WorkstationCLM03, public ResourceLmm {
102 public:
103   WorkstationCLM03Lmm(WorkstationModelPtr model, const char* name, xbt_dict_t props, xbt_dynar_t storage, RoutingEdgePtr netElm, CpuPtr cpu):
104           WorkstationCLM03(model, name, props, storage, netElm, cpu){};
105   e_surf_resource_state_t getState();
106 };
107
108 /**********
109  * Action *
110  **********/
111 class WorkstationAction : virtual public Action {
112 public:
113   WorkstationAction(ModelPtr model, double cost, bool failed): Action(model, cost, failed) {};
114 };
115
116 class WorkstationActionLmm : public ActionLmm, public WorkstationAction {
117 public:
118   WorkstationActionLmm(ModelPtr model, double cost, bool failed): ActionLmm(model, cost, failed), WorkstationAction(model, cost, failed) {};
119 };
120
121
122 #endif /* WORKSTATION_HPP_ */