Changeset 19125 for trunk/Ohana/src/opihi/pantasks/controller_host.c

Timestamp:

Aug 19, 2008, 12:29:10 PM (18 years ago)

Author:

eugene

Message:

adding host tracking and restart

File:

• trunk/Ohana/src/opihi/pantasks/controller_host.c (modified) (3 diffs)

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

@@ -3 +3 @@
 int controller_host (int argc, char **argv) {
 
-  int status;
+  int N, status, max_threads;
   char command[1024];
   IOBuffer buffer;
 
-  if (argc != 3) {
-    gprint (GP_ERR, "USAGE: controller host (command) (hostname)\n");
-    return (FALSE);
+  max_threads = 0;
+  if ((N = get_argument (argc, argv, "-threads"))) {
+    remove_argument (N, &argc, argv);
+    max_threads = atoi(argv[N]);
+    remove_argument (N, &argc, argv);
   }
+
+  if (argc != 3) goto usage;
 
   /* start controller connection (if needed) */
@@ -18 +22 @@
   }
 
-  sprintf (command, "host %s %s", argv[1], argv[2]);
+  // the user may issue any of these commands:
+  // ADD, ON, RETRY, CHECK, OFF, DELETE
+  // we need to catch ADD and DELETE and modify our host table accordingly
+  if (!strcasecmp (argv[1], "ADD")) {
+    AddHost (argv[2], max_threads);
+  } else {
+    if (max_threads) goto usage;
+  }
+
+  if (!strcasecmp (argv[1], "DELETE")) {
+    DeleteHost (argv[2]);
+  }
+
+  if (max_threads) {
+    sprintf (command, "host %s %s -threads %d", argv[1], argv[2], max_threads);
+  } else {
+    sprintf (command, "host %s %s", argv[1], argv[2]);
+  }
   InitIOBuffer (&buffer, 0x100);
 
@@ -29 +50 @@
   FreeIOBuffer (&buffer);
   return (TRUE);
+  
+usage:
+  gprint (GP_LOG, "USAGE: controller host (command) (hostname)\n");
+  gprint (GP_ERR, "  valid commands: add, on, retry, check, off, delete\n");
+  gprint (GP_ERR, "  -threads Nthreads is optional for 'add'\n");
+  return (FALSE);
 }