| line |
true |
false |
branch |
|
72
|
0 |
4 |
if (@_) { } |
|
|
0 |
4 |
elsif (exists $self->{'prefer_integer'}) { } |
|
111
|
28 |
0 |
unless $self->socket |
|
118
|
0 |
17 |
if $self->socket_io and not $force |
|
120
|
1 |
16 |
defined $self->socket ? : |
|
129
|
14 |
3 |
unless ($sock) |
|
132
|
0 |
14 |
if (@{$self->connect_error_history;} > 12) |
|
146
|
2 |
5 |
if (length $self->{'pending'}) |
|
148
|
2 |
0 |
unless $self->socket_io |
|
152
|
2 |
0 |
if ($@ or not $written) { } |
|
164
|
3 |
4 |
if $socket |
|
182
|
0 |
28 |
if ($self->event_time) { } |
|
194
|
0 |
28 |
if (ref $msg ne 'HASH') |
|
199
|
0 |
28 |
if $self->tag_prefix |
|
212
|
0 |
28 |
if ($self->ack) { } |
|
225
|
16 |
12 |
if ($errors and length $self->pending <= $self->buffer_limit) |
|
228
|
16 |
0 |
if ($errors < 12) { } |
|
233
|
16 |
0 |
if (&Fluent::Logger::time() - $self->connect_error_history->[-1] < $suppress_sec) |
|
239
|
10 |
2 |
if (not $self->socket_io or $self->owner_pid != $$) |
|
247
|
0 |
2 |
$self->ack ? : |
|
249
|
2 |
0 |
if ($written and $acked) |
|
254
|
10 |
2 |
if ($@) |
|
258
|
0 |
10 |
if $sock |
|
260
|
10 |
0 |
if (length $self->{'pending'} > $self->buffer_limit) |
|
261
|
1 |
9 |
if (defined $self->buffer_overflow_handler) { } |
|
|
9 |
0 |
elsif ($self->truncate_buffer_at_overflow) { } |
|
264
|
0 |
1 |
if $self->ack |
|
267
|
0 |
9 |
if $self->ack |
|
285
|
0 |
0 |
unless ($s) |
|
289
|
0 |
0 |
if @acks > 0 and length $buf == 0 |
|
294
|
0 |
0 |
if ($unique_key and ref $ack eq 'HASH') { } |
|
295
|
0 |
0 |
if ($ack->{'ack'} ne $unique_key) |
|
302
|
0 |
0 |
if @acks == 0 |
|
310
|
2 |
1 |
if (my $handler = $self->buffer_overflow_handler) |
|
314
|
0 |
2 |
if (my $error = $@) |
|
325
|
12 |
2 |
unless $self->socket_io |
|
331
|
0 |
2 |
unless $s |
|
335
|
0 |
2 |
if (not $nwrite) { } |
|
336
|
0 |
0 |
if ($retry > $self->max_write_retry) |