[PVFS2-CVS] commit by pcarns in pvfs2/src/io/flow/flowproto-bmi-trove: flowproto-multiqueue.c

[CVS commit program]

Update of /projects/cvsroot/pvfs2/src/io/flow/flowproto-bmi-trove
In directory parlweb:/tmp/cvs-serv1039

Modified Files:
	flowproto-multiqueue.c 
Log Message:
whoops, make sure that bmi<->mem flows put all buffers on a placeholder
queue, just so cleanup is consistent


Index: flowproto-multiqueue.c
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/io/flow/flowproto-bmi-trove/flowproto-multiqueue.c,v
diff -p -u -r1.68 -r1.69
--- flowproto-multiqueue.c	16 Feb 2004 21:57:51 -0000	1.68
+++ flowproto-multiqueue.c	16 Feb 2004 22:24:27 -0000	1.69
@@ -421,6 +421,14 @@ int fp_multiqueue_post(flow_descriptor *
 	flow_data->prealloc_array[0].buffer = flow_d->dest.u.mem.buffer;
 	flow_data->prealloc_array[0].bmi_callback.fn =
 	    bmi_to_mem_callback_wrapper;
+	/* put all of the buffers on empty list, we don't really do any
+	 * queueing for this type of flow
+	 */
+	for(i=0; i<BUFFERS_PER_FLOW; i++)
+	{
+	    qlist_add_tail(&flow_data->prealloc_array[i].list_link,
+		&flow_data->empty_list);
+	}
 	gen_mutex_lock(&flow_data->flow_mutex);
 	bmi_to_mem_callback_fn(&(flow_data->prealloc_array[0]), 0, 0);
 	if(flow_data->parent->state == FLOW_COMPLETE)
@@ -439,6 +447,14 @@ int fp_multiqueue_post(flow_descriptor *
 	flow_data->prealloc_array[0].buffer = flow_d->src.u.mem.buffer;
 	flow_data->prealloc_array[0].bmi_callback.fn =
 	    mem_to_bmi_callback_wrapper;
+	/* put all of the buffers on empty list, we don't really do any
+	 * queueing for this type of flow
+	 */
+	for(i=0; i<BUFFERS_PER_FLOW; i++)
+	{
+	    qlist_add_tail(&flow_data->prealloc_array[i].list_link,
+		&flow_data->empty_list);
+	}
 	gen_mutex_lock(&flow_data->flow_mutex);
 	mem_to_bmi_callback_fn(&(flow_data->prealloc_array[0]), 0, 0);
 	if(flow_data->parent->state == FLOW_COMPLETE)