Changeset 18424 for branches/eam_branch_20080421/Ohana/src/opihi/include/pcontrol.h

Timestamp:

Jul 3, 2008, 10:26:51 PM (18 years ago)

Author:

eugene

Message:

updates from HEAD

File:

• branches/eam_branch_20080421/Ohana/src/opihi/include/pcontrol.h (modified) (6 diffs)

branches/eam_branch_20080421/Ohana/src/opihi/include/pcontrol.h

@@ -8 +8 @@
 /** job status values **/
 typedef enum {
+  PCONTROL_JOB_ALLJOBS,
   PCONTROL_JOB_PENDING,
   PCONTROL_JOB_BUSY,  
+  PCONTROL_JOB_RESP,  
   PCONTROL_JOB_HUNG,  
   PCONTROL_JOB_DONE,  
@@ -26 +28 @@
 /** host status values **/
 typedef enum {
+  PCONTROL_HOST_ALLHOSTS,
   PCONTROL_HOST_IDLE,
   PCONTROL_HOST_BUSY,  
+  PCONTROL_HOST_RESP,
   PCONTROL_HOST_DOWN,
   PCONTROL_HOST_DONE,
   PCONTROL_HOST_OFF,
 } HostStat;
+
+/** host response options **/
+typedef enum {
+  PCONTROL_RESP_NONE,
+  PCONTROL_RESP_START_JOB,
+  PCONTROL_RESP_CHECK_BUSY_JOB,  
+  PCONTROL_RESP_CHECK_DONE_HOST,  
+  PCONTROL_RESP_CHECK_HOST,
+  PCONTROL_RESP_KILL_JOB,
+  PCONTROL_RESP_STOP_HOST,
+} HostResp;
 
 typedef enum {
@@ -97 +112 @@
   Ptime       nexttry;
   IDtype      HostID;
+  IOBuffer    comms_buffer;
+  char       *response;
+  HostResp    response_state;
   struct Job *job;
 } Host;
@@ -156 +174 @@
 
 /*** own files ***/
+int StartJob (Job *job, Host *host);
+int StartJobResponse (Host *host);
+
 int CheckHost (Host *host);
+int CheckHostResponse (Host *host);
+
+int CheckDoneHost (Host *host);
+int CheckDoneHostResponse (Host *host);
+
+int CheckBusyJob (Job *job, Host *host);
+int CheckBusyJobResponse (Host *host);
+
+int KillJob (Job *job, Host *host);
+int KillJobResponse (Host *host);
+
 int StartHost (Host *host);
 int CheckIdleHost (Host *host);
-int CheckDoneHost (Host *host);
-int CheckBusyJob (Job *job, Host *host);
 int CheckDoneJob (Job *job, Host *host);
-int KillJob (Job *job, Host *host);
-int StartJob (Job *job, Host *host);
-int ResetJob (Job *job);
 int GetJobOutput (char *command, Host *host, IOBuffer *buffer, int Nbytes);
-int PclientCommand (Host *host, char *command, char *response, IOBuffer *buffer);
 int rconnect (char *command, char *hostname, char *shell, int *stdio);
+
+int PclientCommand (Host *host, char *command, char *response, HostResp response_state);
+int PclientResponse (Host *host, char *response, IOBuffer *buffer);
+
+int CheckRespHosts (float MaxDelay);
+int CheckRespHost (Host *host);
 
 /*** misc files ***/
@@ -178 +210 @@
 IDtype NextHostID ();
 void PrintID (gpDest dest, IDtype ID);
+IDtype GetID (char *IDword);
 
 /*** CheckPoint.c ***/
@@ -203 +236 @@
 int    DownHosts ();
 int    StopHost (Host *host);
+int    StopHostResponse (Host *host);
 int    HarvestHost (int pid);