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

[CVS commit program]

Update of /projects/cvsroot/pvfs2/src/io/flow
In directory parlweb:/tmp/cvs-serv31900/src/io/flow

Modified Files:
	flow.c flow.h 
Log Message:
exposed a lock used in the flow protocol at a slightly higher level, need it
for some future changes


Index: flow.c
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/io/flow/flow.c,v
diff -p -u -r1.33 -r1.34
--- flow.c	10 Feb 2004 18:11:28 -0000	1.33
+++ flow.c	23 Feb 2004 18:22:47 -0000	1.34
@@ -277,6 +277,7 @@ void PINT_flow_reset(flow_descriptor * f
     flow_d->aggregate_size = -1;
     flow_d->state = FLOW_INITIAL;
     flow_d->type = FLOWPROTO_DEFAULT;
+    gen_mutex_init(&flow_d->flow_mutex);
 
     return;
 }
@@ -289,6 +290,7 @@ void PINT_flow_reset(flow_descriptor * f
  */
 void PINT_flow_free(flow_descriptor * flow_d)
 {
+    gen_mutex_destroy(&flow_d->flow_mutex);
     free(flow_d);
     return;
 }

Index: flow.h
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/io/flow/flow.h,v
diff -p -u -r1.25 -r1.26
--- flow.h	23 Feb 2004 18:05:36 -0000	1.25
+++ flow.h	23 Feb 2004 18:22:47 -0000	1.26
@@ -11,6 +11,7 @@
 #ifndef __FLOW_H
 #define __FLOW_H
 
+#include "gen-locks.h"
 #include "quicklist.h"
 #include "pvfs2-types.h"
 #include "bmi.h"
@@ -122,6 +123,7 @@ struct flow_descriptor
 	/***********************************************************/
     /* fields reserved strictly for internal use */
 
+    gen_mutex_t flow_mutex;
     int flowproto_id;		/* identifies which protocol owns this */
     void *flow_protocol_data;	/* used by flow protocols */
     /* called upon completion before callback */