/[Sack]/trunk/bin/sack.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/bin/sack.pl

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

revision 59 by dpavlin, Fri Sep 25 12:24:42 2009 UTC revision 60 by dpavlin, Fri Sep 25 13:02:32 2009 UTC
# Line 96  sub send_nodes { Line 96  sub send_nodes {
96          my $header = defined $content ? length($content) : 0;          my $header = defined $content ? length($content) : 0;
97          $header .= ' ' . join(' ', @_) if @_;          $header .= ' ' . join(' ', @_) if @_;
98    
99            warn "# send_nodes ", dump @nodes;
100    
101          foreach my $node ( @nodes ) {          foreach my $node ( @nodes ) {
102    
103                  my $sock = IO::Socket::INET->new(                  my $sock = IO::Socket::INET->new(
# Line 105  sub send_nodes { Line 107  sub send_nodes {
107                  );                  );
108    
109                  if ( ! $sock ) {                  if ( ! $sock ) {
110                          warn "can't connect to $node - $!"; # FIXME die?                          warn "[$port] can't connect to $node - $!\n"; # FIXME die?
111                          next;                          next;
112                  }                  }
113    
# Line 194  sub merge_out { Line 196  sub merge_out {
196                  }                  }
197          }          }
198    
199          print STDERR "$tick\n";          warn "$tick $local/$remote\n";
200    
         warn "[$port] merge local $local remote $remote from $from_node\n";  
201          warn "## merge out ", dump $out if $debug;          warn "## merge out ", dump $out if $debug;
202  }  }
203    
# Line 245  sub run_code { Line 246  sub run_code {
246                          $o = thaw $o;                          $o = thaw $o;
247                          warn "[$port] merge $node $s bytes\n";                          warn "[$port] merge $node $s bytes\n";
248                          merge_out $node => $o;                          merge_out $node => $o;
249                            report "[$port] merged $node";
250                  }                  }
251          }          }
252  }  }
# Line 384  __HELP__ Line 386  __HELP__
386          } elsif ( $cmd =~ m{^(v|r)}i ) {          } elsif ( $cmd =~ m{^(v|r)}i ) {
387                  run_views;                  run_views;
388          } elsif ( $cmd =~ m{^n(ode)?\s*(\d+)}i ) {          } elsif ( $cmd =~ m{^n(ode)?\s*(\d+)}i ) {
389                  push @nodes, $1;                  push @nodes, $2;
390                  info;                  info;
391          } elsif ( $cmd ) {          } elsif ( $cmd ) {
392                  warn "UNKNOWN ", dump $cmd;                  warn "UNKNOWN ", dump $cmd;
Legend:
Removed from v.59  
changed lines
  Added in v.60
  ViewVC Help
Powered by ViewVC 1.1.26