| … | |
… | |
| 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 | |
|
|
| 41 | if ($self->{transport}) { |
39 | if ($self->{transport}) { |
| 42 | $self->{transport}->send ($msg); |
40 | $self->{transport}->send ($msg); |
| 43 | } elsif ($self->{queue}) { |
41 | } elsif ($self->{queue}) { |
| 44 | push @{ $self->{queue} }, $msg; |
42 | push @{ $self->{queue} }, $msg; |
| 45 | } else { |
43 | } else { |
| … | |
… | |
| 51 | sub set_transport { |
49 | sub set_transport { |
| 52 | my ($self, $transport) = @_; |
50 | my ($self, $transport) = @_; |
| 53 | |
51 | |
| 54 | delete $self->{trial}; |
52 | delete $self->{trial}; |
| 55 | delete $self->{next_connect}; |
53 | 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# |
|
|
| 58 | |
54 | |
| 59 | if ( |
55 | if ( |
| 60 | exists $self->{remote_uniq} |
56 | exists $self->{remote_uniq} |
| 61 | && $self->{remote_uniq} ne $transport->{remote_uniq} |
57 | && $self->{remote_uniq} ne $transport->{remote_uniq} |
| 62 | ) { |
58 | ) { |
| … | |
… | |
| 74 | |
70 | |
| 75 | sub clr_transport { |
71 | sub clr_transport { |
| 76 | my ($self) = @_; |
72 | my ($self) = @_; |
| 77 | |
73 | |
| 78 | delete $self->{transport}; |
74 | delete $self->{transport}; |
| 79 | warn "clr_transport\n"; |
75 | |
|
|
76 | $self->connect; |
| 80 | } |
77 | } |
| 81 | |
78 | |
| 82 | sub connect { |
79 | sub connect { |
| 83 | my ($self) = @_; |
80 | my ($self) = @_; |
| 84 | |
81 | |
