… | |
… | |
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 | |