Changeset 1899afd for fedkit

Timestamp:

Feb 15, 2010 5:32:05 AM (14 years ago)

Author:

Ted Faber <faber@…>

Branches:

axis_example, compt_changes, info-ops, master, version-3.01, version-3.02

Children:

3132419

Parents:

6d985c0

Message:

Add port waiting. Should be asynchronous now.

Location:

fedkit

Files:

• active_config.pl (modified) (1 diff)
• gateway_lib.pm (modified) (3 diffs)

fedkit/active_config.pl

@@ -44 +44 @@
 my $f = new IO::File($iface_file) || die "Can't open $iface_file: $!\n";
 my $ifnum = 0;
+
+print "Waiting for ssh on $peer\n";
+gateway_lib::wait_for_port($peer, 22, 60*60) || 
+    die "ssh never came up on $peer\n";
 
 while (<$f>) {

fedkit/gateway_lib.pm

@@ -16 +16 @@
 use IO::File;
 use IO::Pipe;
+use IO::Socket;
 
 use File::Temp;
@@ -244 +245 @@
 }
 
-# untested
 sub read_config {
     my($file, $map) = @_;
@@ -317 +317 @@
 }
 
+sub wait_for_port {
+    my($addr, $port, $timeout, $sleep) = @_;
+    my $start = time();
+    $sleep = 5 unless $sleep;
+    die "Need both address and port\n" unless $addr && $port;
+
+    my $s;
+
+    while (!$s) {
+        if (!($s = new IO::Socket(Domain => &AF_INET, PeerAddr => $addr, 
+            PeerPort => $port))) {
+            if ($timeout and time() - $start > $timeout) {
+                return undef;
+            }
+            else { sleep($sleep); }
+        }
+    }
+    $s->close();
+    return 1;
+
+}
+
+
 1;