… | |
… | |
34 | use base "AnyEvent::MP::Node"; |
34 | use base "AnyEvent::MP::Node"; |
35 | |
35 | |
36 | sub send { |
36 | sub 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 { |
… | |
… | |
49 | sub set_transport { |
51 | sub 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 | ) { |
… | |
… | |
136 | sub set_transport { |
140 | sub set_transport { |
137 | die "FATAL error, set_transport was called"; |
141 | die "FATAL error, set_transport was called"; |
138 | } |
142 | } |
139 | |
143 | |
140 | sub send { |
144 | sub 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 | |
146 | L<AnyEvent>. |
150 | L<AnyEvent>. |