| line |
true |
false |
branch |
|
37
|
0 |
2 |
unless $self->{'is_reader'} or $self->{'is_writer'} |
|
38
|
0 |
2 |
if $self->{'is_reader'} and $self->{'is_writer'} |
|
40
|
0 |
4 |
unless my $dir = $self->{'dir'} |
|
41
|
0 |
4 |
unless -d $dir |
|
43
|
2 |
2 |
if ($self->{'is_writer'}) { } |
|
50
|
0 |
2 |
unless defined $self->{'batch_size'} |
|
64
|
0 |
2 |
$params{'shm'} ? : |
|
65
|
0 |
2 |
if ($base) { } |
|
66
|
0 |
0 |
unless -d $base |
|
92
|
0 |
0 |
unless my $dir = $ENV{'CONSUMER_NONBLOCK_DIR'} |
|
106
|
56 |
0 |
unless ($dir) |
|
107
|
0 |
56 |
unless ref $self_or_class |
|
125
|
0 |
56 |
unless open my $fh, $mode, $df |
|
126
|
4 |
52 |
$write ? : |
|
|
0 |
56 |
unless flock $fh, $write ? 2 : 1 |
|
130
|
0 |
108 |
unless $key |
|
134
|
4 |
52 |
if ($write) |
|
141
|
0 |
56 |
unless flock $fh, 8 |
|
157
|
0 |
0 |
unless defined $item |
|
172
|
73 |
4 |
if $self->{'batch_item'} < $self->{'batch_size'} |
|
178
|
2 |
2 |
if $params{'delete'} |
|
189
|
69 |
8 |
if $self->{'fh'} |
|
195
|
0 |
8 |
unless -e $file or $mode eq ">" |
|
205
|
0 |
3 |
unless defined $raw |
|
221
|
0 |
12 |
unless defined $line |
|
242
|
48 |
15 |
if $loop |
|
249
|
62 |
0 |
if ($fh = $self->_batch_fh("<")) |
|
250
|
49 |
13 |
if $fh->eof |
|
252
|
14 |
48 |
if (defined $line) |
|
253
|
1 |
13 |
unless (chomp $line) |
|
254
|
0 |
1 |
defined $$buffer ? : |
|
260
|
13 |
48 |
if ($fh and defined $line) { } |
|
262
|
1 |
12 |
if ($$buffer) |
|
264
|
1 |
0 |
if $$buffer |
|
271
|
47 |
1 |
if $data->{'open'} |
|
294
|
1 |
4 |
if $self->is_weak |
|
296
|
2 |
2 |
if ($self->{'is_writer'}) |
|
301
|
2 |
0 |
if ($self->{'is_reader'}) |