[Pvfs2-cvs] commit by nlmills in pvfs2/src/io/flow/flowproto-bmi-cache: flowproto-bmi-cache-server.c

CVS commit program cvs at parl.clemson.edu
Tue Aug 25 13:56:15 EDT 2009


Update of /anoncvs/pvfs2/src/io/flow/flowproto-bmi-cache
In directory parlweb1:/tmp/cvs-serv5511/src/io/flow/flowproto-bmi-cache

Modified Files:
      Tag: cu-security-branch
	flowproto-bmi-cache-server.c 
Log Message:
merged in changes from summer at LANL


Index: flowproto-bmi-cache-server.c
===================================================================
RCS file: /anoncvs/pvfs2/src/io/flow/flowproto-bmi-cache/flowproto-bmi-cache-server.c,v
diff -p -u -r1.17 -r1.17.36.1
--- flowproto-bmi-cache-server.c	27 May 2006 23:52:21 -0000	1.17
+++ flowproto-bmi-cache-server.c	25 Aug 2009 17:56:15 -0000	1.17.36.1
@@ -221,7 +221,7 @@ int fp_bmi_cache_initialize(int flowprot
     ret = PINT_thread_mgr_bmi_start();
     if(ret < 0)
 	return(ret);
-    PINT_thread_mgr_bmi_getcontext(&global_bmi_context);
+    PINT_thread_mgr_bmi_getcontext((PVFS_context_id *)&global_bmi_context);
 
     return(0);
 }
@@ -312,7 +312,6 @@ int fp_bmi_cache_post(flow_descriptor * 
 			fprintf(stderr, "TROVE_open_context() failure.\n");
 			return (-1);
 		}
-		fprintf(stderr, "collid:%d, trove_context:%d\n", flow_d->dest.u.trove.coll_id, global_trove_context);
 
 		ret = cache_init(&info);
 		if ( ret < 0 )
@@ -870,7 +869,8 @@ static void cache_write_callback_fn(void
 		q_item->cache_req.buffer_type,
         	q_item->parent->tag,
         	&q_item->bmi_callback,
-        	global_bmi_context);
+        	global_bmi_context,
+		q_item->parent->hints);
 
 	/* TODO: error handling */
 	assert(ret >= 0);
@@ -941,7 +941,8 @@ static void cache_read_callback_fn(void 
 		q_item->cache_req.buffer_type,
 		q_item->parent->tag,
 		&q_item->bmi_callback,
-		global_bmi_context);
+		global_bmi_context,
+		(bmi_hint)q_item->parent->hints);
 		
 	/* TODO: error handling */
 	assert(ret >= 0);



More information about the Pvfs2-cvs mailing list