[PVFS2-CVS] commit by pcarns in pvfs2/src/io/job: thread-mgr.c
CVS commit program
cvs at parl.clemson.edu
Sat Feb 14 15:46:44 EST 2004
Update of /projects/cvsroot/pvfs2/src/io/job
In directory parlweb:/tmp/cvs-serv19021
Modified Files:
thread-mgr.c
Log Message:
fixed logic bug in thread mgr cancel path, added some lazy #if 0'd print
statements for the moment
Index: thread-mgr.c
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/io/job/thread-mgr.c,v
diff -p -u -r1.13 -r1.14
--- thread-mgr.c 12 Feb 2004 22:32:11 -0000 1.13
+++ thread-mgr.c 14 Feb 2004 20:46:44 -0000 1.14
@@ -486,11 +486,23 @@ int PINT_thread_mgr_bmi_cancel(PVFS_id_g
/* iterate down list of pending completions, to see if the caller is
* trying to cancel one of them
*/
+#if 0
+ gossip_err("THREAD MGR trying to cancel op: %Lu, ptr: %p.\n",
+ Lu(id), user_ptr);
+#endif
for(i=0; i<bmi_test_count; i++)
{
- if(stat_bmi_id_array[i] == id && stat_bmi_user_ptr_array ==
+#if 0
+ gossip_err("THREAD MGR bmi cancel scanning op: %Lu.\n",
+ Lu(stat_bmi_id_array[i]));
+#endif
+ if(stat_bmi_id_array[i] == id && stat_bmi_user_ptr_array[i] ==
user_ptr)
{
+#if 0
+ gossip_err("THREAD MGR bmi cancel SKIPPING op: %Lu.\n",
+ Lu(stat_bmi_id_array[i]));
+#endif
/* match; no steps needed to cancel, the op is already done */
gen_mutex_unlock(&bmi_test_mutex);
return(0);
@@ -610,9 +622,17 @@ int PINT_thread_mgr_trove_cancel(PVFS_id
*/
for(i=0; i<trove_test_count; i++)
{
- if(stat_trove_id_array[i] == id && stat_trove_user_ptr_array ==
+#if 0
+ gossip_err("THREAD MGR trove cancel scanning op: %Lu.\n",
+ Lu(stat_trove_id_array[i]));
+#endif
+ if(stat_trove_id_array[i] == id && stat_trove_user_ptr_array[i] ==
user_ptr)
{
+#if 0
+ gossip_err("THREAD MGR trove cancel SKIPPING op: %Lu.\n",
+ Lu(stat_trove_id_array[i]));
+#endif
/* match; no steps needed to cancel, the op is already done */
gen_mutex_unlock(&trove_test_mutex);
return(0);
More information about the PVFS2-CVS
mailing list