/[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 163 by dpavlin, Sun Nov 1 20:30:48 2009 UTC revision 164 by dpavlin, Sun Nov 1 21:00:30 2009 UTC
# Line 50  while (1) { Line 50  while (1) {
50                          my $new = $lsn->accept;                          my $new = $lsn->accept;
51                          $sel->add($new);                          $sel->add($new);
52                          $session->{$new} = $new->peerhost;                          $session->{$new} = $new->peerhost;
53                          warn "[socket] connect from ", $new->peerhost, "\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 ) {                          if ( $sock->connected ) {
57                                  my $data = Storable::fd_retrieve( $sock );                                  my $data = Storable::fd_retrieve( $sock );
58                                  warn "<<<< ", dump($data), $/;                                  warn "<<<< ", dump($data), $/;
59                                    if ( $data->{repl} ) {
60                                            Storable::store_fd( { repl => $data }, $sock );
61                                    }
62                          } else {                          } else {
                                 $session->{$sock}->close();  
63                                  delete $session->{$sock};                                  delete $session->{$sock};
64                                  warn "[socket] disconnect\n";                                  warn "[socket] disconnect\n";
65                                  $sel->remove($sock);                                  $sel->remove($sock);
Legend:
Removed from v.163  
changed lines
  Added in v.164
  ViewVC Help
Powered by ViewVC 1.1.26