Changeset 4539

Timestamp:

Jul 12, 2005, 7:05:52 AM (21 years ago)

Author:

eugene

Message:

adding user-level controller commands

Location:

trunk/Ohana/src/opihi/pantasks

Files:

• controller.c (modified) (1 diff)
• controller_check.c (added)
• controller_host.c (added)
• controller_status.c (added)
• delete.c (added)
• init.c (modified) (1 diff)
• job.c (added)
• kill.c (added)

trunk/Ohana/src/opihi/pantasks/controller.c

@@ -1 +1 @@
 # include "scheduler.h"
+
+static Command controller_cmds[] = {
+  {"host",   controller_host,   "define host for controller"},
+  {"status", controller_status, "check controller status"},
+  {"check",  controller_check,  "check controller host/job"},
+};
 
 int controller (int argc, char **argv) {
 
   int status;
-  char command[1024];
-  IOBuffer buffer;
+  Function *func;
 
-  if (argc != 3) {
-    fprintf (stderr, "USAGE: controller host (hostname)\n");
+  if (argc < 2) {
+    fprintf (stderr, "USAGE: controller (command) ... \n");
     return (FALSE);
   }
 
-  if (strcmp (argv[1], "host")) {
+  func = FindControllerCommand (argv[1]);
+  if (func == NULL) {
     fprintf (stderr, "invalid controller command\n");
     return (FALSE);
   }
 
-  /* start controller connection (if needed) */
-  StartController ();
+  status = (*func)(argc - 1, argv + 1);
+  return (status);
+}
 
-  sprintf (command, "host %s", argv[2]);
-  InitIOBuffer (&buffer, 0x100);
-  status = ControllerCommand (command, CONTROLLER_PROMPT, &buffer);
-  FreeIOBuffer (&buffer);
+Function *FindControllerCommand (char *cmd) {
 
-  /* check on success of controller command */
-  switch (status) {
-    case CONTROLLER_DOWN:
-      fprintf (stderr, "controller is down\n");
-      return (FALSE);
+  int i, N;
 
-    case CONTROLLER_HUNG:
-      fprintf (stderr, "controller is not responding\n");
-      return (FALSE);
+  N = sizeof (controller_cmds) / sizeof (Command);
 
-    case CONTROLLER_GOOD:
-      fprintf (stderr, "controller command sent\n");  
-      return (TRUE);
-
-    default:
-      fprintf (stderr, "unknown status for controller command: programming error\n");  
-      exit (1);
+  for (i = 0; i < N; i++) {
+    if (!strcmp (controller_cmds[i].name, argv[1])) {
+      return (controller_cmds[i].func);
+    }
   }
-
-  fprintf (stderr, "programming error: should not reach here\n");  
-  exit (1);
+  return (NULL);
 }

trunk/Ohana/src/opihi/pantasks/init.c

@@ -21 +21 @@
   {"run",        run,          "run the scheduler"},
   {"stop",       stop,         "stop the scheduler"},
+
+  {"kill",       kill_sh,      "kill job"},
+  {"delete",     delete,       "delete job"},
+  {"job",        job,          "add job"},
+  {"host",       host,         "add / delete / modify host"},
+  {"check",      check,        "get job or host status"},
+  {"status",     status,       "get system status"},
+  {"stdout",     stdout_pc,    "get stdout buffer for job"},
+  {"stderr",     stderr_pc,    "get stderr buffer for job"},
 };