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_ */