[PVFS2-CVS] commit by neill in pvfs2/src/io/job: job.c job.h

[CVS commit program]

Update of /projects/cvsroot/pvfs2/src/io/job
In directory parlweb:/tmp/cvs-serv1189/src/io/job

Modified Files:
	job.c job.h 
Log Message:
- extend the job interface to take a flags argument, which is passed to various
  trove operations, rather than hard-coding TROVE_SYNC
- make changes to server to pass in the mode value matching the config option
- update test programs (hardcode TROVE_SYNC)


Index: job.c
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/io/job/job.c,v
diff -p -u -r1.109 -r1.110
--- job.c	16 Feb 2004 21:35:29 -0000	1.109
+++ job.c	16 Feb 2004 23:08:21 -0000	1.110
@@ -1762,6 +1762,7 @@ int job_trove_dspace_getattr(PVFS_fs_id 
 int job_trove_dspace_setattr(PVFS_fs_id coll_id,
 			     PVFS_handle handle,
 			     PVFS_ds_attributes *ds_attr_p,
+                             TROVE_ds_flags flags,
 			     void *user_ptr,
 			     job_aint status_user_tag,
 			     job_status_s * out_status_p,
@@ -1795,7 +1796,7 @@ int job_trove_dspace_setattr(PVFS_fs_id 
 
 #ifdef __PVFS2_TROVE_SUPPORT__
     ret = trove_dspace_setattr(coll_id, handle, ds_attr_p,
-                               TROVE_SYNC /* flags */ ,
+                               flags,
 			       user_ptr_internal, global_trove_context, 
 			       &(jd->u.trove.id));
 #else
@@ -1877,7 +1878,7 @@ int job_trove_bstream_resize(PVFS_fs_id 
 
 #ifdef __PVFS2_TROVE_SUPPORT__
     ret = trove_bstream_resize(coll_id, handle, &size,
-                               TROVE_SYNC /* flags */ ,
+                               flags,
 			       vtag, user_ptr_internal, global_trove_context, 
 			       &(jd->u.trove.id));
 #else
@@ -2268,6 +2269,7 @@ int job_trove_dspace_create(PVFS_fs_id c
 			    PVFS_handle_extent_array *handle_extent_array,
 			    PVFS_ds_type type,
 			    void *hint,
+                            PVFS_ds_flags flags,
 			    void *user_ptr,
 			    job_aint status_user_tag,
 			    job_status_s * out_status_p,
@@ -2303,7 +2305,7 @@ int job_trove_dspace_create(PVFS_fs_id c
                               handle_extent_array,
 			      &(jd->u.trove.handle),
 			      type,
-			      hint, TROVE_SYNC /* flags */ ,
+			      hint, flags,
 			      user_ptr_internal, 
 			      global_trove_context, &(jd->u.trove.id));
 #else
@@ -2351,6 +2353,7 @@ int job_trove_dspace_create(PVFS_fs_id c
  */
 int job_trove_dspace_remove(PVFS_fs_id coll_id,
 			    PVFS_handle handle,
+                            PVFS_ds_flags flags,
 			    void *user_ptr,
 			    job_aint status_user_tag,
 			    job_status_s * out_status_p,
@@ -2382,7 +2385,7 @@ int job_trove_dspace_remove(PVFS_fs_id c
 
 #ifdef __PVFS2_TROVE_SUPPORT__
     ret = trove_dspace_remove(coll_id,
-			      handle, TROVE_SYNC /* flags */ ,
+			      handle, flags,
 			      user_ptr_internal, 
 			      global_trove_context, &(jd->u.trove.id));
 #else
@@ -2429,6 +2432,7 @@ int job_trove_dspace_remove(PVFS_fs_id c
  */
 int job_trove_dspace_verify(PVFS_fs_id coll_id,
 			    PVFS_handle handle,
+                            PVFS_ds_flags flags,
 			    void *user_ptr,
 			    job_aint status_user_tag,
 			    job_status_s * out_status_p,
@@ -2461,7 +2465,7 @@ int job_trove_dspace_verify(PVFS_fs_id c
 #ifdef __PVFS2_TROVE_SUPPORT__
     ret = trove_dspace_verify(coll_id,
 			      handle, &jd->u.trove.type, 
-			      TROVE_SYNC /* flags */ ,
+			      flags,
 			      user_ptr_internal, global_trove_context, &(jd->u.trove.id));
 #else
     gossip_err("Error: Trove support not enabled.\n");

Index: job.h
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/io/job/job.h,v
diff -p -u -r1.39 -r1.40
--- job.h	16 Feb 2004 21:35:29 -0000	1.39
+++ job.h	16 Feb 2004 23:08:22 -0000	1.40
@@ -297,6 +297,7 @@ int job_trove_dspace_getattr(PVFS_fs_id 
 int job_trove_dspace_setattr(PVFS_fs_id coll_id,
 			     PVFS_handle handle,
 			     PVFS_ds_attributes * ds_attr_p,
+                             PVFS_ds_flags flags,
 			     void *user_ptr,
 			     job_aint status_user_tag,
 			     job_status_s * out_status_p,
@@ -394,6 +395,7 @@ int job_trove_dspace_create(PVFS_fs_id c
 			    PVFS_handle_extent_array *handle_extent_array,
 			    PVFS_ds_type type,
 			    void *hint,
+                            PVFS_ds_flags flags,
 			    void *user_ptr,
 			    job_aint status_user_tag,
 			    job_status_s * out_status_p,
@@ -403,6 +405,7 @@ int job_trove_dspace_create(PVFS_fs_id c
 /* remove an entire data space object (byte stream and key/value) */
 int job_trove_dspace_remove(PVFS_fs_id coll_id,
 			    PVFS_handle handle,
+                            PVFS_ds_flags flags,
 			    void *user_ptr,
 			    job_aint status_user_tag,
 			    job_status_s * out_status_p,
@@ -412,6 +415,7 @@ int job_trove_dspace_remove(PVFS_fs_id c
 /* verify that a given dataspace exists and discover its type */
 int job_trove_dspace_verify(PVFS_fs_id coll_id,
 			    PVFS_handle handle,
+                            PVFS_ds_flags flags,
 			    void *user_ptr,
 			    job_aint status_user_tag,
 			    job_status_s * out_status_p,