/[Sack]/trunk/lib/Sack/Lorry.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/Lorry.pm

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

revision 92 by dpavlin, Sat Oct 3 21:09:51 2009 UTC revision 93 by dpavlin, Sat Oct 3 21:43:34 2009 UTC
# Line 51  sub start_node { Line 51  sub start_node {
51    
52                  warn "\nconnected to $port\n";                  warn "\nconnected to $port\n";
53    
54                    $self->{connected}->{$port} = $host;
55    
56                  return $port++;                  return $port++;
57    
58          } elsif ( ! defined $pid ) {          } elsif ( ! defined $pid ) {
# Line 78  sub start_node { Line 80  sub start_node {
80    
81  sub send_to {  sub send_to {
82          my ( $self, $port, $data ) = @_;          my ( $self, $port, $data ) = @_;
83          warn ">>>> [$port] ", dump( keys %$data ), $/;          warn "send_to [$port]\n";
84          Storable::store_fd( $data => $self->{sock}->{$port} );          Storable::store_fd( $data => $self->{sock}->{$port} );
85  }  }
86    
87  sub get_from {  sub get_from {
88          my ( $self, $port )  = @_;          my ( $self, $port )  = @_;
89          warn "<<<< [$port]\n";          warn "get_from [$port]\n";
90          Storable::fd_retrieve( $self->{sock}->{$port} );          Storable::fd_retrieve( $self->{sock}->{$port} );
91  }  }
92    
93    sub send_to_all {
94            my ( $self, $data ) = @_;
95            $self->send_to( $_, $data ) foreach keys %{ $self->{connected} };
96    }
97    
98    sub get_from_all {
99            my ( $self ) = @_;
100            my $result;
101            $result->{$_} = $self->get_from( $_ ) foreach keys %{ $self->{connected} };
102            return $result;
103    }
104    
105  sub DESTROY {  sub DESTROY {
106          warn "pids ",dump( $pids );          warn "pids ",dump( $pids );
107          foreach ( values %$pids ) {          foreach ( values %$pids ) {
Legend:
Removed from v.92  
changed lines
  Added in v.93
  ViewVC Help
Powered by ViewVC 1.1.26