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.28 by root, Thu Aug 27 21:29:37 2009 UTC vs.
Revision 1.32 by root, Sun Aug 30 09:24:09 2009 UTC

1=head1 NAME 1=head1 NAME
2 2
3AnyEvent::MP::Node - a single processing node (CPU/process...) 3AnyEvent::MP::Node - represent a node
4 4
5=head1 SYNOPSIS 5=head1 SYNOPSIS
6 6
7 use AnyEvent::MP::Node; 7 use AnyEvent::MP::Node;
8 8
9=head1 DESCRIPTION 9=head1 DESCRIPTION
10
11This is an internal utility module, horrible to look at, so don't.
10 12
11=cut 13=cut
12 14
13package AnyEvent::MP::Node; 15package AnyEvent::MP::Node;
14 16
… …
54 56
55 $self->{send} = sub { 57 $self->{send} = sub {
56 push @{$self->{queue}}, shift; 58 push @{$self->{queue}}, shift;
57 $self->connect; 59 $self->connect;
58 }; 60 };
59
60 $self->connect
61 if $self->{autoconnect};
62} 61}
63 62
64# called only after successful handshake 63# called each time we fail to establish a connection,
64# or the existing connection failed
65sub transport_error { 65sub transport_error {
66 my ($self, @reason) = @_; 66 my ($self, @reason) = @_;
67 67
68 my $no_transport = !$self->{transport}; 68 my $no_transport = !$self->{transport};
69 69
70 delete $self->{connect_w}; 70 delete $self->{connect_w};
71 delete $self->{connect_to}; 71 delete $self->{connect_to};
72 72
73 delete $self->{queue}; 73 delete $self->{queue};
74 $self->transport_reset; 74 $self->transport_reset;
75
76 AnyEvent::MP::Kernel::_inject_nodeevent ($self, 0, @reason)
77 unless $no_transport;
78 75
79 if (my $mon = delete $self->{lmon}) { 76 if (my $mon = delete $self->{lmon}) {
80 $_->(@reason) for map @$_, values %$mon; 77 $_->(@reason) for map @$_, values %$mon;
81 } 78 }
79
80 AnyEvent::MP::Kernel::_inject_nodeevent ($self, 0, @reason)
81 unless $no_transport;
82
83 # if we are here and are idle, we nuke ourselves
84 delete $AnyEvent::MP::Kernel::NODE{$self->{id}}
85 unless $self->{transport} || $self->{connect_to};
82} 86}
83 87
84# called after handshake was successful 88# called after handshake was successful
85sub transport_connect { 89sub transport_connect {
86 my ($self, $transport) = @_; 90 my ($self, $transport) = @_;
… …
119 0, 123 0,
120 sub { 124 sub {
121 $self->transport_error (transport_error => $self->{id}, "unable to connect"); 125 $self->transport_error (transport_error => $self->{id}, "unable to connect");
122 }; 126 };
123 127
128 return unless @addresses;
129
124 $AnyEvent::MP::Kernel::WARN->(9, "connecting to $self->{id} with [@addresses]"); 130 $AnyEvent::MP::Kernel::WARN->(9, "connecting to $self->{id} with [@addresses]");
125 return unless @addresses;
126 131
127 unless ($self->{connect_w}) { 132 unless ($self->{connect_w}) {
128 my @endpoints; 133 my @endpoints;
129 134
130 $self->{connect_w} = AE::timer 135 $self->{connect_w} = AE::timer

Diff Legend

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