ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/AnyEvent-MP/MP/Node.pm
(Generate patch)

Comparing AnyEvent-MP/MP/Node.pm (file contents):
Revision 1.1 by root, Fri Jul 31 20:55:46 2009 UTC vs.
Revision 1.2 by root, Sat Aug 1 07:11:45 2009 UTC

… …
34use base "AnyEvent::MP::Node"; 34use base "AnyEvent::MP::Node";
35 35
36sub send { 36sub send {
37 my ($self, $msg) = @_; 37 my ($self, $msg) = @_;
38 38
39 warn "send $self $self->{noderef}\n";#d#
40
39 if ($self->{transport}) { 41 if ($self->{transport}) {
40 $self->{transport}->send ($msg); 42 $self->{transport}->send ($msg);
41 } elsif ($self->{queue}) { 43 } elsif ($self->{queue}) {
42 push @{ $self->{queue} }, $msg; 44 push @{ $self->{queue} }, $msg;
43 } else { 45 } else {
… …
49sub set_transport { 51sub set_transport {
50 my ($self, $transport) = @_; 52 my ($self, $transport) = @_;
51 53
52 delete $self->{trial}; 54 delete $self->{trial};
53 delete $self->{next_connect}; 55 delete $self->{next_connect};
56
57 use Data::Dumper; warn "set_transport $self->{noderef} $self $AnyEvent::MP::NODE{'10.0.0.1:4040'}\n";#d#
54 58
55 if ( 59 if (
56 exists $self->{remote_uniq} 60 exists $self->{remote_uniq}
57 && $self->{remote_uniq} ne $transport->{remote_uniq} 61 && $self->{remote_uniq} ne $transport->{remote_uniq}
58 ) { 62 ) {
… …
136sub set_transport { 140sub set_transport {
137 die "FATAL error, set_transport was called"; 141 die "FATAL error, set_transport was called";
138} 142}
139 143
140sub send { 144sub send {
141 die "self-send not implemented yet\n";#d# 145 AnyEvent::MP::_inject ($_[1]);
142} 146}
143 147
144=head1 SEE ALSO 148=head1 SEE ALSO
145 149
146L<AnyEvent>. 150L<AnyEvent>.

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines