/[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 166 by dpavlin, Sun Nov 1 21:17:36 2009 UTC
# Line 16  my $node_path = '/tmp/client.pl'; Line 16  my $node_path = '/tmp/client.pl';
16  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 exit;
17  my $sel = IO::Select->new($lsn);  my $sel = IO::Select->new($lsn);
18    
19    my $info;
20    sub info {
21            my $port = shift;
22            push @{ $info->{$port} }, [ @_ ];
23    }
24    
25  sub fork_node {  sub fork_node {
26          my ( $port, $host ) = @_;          my ( $port, $host ) = @_;
27    
28          if ( my $pid = fork ) {          if ( my $pid = fork ) {
29                  # parent                  # parent
30                    info $port => 'forked', $pid;
31                  return $port;                  return $port;
32    
33          } elsif ( ! defined $pid ) {          } elsif ( ! defined $pid ) {
# Line 49  while (1) { Line 55  while (1) {
55                  if ($sock == $lsn) {                  if ($sock == $lsn) {
56                          my $new = $lsn->accept;                          my $new = $lsn->accept;
57                          $sel->add($new);                          $sel->add($new);
58                          $session->{$new} = $new->peerhost;                          $session->{$new} = $new->peerport;
59                          warn "[socket] connect\n";                          warn "[socket] connect\n";
60                          Storable::store_fd( { ping => 1 }, $new );                          Storable::store_fd( { ping => 1 }, $new );
61                            info 0 => 'ping', $new->peerport;
62                  } else {                  } else {
63                          if ( $sock->connected ) {                          my $data = eval { Storable::fd_retrieve( $sock ) };
64                                  my $data = Storable::fd_retrieve( $sock );                          if ( $@ ) {
                                 warn "<<<< ", dump($data), $/;  
                                 if ( $data->{repl} ) {  
                                         Storable::store_fd( { repl => $data }, $sock );  
                                 }  
                         } else {  
65                                  delete $session->{$sock};                                  delete $session->{$sock};
66                                  warn "[socket] disconnect\n";                                  warn "[socket] disconnect: $@\n";
67                                  $sel->remove($sock);                                  $sel->remove($sock);
68                                  $sock->close;                                  $sock->close;
69                            } else {
70                                    warn "<<<< ", dump($data), $/;
71                                    if ( $data->{repl} ) {
72                                            my $response = { repl => $$, info => $info };
73                                            Storable::store_fd( $response, $sock );
74                                    } elsif ( $data->{ping} ) {
75                                            $info->{_peer_port}->{$sock->peerport} = $data->{port};
76                                            info $data->{port} => 'peer port', $sock->peerport;
77                                    }
78                          }                          }
79                  }                  }
80          }          }
Legend:
Removed from v.164  
changed lines
  Added in v.166
  ViewVC Help
Powered by ViewVC 1.1.26