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 };
  56
  57 /************
  58  * Resource *
  59  ************/
  60
  61 class WorkstationCLM03 : virtual public Resource {
  62 public:
  63   WorkstationCLM03(WorkstationModelPtr model, const char* name, xbt_dict_t properties, xbt_dynar_t storage, RoutingEdgePtr netElm, CpuPtr cpu);
  64
  65   void updateState(tmgr_trace_event_t event_type, double value, double date);
  66
  67   virtual ActionPtr execute(double size);
  68   virtual ActionPtr sleep(double duration);
  69   e_surf_resource_state_t getState();
  70
  71   virtual int getCore();
  72   virtual double getSpeed(double load);
  73   virtual double getAvailableSpeed();
  74   virtual double getCurrentPowerPeak();
  75   virtual double getPowerPeakAt(int pstate_index);
  76   virtual int getNbPstates();
  77   virtual void setPowerPeakAt(int pstate_index);
  78   virtual double getConsumedEnergy();
  79
  80   xbt_dict_t getProperties();
  81
  82   StoragePtr findStorageOnMountList(const char* storage);
  83   xbt_dict_t getStorageList();
  84   ActionPtr open(const char* mount, const char* path);
  85   ActionPtr close(surf_file_t fd);
  86   int unlink(surf_file_t fd);
  87   ActionPtr ls(const char* mount, const char *path);
  88   sg_size_t getSize(surf_file_t fd);
  89   ActionPtr read(surf_file_t fd, sg_size_t size);
  90   ActionPtr write(surf_file_t fd, sg_size_t size);
  91   xbt_dynar_t getInfo( surf_file_t fd);
  92   sg_size_t getFreeSize(const char* name);
  93   sg_size_t getUsedSize(const char* name);
  94
  95   bool isUsed();
  96   //bool isShared();
  97   xbt_dynar_t p_storage;
  98   RoutingEdgePtr p_netElm;
  99   CpuPtr p_cpu;
 100   NetworkCm02LinkPtr p_network;
 101
 102   xbt_dynar_t getVms();
 103
 104   /* common with vm */
 105   void getParams(ws_params_t params);
 106   void setParams(ws_params_t params);
 107   s_ws_params_t p_params;
 108 };
 109
 110 class WorkstationCLM03Lmm : virtual public WorkstationCLM03, public ResourceLmm {
 111 public:
 112   WorkstationCLM03Lmm(WorkstationModelPtr model, const char* name, xbt_dict_t props, xbt_dynar_t storage, RoutingEdgePtr netElm, CpuPtr cpu):
 113           WorkstationCLM03(model, name, props, storage, netElm, cpu){};
 114   e_surf_resource_state_t getState();
 115 };
 116
 117 /**********
 118  * Action *
 119  **********/
 120 class WorkstationAction : virtual public Action {
 121 public:
 122   WorkstationAction(ModelPtr model, double cost, bool failed): Action(model, cost, failed) {};
 123 };
 124
 125 class WorkstationActionLmm : public ActionLmm, public WorkstationAction {
 126 public:
 127   WorkstationActionLmm(ModelPtr model, double cost, bool failed): ActionLmm(model, cost, failed), WorkstationAction(model, cost, failed) {};
 128 };
 129
 130
 131 #endif /* WORKSTATION_HPP_ */