Changeset 33204 for branches/eam_branches/ipp-20111122/Ohana/src/photdbc/src/HostTableLoad.c

Timestamp:

Feb 6, 2012, 6:50:18 AM (14 years ago)

Author:

eugene

Message:

added some notes to dvosplit; working on dvodist

File:

• branches/eam_branches/ipp-20111122/Ohana/src/photdbc/src/HostTableLoad.c (modified) (6 diffs)

branches/eam_branches/ipp-20111122/Ohana/src/photdbc/src/HostTableLoad.c

@@ -1 +1 @@
 # include "photdbc.h"
+# define DEBUG 1
 
 typedef struct {
@@ -48 +49 @@
   InitHosts (hosts, Nhosts, NHOSTS);
 
+  int maxID = 0;
+
   int Nline;
   for (Nline = 0; TRUE; Nline ++) {
@@ -69 +72 @@
     }
 
+    // check the validity of ID (0 < ID < MAX_SHORT)
+
+    if (ID < 1) {
+      fprint (stderr, "invalid host ID %d\n", ID);
+      exit (1);
+    }
+    if (ID > 65535) {
+      fprint (stderr, "invalid host ID %d\n", ID);
+      exit (1);
+    }
+    maxID = MAX(maxID, ID);
+
     hosts[Nhosts].hostID = ID;
     hosts[Nhosts].hostname = strcreate(tmphost);
@@ -85 +100 @@
   table->hosts = hosts;
 
+  ALLOCATE (table->index, unsigned short, maxID + 1);
+  for (i = 0; i <= maxID; i++) table->index[i] = -1;
+
+  for (i = 0; i < table->Nhosts; i++) {
+    if (table->index[table->hosts[i].hostID] == -1) {
+      fprintf (stderr, "error: duplicate hostID %d\n", table->hosts[i].hostID);
+      exit (1);
+    }
+    table->index[table->hosts[i].hostID] = i;
+  }
+
   return table;
 }
@@ -90 +116 @@
 int CheckHostsAndPaths (HostTable *table) {
 
+  int i;
+  int stdio[3];
   char command[64];
   char shell[64];
 
   strcpy (command, "ssh");
-  strcpy (shell, "pclient");
+  strcpy (shell, "csh");
 
   for (i = 0; i < table->Nhosts; i++) {
@@ -101 +129 @@
     if (DEBUG) fprintf (stderr, "starting host within thread\n");
 
-    pid = rconnect (command, host[0].hostname, shell, stdio);
+    pid = rconnect (command, table->hosts[i].hostname, shell, stdio);
     if (!pid) {     
       /** failure to start: extend retry period **/
       if (DEBUG) fprintf (stderr, "failure to start %s\n", table->hosts[i].hostname);
+      exit (1);
     }
+
+    // XXX check anything else?
+
+    // close the connection
+    close(stdio[0]);
+    close(stdio[1]);
+    close(stdio[2]);
+
+    status = check_dir_access (table->hosts[i].pathname, DEBUG);
+    if (!status) {
+      fprintf (stderr, "failed to find / create target path\n");
+      exit (2);
+    }
+
+    fprintf (stderr, "success : %s, %s\n", table->hosts[i].hostname, table->hosts[i].pathname);
   }
-
+  return (TRUE);
 }