Changeset 33544

Timestamp:

Mar 16, 2012, 7:54:57 AM (14 years ago)

Author:

eugene

Message:

close the pipes when remove dvo clients are finished

File:

• branches/eam_branches/ipp-20111122/Ohana/src/libdvo/src/HostTable.c (modified) (4 diffs)

branches/eam_branches/ipp-20111122/Ohana/src/libdvo/src/HostTable.c

@@ -301 +301 @@
         // check on the status of this and report any output?
         fprintf (stdout, "job finished for %s (%d)\n", host->hostname, pid);
-        close (host->stdio[HOST_STDIN]);
 
         // read stdout
@@ -308 +307 @@
         write (STDOUT_FILENO, host->stdout.buffer, host->stdout.Nbuffer);
         FlushIOBuffer (&host->stdout);
-        close (host->stdio[HOST_STDOUT]);
         fprintf (stdout, "\n");
             
@@ -316 +314 @@
         write (STDOUT_FILENO, host->stderr.buffer, host->stderr.Nbuffer);
         FlushIOBuffer (&host->stderr);
-        close (host->stdio[HOST_STDERR]);
         fprintf (stdout, "\n");
 
@@ -343 +340 @@
 
 escape:
+
+  // close all opened connections
+  for (i = 0; i < table->Nhosts; i++) {
+    if (!table->hosts[i].pid) continue; // any unconnected hosts should be skipped
+    close (table->hosts[i].stdio[HOST_STDIN]);
+    close (table->hosts[i].stdio[HOST_STDOUT]);
+    close (table->hosts[i].stdio[HOST_STDERR]);
+  }
+
   return globalStatus;
 }