Changeset 8424 for trunk/Ohana/src/opihi/pcontrol/CheckIdleHost.c

Timestamp:

Aug 18, 2006, 1:44:51 PM (20 years ago)

Author:

eugene

Message:

successful implementation of the threaded version of pcontrol

File:

• trunk/Ohana/src/opihi/pcontrol/CheckIdleHost.c (modified) (8 diffs)

trunk/Ohana/src/opihi/pcontrol/CheckIdleHost.c

@@ -8 +8 @@
   Job *job;
 
+  /* if this host has been marked to be turned off, do that and return */
+  if (host[0].markoff) {
+    host[0].markoff = FALSE;
+    StopHost (host);
+    OffHost (host);
+    return (TRUE);
+  }
+    
   /* search the JOB_PENDING stack for an appropriate job */
   stack = GetJobStack (PCONTROL_JOB_PENDING);
@@ -16 +24 @@
     job = (Job *) stack[0].object[i];
     if (job[0].mode != PCONTROL_JOB_NEEDHOST) continue;
-    if (job[0].hostname == NULL) {
-      gprint (GP_ERR, "programming error: NEEDHOST hostname missing\n");
-      exit (2);
-    }
+    ASSERT (job[0].hostname != NULL, "NEEDHOST hostname missing");
     if (strcasecmp (job[0].hostname, host[0].hostname)) continue;
 
@@ -29 +34 @@
     RemoveStackEntry (stack, i);
     UnlockStack (stack);
-    StartJob (job);
+    StartJob (job, host);
     return (TRUE);
   }
@@ -37 +42 @@
     job = (Job *) stack[0].object[i];
     if (job[0].mode != PCONTROL_JOB_WANTHOST) continue;
-    if (job[0].hostname == NULL) {
-      gprint (GP_ERR, "programming error: WANTHOST hostname missing\n");
-      exit (2);
-    }
+    ASSERT (job[0].hostname != NULL, "WANTHOST hostname missing");
     if (strcasecmp (job[0].hostname, host[0].hostname)) continue;
 
@@ -50 +52 @@
     RemoveStackEntry (stack, i);
     UnlockStack (stack);
-    StartJob (job);
+    StartJob (job, host);
     return (TRUE);
   }
@@ -66 +68 @@
     RemoveStackEntry (stack, i);
     UnlockStack (stack);
-    StartJob (job);
-   return (TRUE);
+    StartJob (job, host);
+    return (TRUE);
   }
 
@@ -76 +78 @@
     job = (Job *) stack[0].object[i];
     if (job[0].mode != PCONTROL_JOB_WANTHOST) continue;
-    // test the job age and skip if too young
+    // XXX test the job age and skip if too young
 
     /* we have found an appropriate job; link it to the host and send to StartJob */
@@ -85 +87 @@
     RemoveStackEntry (stack, i);
     UnlockStack (stack);
-    StartJob (job);
+    StartJob (job, host);
    return (TRUE);
   }