[Pvfs2-cvs] commit by bligon in pvfs2/src/client/sysint: client-state-machine.h sys-io.sm

CVS commit program cvs at parl.clemson.edu
Wed Jul 1 15:07:12 EDT 2009


Update of /projects/cvsroot/pvfs2/src/client/sysint
In directory parlweb1:/tmp/cvs-serv1855/src/client/sysint

Modified Files:
      Tag: Orange-FailOver-Becky
	client-state-machine.h sys-io.sm 
Log Message:
Making backup


Index: client-state-machine.h
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/client/sysint/client-state-machine.h,v
diff -p -u -r1.177.10.1.6.1 -r1.177.10.1.6.2
--- client-state-machine.h	25 Jun 2009 21:27:50 -0000	1.177.10.1.6.1
+++ client-state-machine.h	1 Jul 2009 19:07:12 -0000	1.177.10.1.6.2
@@ -385,10 +385,13 @@ struct PINT_server_fetch_config_sm_state
 
 typedef struct PINT_sm_getmir_state
 {
+  /* meta data handle */
   PVFS_object_ref object_ref;
 
+  /* number of mirrored copies */
   uint32_t copies;
 
+  /* retrieved handles */
   PVFS_handle *handles;
 
 } PINT_sm_getmir_state;

Index: sys-io.sm
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/client/sysint/sys-io.sm,v
diff -p -u -r1.164.8.1.6.2 -r1.164.8.1.6.3
--- sys-io.sm	25 Jun 2009 21:27:50 -0000	1.164.8.1.6.2
+++ sys-io.sm	1 Jul 2009 19:07:12 -0000	1.164.8.1.6.3
@@ -39,8 +39,7 @@ enum
     IO_ANALYZE_SIZE_RESULTS,
     IO_DO_SMALL_IO,
     IO_UNSTUFF,
-    IO_FATAL_ERROR,
-    IO_MIRRORING
+    IO_FATAL_ERROR
 };
 
 /* Helper functions local to sys-io.sm. */
@@ -167,7 +166,7 @@ machine pvfs2_client_io_sm
     {   
         run io_inspect_attr;
         IO_UNSTUFF => unstuff_setup_msgpair;
-        success => io_mirroring; 
+        success => io_datafile_setup_msgpairs; 
         default => io_cleanup;
     }
 
@@ -181,23 +180,7 @@ machine pvfs2_client_io_sm
     state unstuff_xfer_msgpair
     {
         jump pvfs2_msgpairarray_sm;
-        success => io_mirroring; 
-        default => io_cleanup;
-    }
-
-    state io_mirroring
-    {
-        run io_mirroring;
-        IO_MIRRORING => io_get_mirrors;
-        success => io_datafile_setup_msgpairs;
-        default => io_cleanup;
-    }
-   
-    state io_get_mirrors
-    {
-       /* jump pvfs2_get_mirrors_sm;*/
-        run pvfs2_get_mirrors_sm;
-        success => io_datafile_setup_msgpairs;
+        success => io_datafile_setup_msgpairs; 
         default => io_cleanup;
     }
 
@@ -210,9 +193,8 @@ machine pvfs2_client_io_sm
         default => io_cleanup;
     }
 
-
     /*We will make changes to msgpairarray to handle mirrored copies of a 
-     *data handle.
+     *data handle when retries are warrented.
     */
     state small_io
     {
@@ -223,7 +205,8 @@ machine pvfs2_client_io_sm
 
     state io_datafile_post_msgpairs
     { /*whenever a msgpair is retried, we will use the "next" data handle, if
-       *mirrored data handles are available.
+       *mirrored data handles are available, instead of retrying the same
+       *handle.
       */
         run io_datafile_post_msgpairs;
         IO_RETRY => io_datafile_post_msgpairs_retry;
@@ -537,39 +520,6 @@ static PINT_sm_action io_unstuff_setup_m
     PINT_sm_push_frame(smcb, 0, &sm_p->msgarray_op);
     return SM_ACTION_COMPLETE;
 }
-
-static PINT_sm_action pvfs2_get_mirrors_sm
-(struct PINT_smcb *smcb, job_status_s *js_p)
-{
-   return SM_ACTION_COMPLETE;
-}
-
-static PINT_sm_action io_mirroring(struct PINT_smcb *smcb, job_status_s *js_p)
-{
-
-    gossip_debug(GOSSIP_MIRROR_DEBUG,"Executing io_mirroring....\n");
-
-    struct PINT_client_sm *sm_p = PINT_sm_frame(smcb, PINT_FRAME_CURRENT);
-    PINT_sm_getmir_state *getmir_p = &(sm_p->getmir);
-
-    js_p->error_code = 0;
-
-    /*If mirroring is not activated for the logical file, then bypass this
-     *step.
-    */
-    if (sm_p->getattr.attr.u.meta.hint.flags & PVFS_MIRROR_FL)
-        js_p->error_code = IO_MIRRORING;
-    else
-        return SM_ACTION_COMPLETE;
-
-    memset(getmir_p,0,sizeof(PINT_sm_getmir_state));
-
-    getmir_p->object_ref.handle = sm_p->object_ref.handle;
-    getmir_p->object_ref.fs_id  = sm_p->object_ref.fs_id;
-    
-
-    return SM_ACTION_COMPLETE;
-}/*end io_mirroring*/
 
 
 static PINT_sm_action io_datafile_setup_msgpairs(



More information about the Pvfs2-cvs mailing list