Changeset 62 for trunk

Timestamp:

01/10/12 09:58:12 (13 years ago)

Author:

mmamonski

Message:

Log missing time

Location:

trunk/pbs_drmaa

Files:

• job.c (modified) (2 diffs)
• job.h (modified) (1 diff)

trunk/pbs_drmaa/job.c

@@ -68 +68 @@
         self->super.update_status = pbsdrmaa_job_update_status;
         self->super.on_missing = pbsdrmaa_job_on_missing;
+        self->missing_time = 0;
         self->update = pbsdrmaa_job_update;
         return (fsd_job_t*)self;
@@ -471 +472 @@
 {
         pbsdrmaa_session_t *pbssession = (pbsdrmaa_session_t*)self->session;
-
-        if( pbssession->pbs_home != NULL && pbssession->super.wait_thread_started && self->submit_time)
+        pbsdrmaa_job_t *pbsself = (pbsdrmaa_job_t *)self;
+        
+        if (!pbsself->missing_time)
+         {
+                pbsself->missing_time = time(NULL);
+         }
+
+        fsd_log_info(("pbsdrmaa_job_on_missing: pbs_home=%s, wait_thread_started=%d, submit_time=%d, missing_time=%d", 
+                pbssession->pbs_home, 
+                pbssession->super.wait_thread_started, 
+                self->submit_time, 
+                pbsself->missing_time));
+        
+        #define DRMAA_MAX_MISSING_TIME (30)
+        if( pbssession->pbs_home != NULL && pbssession->super.wait_thread_started && self->submit_time && (time(NULL) - pbsself->missing_time < DRMAA_MAX_MISSING_TIME))
                 fsd_log_info(("Job on missing but WT is running. Skipping...")); /* TODO: try to provide implementation that uses accounting/server log files */
         else

trunk/pbs_drmaa/job.h

@@ -37 +37 @@
 struct pbsdrmaa_job_s {
         fsd_job_t super;
+        time_t missing_time; /* The time when job was seen as missing for the first time */
 
         void (*