[Pvfs2-cvs] commit by slang in pvfs2/src/io/job: job-time-mgr.c

CVS commit program cvs at parl.clemson.edu
Fri Aug 18 01:12:09 EDT 2006


Update of /projects/cvsroot/pvfs2/src/io/job
In directory parlweb1:/tmp/cvs-serv28668/src/io/job

Modified Files:
      Tag: kunkel-branch
	job-time-mgr.c 
Log Message:
reverse merge from trunk.  working for now.


Index: job-time-mgr.c
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/io/job/job-time-mgr.c,v
diff -p -u -r1.17.12.2 -r1.17.12.3
--- job-time-mgr.c	24 Jul 2006 17:20:45 -0000	1.17.12.2
+++ job-time-mgr.c	18 Aug 2006 05:12:09 -0000	1.17.12.3
@@ -118,8 +118,8 @@ static int __job_time_mgr_add(struct job
             break;
         }
 
-        tmp_bucket = NULL;
         prev_bucket = tmp_bucket;
+        tmp_bucket = NULL;
     }
 
     if(!tmp_bucket || tmp_bucket->expire_time_sec != expire_time_sec)
@@ -257,6 +257,7 @@ int job_time_mgr_expire(void)
 	    case JOB_BMI:
 		gossip_err("Job time out: cancelling bmi operation, job_id: %llu.\n", llu(jd->job_id));
 		ret = job_bmi_cancel(jd->job_id, jd->context_id);
+	        jd->time_bucket = NULL;
 		break;
 	    case JOB_FLOW:
 		/* have we made any progress since last time we checked? */
@@ -274,22 +275,23 @@ int job_time_mgr_expire(void)
 		    /* otherwise kill the flow */
 		    gossip_err("Job time out: cancelling flow operation, job_id: %llu.\n", llu(jd->job_id));
 		    ret = job_flow_cancel(jd->job_id, jd->context_id);
+	            jd->time_bucket = NULL;
 		}
 		break;
 	    case JOB_TROVE:
 		gossip_err("Job time out: cancelling trove operation, job_id: %llu.\n", llu(jd->job_id));
 		ret = job_trove_dspace_cancel(
                     jd->u.trove.fsid, jd->job_id, jd->context_id);
+	        jd->time_bucket = NULL;
                 break;
 	    default:
 		ret = 0;
+	        jd->time_bucket = NULL;
 		break;
 	    }
 
 	    /* FIXME: error handling */
 	    assert(ret == 0);
-
-	    jd->time_bucket = NULL;
 	}
 	qlist_del(&tmp_bucket->bucket_link);
         INIT_QLIST_HEAD(&tmp_bucket->jd_queue);



More information about the Pvfs2-cvs mailing list