/[Sack]/trunk/lib/Sack/Server.pm
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /trunk/lib/Sack/Server.pm

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 164 by dpavlin, Sun Nov 1 21:00:30 2009 UTC revision 176 by dpavlin, Fri Nov 6 10:48:19 2009 UTC
# Line 8  use IO::Select; Line 8  use IO::Select;
8    
9  use Data::Dump qw(dump);  use Data::Dump qw(dump);
10  use Storable qw();  use Storable qw();
11    use File::Slurp;
12    use Cwd qw(abs_path);
13    
14    my @cloud = qw(localhost tab.lan llin.lan);
15    
16    my $cloud_path = $ENV{CLOUD} || '/srv/Sack/etc/lib';
17    @cloud = read_file $cloud_path;
18    @cloud = map { chomp $_; $_ } @cloud;
19    
20    warn "# cloud ",dump( @cloud );
21    
22  my $listen_port = 4444;  my $listen_port = 4444;
23    
24  my $node_path = '/tmp/client.pl';  my $node_path = abs_path $0;
25    $node_path =~ s{server.pl}{client.pl};
26    
27  my $lsn = IO::Socket::INET->new(Listen => 1, LocalPort => $listen_port, Reuse => 1) or exit;  my $lsn = IO::Socket::INET->new(Listen => 1, LocalPort => $listen_port, Reuse => 1) or die $!;
28  my $sel = IO::Select->new($lsn);  my $sel = IO::Select->new($lsn);
29    
30    my $info;
31    sub info {
32            my $port = shift;
33            push @{ $info->{$port} }, [ @_ ];
34    }
35    
36  sub fork_node {  sub fork_node {
37          my ( $port, $host ) = @_;          my ( $port, $host ) = @_;
38    
39          if ( my $pid = fork ) {          if ( my $pid = fork ) {
40                  # parent                  # parent
41                    info $port => 'forked', $pid;
42                  return $port;                  return $port;
43    
44          } elsif ( ! defined $pid ) {          } elsif ( ! defined $pid ) {
# Line 29  sub fork_node { Line 46  sub fork_node {
46                  return;                  return;
47          } else {          } else {
48                  # child                  # child
49                  my $cmd = qq|ssh -R $port:127.0.0.1:$listen_port $host $node_path $port|;                  my $cmd = qq|ssh -F $cloud_path.ssh -R $port:127.0.0.1:$listen_port $host $node_path $port|;
50                  warn "# exec: $cmd\n";                  warn "# exec: $cmd\n";
51                  exec $cmd;                  exec $cmd;
52          }          }
# Line 37  sub fork_node { Line 54  sub fork_node {
54    
55  my $node_port = 4000;  my $node_port = 4000;
56    
57  foreach my $host ( qw/localhost tab.lan llin.lan/ ) {  foreach my $host ( @cloud ) {
58          system "scp client.pl $host:$node_path";          system "find /srv/Sack/ | cpio --create --dereference | ssh -T -F $cloud_path.ssh $host cpio --extract --make-directories --unconditional";
59          fork_node( $node_port++, $host );          fork_node( $node_port++, $host );
60  }  }
61    
# Line 49  while (1) { Line 66  while (1) {
66                  if ($sock == $lsn) {                  if ($sock == $lsn) {
67                          my $new = $lsn->accept;                          my $new = $lsn->accept;
68                          $sel->add($new);                          $sel->add($new);
69                          $session->{$new} = $new->peerhost;                          $session->{peerport}->{ $new->peerport } = $new;
70                          warn "[socket] connect\n";                          warn "[socket] connect\n";
71                          Storable::store_fd( { ping => 1 }, $new );                          Storable::store_fd( { ping => 1 }, $new );
72                            info 0 => 'ping', $new->peerport;
73                  } else {                  } else {
74                          if ( $sock->connected ) {                          my $data = eval { Storable::fd_retrieve( $sock ) };
75                                  my $data = Storable::fd_retrieve( $sock );                          if ( $@ ) {
                                 warn "<<<< ", dump($data), $/;  
                                 if ( $data->{repl} ) {  
                                         Storable::store_fd( { repl => $data }, $sock );  
                                 }  
                         } else {  
76                                  delete $session->{$sock};                                  delete $session->{$sock};
77                                  warn "[socket] disconnect\n";                                  warn "[socket] disconnect: $@\n";
78                                  $sel->remove($sock);                                  $sel->remove($sock);
79                                  $sock->close;                                  $sock->close;
80                            } else {
81                                    warn "<<<< ", dump($data), $/;
82                                    if ( $data->{repl} ) {
83                                            my $response = { repl => $$ };
84                                            if ( $data->{repl} =~ m/ping/ ) {
85                                                    foreach my $port ( keys %{ $session->{port} } ) {
86                                                            warn ">>>> [$port]\n";
87                                                            Storable::store_fd( { ping => 1 }, $session->{port}->{$port} );
88                                                    }
89                                            } elsif ( $data->{repl} =~ m/info/ ) {
90                                                    $response->{info} = $info;
91                                            }
92                                            Storable::store_fd( $response, $sock );
93                                    } elsif ( $data->{ping} ) {
94                                            my $port = $data->{port};
95                                            info $port => 'ping', $port;
96                                            $session->{port}->{ $data->{port} } = $sock;
97                                    }
98                          }                          }
99                  }                  }
100          }          }
Legend:
Removed from v.164  
changed lines
  Added in v.176
  ViewVC Help
Powered by ViewVC 1.1.26