| line |
l |
!l&&r |
!l&&!r |
condition |
|
178
|
11 |
0 |
0 |
$params->{'ua'} ||= do {
require Net::Async::HTTP;
'Net::Async::HTTP'->VERSION('0.36');
my $ua = 'Net::Async::HTTP'->new('fail_on_error', 1, 'max_connections_per_host', 3, 'user_agent', 'Net::Async::Matrix', 'pipeline', 0);
$self->add_child($ua);
$ua
} |
|
196
|
10 |
1 |
0 |
delete $params->{'make_delay'} || $self->_capture_weakself(sub {
my($self, $secs) = @_;
$self->loop->delay_future('after', $secs);
}
) |
|
246
|
113 |
0 |
1 |
not ref $v or &blessed($v) |
|
350
|
0 |
0 |
0 |
defined $params{'file'} or defined $params{'fh'} |
|
357
|
0 |
0 |
0 |
$fh or open $fh, '<', $params{'file'} |
|
364
|
0 |
0 |
0 |
$params{'content_length'} // &Net::Async::Matrix::stat($fh)->size |
|
602
|
0 |
12 |
0 |
$self->{'synced_future'} //= $self->loop->new_future |
|
628
|
2 |
14 |
0 |
$self->{'start_f'} ||= do {
undef $self->{'synced_future'};
foreach my $room (values %{$$self{'rooms_by_id'};}) {
$room->_reset_for_sync;
} ;
my %first_sync_args;
$first_sync_args{'filter'}{'room'}{'timeline'}{'limit'} = $self->{'first_sync_limit'} if defined $self->{'first_sync_limit'};
$self->sync(%first_sync_args)->then(sub {
my($sync) = @_;
$self->_incoming_sync($sync);
$self->start_longpoll('since', $sync->{'next_batch'});
return $self->await_synced->done;
}
)->on_fail(sub {
undef $self->{'start_f'};
}
)
} |
|
726
|
14 |
6 |
0 |
$self->{'users_by_id'}{$user_id} ||= User($user_id, undef, undef, undef) |
|
765
|
15 |
1 |
0 |
$self->{'rooms_by_id'}{$room_id} // $self->_make_room($room_id) |
|
849
|
0 |
0 |
0 |
$user_id //= $self->{'user_id'} |
|
1105
|
1 |
0 |
0 |
defined $params{'content'} or defined $params{'file'} |
|
|
1 |
0 |
0 |
defined $params{'content'} or defined $params{'file'} or defined $params{'fh'} |