| line |
l |
!l&&r |
!l&&!r |
condition |
|
135
|
0 |
0 |
0 |
$self->{'connect_to'} ||= &AE::timer($AnyEvent::MP::Kernel::CONFIG->{'connect_interval'}, 0, sub {
$self->transport_error('transport_error', $self->{'id'}, 'connect timeout');
}
) |
|
181
|
0 |
0 |
0 |
$self->{'trial'}{$endpoint} ||= do {
return &AE::log('critical', "$self->{'id'}: '${endpoint}' is not a resolved node reference.") unless my($host, $port) = &AnyEvent::Socket::parse_hostport($endpoint);
AnyEvent::MP::Transport::mp_connect($host, $port, sub {
delete $self->{'trial'}{$endpoint};
}
)
} |
|
203
|
0 |
0 |
0 |
@$list or not length $portid |
|
253
|
0 |
0 |
0 |
$DELAY_W ||= &AE::timer(0, 0, $send_delayed) |
|
275
|
0 |
0 |
0 |
$DELAY_W ||= &AE::timer(0, 0, $send_delayed) |