[Pvfs2-cvs] commit by pcarns in pvfs2-1/src/io/flow/flowproto-bmi-trove: flowproto-multiqueue.c

[CVS commit program]

Update of /projects/cvsroot/pvfs2-1/src/io/flow/flowproto-bmi-trove
In directory parlweb1:/tmp/cvs-serv9728

Modified Files:
	flowproto-multiqueue.c 
Log Message:
slight tweak to set flowproto-multiqueue flags as early as possible so that
callbacks can deal with trove immediate completions correctly.


Index: flowproto-multiqueue.c
===================================================================
RCS file: /projects/cvsroot/pvfs2-1/src/io/flow/flowproto-bmi-trove/flowproto-multiqueue.c,v
diff -p -u -r1.118 -r1.119
--- flowproto-multiqueue.c	3 Apr 2008 00:12:16 -0000	1.118
+++ flowproto-multiqueue.c	17 Apr 2008 19:06:00 -0000	1.119
@@ -636,7 +636,6 @@ int fp_multiqueue_post(flow_descriptor  
             bmi_send_callback_fn(&(flow_data->prealloc_array[i]), 0, 0, 1);
             if(flow_data->dest_last_posted)
             {
-                flow_data->initial_posts = 0;
                 break;
             }
         }
@@ -956,7 +955,10 @@ static void trove_read_callback_fn(void 
                 global_bmi_context);
             flow_data->next_seq_to_send++;
             if(q_item->last)
+            {
+                flow_data->initial_posts = 0;
                 flow_data->dest_last_posted = 1;
+            }
             gossip_debug(GOSSIP_FLOW_PROTO_DEBUG,
                 "%s: (post send time) ini posts: %d, pending: %d, last: %d\n",
                 __func__,
@@ -1170,7 +1172,10 @@ static int bmi_send_callback_fn(void *us
          * is no work to do, trigger manually
          */
         if(flow_data->total_bytes_processed == 0)
+        {
+            flow_data->initial_posts = 0;
             flow_data->dest_last_posted = 1;
+        }
     }
 
     if(bytes_processed == 0)
@@ -1214,6 +1219,7 @@ static int bmi_send_callback_fn(void *us
              * to prevent further trying to start other qitems from being
              * posted
              */
+            flow_data->initial_posts = 0;
             flow_data->dest_last_posted = 1;
             return 0;
         }