[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-serv1734/src/io/job

Modified Files:
	job.c job.h 
Log Message:
- add hooks to the job interface for various cancellation methods


Index: job.c
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/io/job/job.c,v
diff -p -u -r1.107 -r1.108
--- job.c	28 Jan 2004 16:25:37 -0000	1.107
+++ job.c	10 Feb 2004 22:10:45 -0000	1.108
@@ -661,6 +661,20 @@ int job_bmi_unexp(struct BMI_unexpected_
     return (0);
 }
 
+/* job_bmi_cancel()
+ *
+ * cancels a job handling a BMI message
+ *
+ * returns 0 on succcess, 1 on immediate completion, and -errno on
+ * failure
+ */
+int job_bmi_cancel(job_id_t * id,
+		   job_context_id context_id)
+{
+    return(-1);
+}
+
+
 /* job_dev_unexp()
  *
  * posts a job for an unexpected device message
@@ -1072,6 +1086,19 @@ int job_flow(flow_descriptor * flow_d,
     return (0);
 }
 
+/* job_flow_cancel()
+ *
+ * cancels a posted job that is servicing a flow (where a flow is a
+ * complex I/O operation between two endpoints, which may be memory,
+ * disk, or network)
+ *
+ * returns 0 on success, 1 on immediate completion, and -errno on
+ * failure
+ */
+int job_flow_cancel(flow_descriptor * flow_d)
+{
+    return(-1);
+}
 
 /* job_trove_bstream_write_at()
  *
@@ -2470,6 +2497,21 @@ int job_trove_dspace_verify(PVFS_fs_id c
 
     return (0);
 }
+
+/* job_trove_dspace_cancel()
+ *
+ * used to cancel a trove dspace operation in progress
+ *
+ * returns 0 on success, 1 on immediate completion, and -errno on
+ * failure
+ */
+int job_trove_dspace_cancel(PVFS_fs_id coll_id,
+			    job_id_t * id,
+			    job_context_id context_id)
+{
+    return(-1);
+}
+
 
 /* job_trove_fs_create()
  *

Index: job.h
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/io/job/job.h,v
diff -p -u -r1.36 -r1.37
--- job.h	26 Nov 2003 19:09:30 -0000	1.36
+++ job.h	10 Feb 2004 22:10:45 -0000	1.37
@@ -125,6 +125,9 @@ int job_bmi_unexp(struct BMI_unexpected_
 		  enum job_flags flags,
 		  job_context_id context_id);
 
+int job_bmi_cancel(job_id_t * id,
+		   job_context_id context_id);
+
 /* unexpected device receive */
 int job_dev_unexp(struct PINT_dev_unexp_info* dev_unexp_d,
     void* user_ptr,
@@ -190,6 +193,8 @@ int job_flow(flow_descriptor * flow_d,
 	     job_id_t * id,
 	     job_context_id context_id);
 
+int job_flow_cancel(flow_descriptor * flow_d);
+
 /* storage byte stream write */
 int job_trove_bstream_write_at(PVFS_fs_id coll_id,
 			       PVFS_handle handle,
@@ -413,6 +418,10 @@ int job_trove_dspace_verify(PVFS_fs_id c
 			    job_id_t * id,
 			    job_context_id context_id);
 
+int job_trove_dspace_cancel(PVFS_fs_id coll_id,
+			    job_id_t * id,
+			    job_context_id context_id);
+
 /* create a new file system */
 int job_trove_fs_create(char *collname,
 			PVFS_fs_id new_coll_id,
@@ -459,6 +468,8 @@ int job_trove_fs_geteattr(PVFS_fs_id col
 			  job_status_s * out_status_p,
 			  job_id_t * id,
 			  job_context_id context_id);
+
+
 
 /******************************************************************
  * job test/wait for completion functions