X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5faf49cdf3f8ad8751317b857a6d3134fe07eda3..283236f8e2414d7c30d46e6d1aea0e8882699dd1:/src/surf/storage.hpp

diff --git a/src/surf/storage.hpp b/src/surf/storage.hpp
index 7e929d6e1e..28994812d0 100644
--- a/src/surf/storage.hpp
+++ b/src/surf/storage.hpp
@@ -13,9 +13,16 @@ typedef StorageModel *StorageModelPtr;
 class Storage;
 typedef Storage *StoragePtr;
 
+class StorageLmm;
+typedef StorageLmm *StorageLmmPtr;
+
+class StorageAction;
+typedef StorageAction *StorageActionPtr;
+
 class StorageActionLmm;
 typedef StorageActionLmm *StorageActionLmmPtr;
 
+
 /*********
  * Model *
  *********/
@@ -34,30 +41,46 @@ public:
  * Resource *
  ************/
 
-class Storage : public ResourceLmm {
+class Storage : virtual public Resource {
 public:
   Storage(StorageModelPtr model, const char* name, xbt_dict_t properties);
 
   bool isUsed();
   void updateState(tmgr_trace_event_t event_type, double value, double date);
 
-  lmm_constraint_t p_constraintWrite;    /* Constraint for maximum write bandwidth*/
-  lmm_constraint_t p_constraintRead;     /* Constraint for maximum write bandwidth*/
   xbt_dict_t p_content; /* char * -> s_surf_file_t */
 
-  StorageActionLmmPtr open(const char* mount, const char* path);
-  StorageActionLmmPtr close(surf_file_t fd);
-  StorageActionLmmPtr unlink(surf_file_t fd);
-  StorageActionLmmPtr ls(const char *path);
-  size_t getSize(surf_file_t fd);
-  StorageActionLmmPtr read(void* ptr, size_t size, surf_file_t fd);//FIXME:why we have a useless param ptr ??
-  StorageActionLmmPtr write(const void* ptr, size_t size, surf_file_t fd);//FIXME:why we have a useless param ptr ??
+  virtual StorageActionPtr open(const char* mount, const char* path)=0;
+  virtual StorageActionPtr close(surf_file_t fd)=0;
+  //virtual StorageActionPtr unlink(surf_file_t fd)=0;
+  virtual StorageActionPtr ls(const char *path)=0;
+  //virtual size_t getSize(surf_file_t fd);
+  virtual StorageActionPtr read(void* ptr, size_t size, surf_file_t fd)=0;//FIXME:why we have a useless param ptr ??
+  virtual StorageActionPtr write(const void* ptr, size_t size, surf_file_t fd)=0;//FIXME:why we have a useless param ptr ??
 
   size_t m_size;
   size_t m_usedSize;
   xbt_dynar_t p_writeActions;
 };
 
+class StorageLmm : public ResourceLmm, public Storage {
+public:
+  StorageLmm(StorageModelPtr model, const char* name, xbt_dict_t properties,
+		     lmm_system_t maxminSystem, double bread, double bwrite, double bconnection,
+		     xbt_dict_t content, size_t size);
+
+  StorageActionPtr open(const char* mount, const char* path);
+  StorageActionPtr close(surf_file_t fd);
+  //StorageActionPtr unlink(surf_file_t fd);
+  StorageActionPtr ls(const char *path);
+  //size_t getSize(surf_file_t fd);
+  StorageActionPtr read(void* ptr, size_t size, surf_file_t fd);//FIXME:why we have a useless param ptr ??
+  StorageActionPtr write(const void* ptr, size_t size, surf_file_t fd);//FIXME:why we have a useless param ptr ??
+
+  lmm_constraint_t p_constraintWrite;    /* Constraint for maximum write bandwidth*/
+  lmm_constraint_t p_constraintRead;     /* Constraint for maximum write bandwidth*/
+};
+
 /**********
  * Action *
  **********/
@@ -66,24 +89,33 @@ typedef enum {
   READ=0, WRITE, STAT, OPEN, CLOSE, LS
 } e_surf_action_storage_type_t;
 
-class StorageActionLmm : public ActionLmm {
+
+class StorageAction : virtual public Action {
 public:
-  StorageActionLmm(){};
-  StorageActionLmm(ModelPtr model, double cost, bool failed, StoragePtr storage, e_surf_action_storage_type_t type);
+  StorageAction(){};
+  StorageAction(ModelPtr model, double cost, bool failed, StoragePtr storage, e_surf_action_storage_type_t type){};
+
+
 
+  e_surf_action_storage_type_t m_type;
+  StoragePtr p_storage;
+  surf_file_t p_file;
+  xbt_dict_t p_lsDict;
+};
+
+class StorageActionLmm : public ActionLmm, public StorageAction {
+public:
+  StorageActionLmm(){};
+  StorageActionLmm(ModelPtr model, double cost, bool failed, StorageLmmPtr storage, e_surf_action_storage_type_t type);
+  void suspend();
   int unref();
   void cancel();
   //FIXME:??void recycle();
-  void suspend();
   void resume();
   bool isSuspended();
   void setMaxDuration(double duration);
   void setPriority(double priority);
 
-  e_surf_action_storage_type_t m_type;
-  StoragePtr p_storage;
-  surf_file_t p_file;
-  xbt_dict_t p_lsDict;
 };