/[Sack]/trunk/experiments/protocol-v3/server.pl
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/experiments/protocol-v3/server.pl

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

revision 164 by dpavlin, Sun Nov 1 21:00:30 2009 UTC revision 165 by dpavlin, Sun Nov 1 21:03:26 2009 UTC
# Line 53  while (1) { Line 53  while (1) {
53                          warn "[socket] connect\n";                          warn "[socket] connect\n";
54                          Storable::store_fd( { ping => 1 }, $new );                          Storable::store_fd( { ping => 1 }, $new );
55                  } else {                  } else {
56                          if ( $sock->connected ) {                          my $data = eval { Storable::fd_retrieve( $sock ) };
57                                  my $data = Storable::fd_retrieve( $sock );                          if ( $@ ) {
58                                    delete $session->{$sock};
59                                    warn "[socket] disconnect: $@\n";
60                                    $sel->remove($sock);
61                                    $sock->close;
62                            } else {
63                                  warn "<<<< ", dump($data), $/;                                  warn "<<<< ", dump($data), $/;
64                                  if ( $data->{repl} ) {                                  if ( $data->{repl} ) {
65                                          Storable::store_fd( { repl => $data }, $sock );                                          Storable::store_fd( { repl => $data }, $sock );
66                                  }                                  }
                         } else {  
                                 delete $session->{$sock};  
                                 warn "[socket] disconnect\n";  
                                 $sel->remove($sock);  
                                 $sock->close;  
67                          }                          }
68                  }                  }
69          }          }
Legend:
Removed from v.164  
changed lines
  Added in v.165
  ViewVC Help
Powered by ViewVC 1.1.26