line |
true |
false |
branch |
111
|
0 |
0 |
unless @_ >= 1 |
122
|
0 |
0 |
if (defined $param->{'family'} and $param->{'family'} eq "UNIX" and not exists $param->{'port'}) |
133
|
0 |
0 |
if $IPC::Locker::Server::Debug |
135
|
0 |
0 |
if ($self->{'family'} eq 'INET') { } |
|
0 |
0 |
elsif ($self->{'family'} eq 'UNIX') { } |
139
|
0 |
0 |
unless $server = "IO::Socket::INET"->new("Proto", "tcp", "LocalAddr", $self->{'host'}, "LocalPort", $self->{'port'}, "Listen", 128, "Reuse", 1) |
144
|
0 |
0 |
unless $server = "IO::Socket::UNIX"->new("Local", $self->{'port'}, "Listen", 128, "Reuse", 1) |
165
|
0 |
0 |
if $IPC::Locker::Server::Debug |
170
|
0 |
0 |
scalar keys %IPC::Locker::Server::Locks ? : |
172
|
0 |
0 |
if ($npolled > 0) |
177
|
0 |
0 |
if $IPC::Locker::Server::Debug |
179
|
0 |
0 |
if ($fh == $server) { } |
|
0 |
0 |
elsif ($fh == $exister_fh) { } |
188
|
0 |
0 |
if $IPC::Locker::Server::Debug |
190
|
0 |
0 |
if $IPC::Locker::Server::Debug |
197
|
0 |
0 |
if ($data eq '') { } |
205
|
0 |
0 |
if ($line =~ /\n$/) { } |
207
|
0 |
0 |
if $IPC::Locker::Server::Debug |
210
|
0 |
0 |
if $IPC::Locker::Server::Debug |
224
|
0 |
0 |
if $IPC::Locker::Server::Debug |
235
|
0 |
0 |
if $IPC::Locker::Server::Debug |
237
|
0 |
0 |
if (defined $clientvar->{'inputlines'}[0]) |
238
|
0 |
0 |
if $IPC::Locker::Server::Debug |
246
|
0 |
0 |
if $IPC::Locker::Server::Debug |
248
|
0 |
0 |
if ($cmd) |
250
|
0 |
0 |
if ($cmd eq 'user') { } |
|
0 |
0 |
elsif ($cmd eq 'locks') { } |
|
0 |
0 |
elsif ($cmd eq 'block') { } |
|
0 |
0 |
elsif ($cmd eq 'timeout') { } |
|
0 |
0 |
elsif ($cmd eq 'autounlock') { } |
|
0 |
0 |
elsif ($cmd eq 'hostname') { } |
|
0 |
0 |
elsif ($cmd eq 'pid') { } |
|
0 |
0 |
elsif ($cmd eq 'UNLOCK') { } |
|
0 |
0 |
elsif ($cmd eq 'LOCK') { } |
|
0 |
0 |
elsif ($cmd eq 'EOF') { } |
|
0 |
0 |
elsif ($cmd eq 'STATUS') { } |
|
0 |
0 |
elsif ($cmd eq 'BREAK_LOCK') { } |
|
0 |
0 |
elsif ($cmd eq 'DEAD_PID') { } |
|
0 |
0 |
elsif ($cmd eq 'LOCK_LIST') { } |
|
0 |
0 |
elsif ($cmd eq 'VERSION') { } |
|
0 |
0 |
elsif ($cmd eq 'RESTART') { } |
264
|
0 |
0 |
if $IPC::Locker::Server::Debug |
265
|
0 |
0 |
if $wait |
302
|
0 |
0 |
if ($clientvar->{'socket'}) |
318
|
0 |
0 |
if (my $locki = locki_find($lockname)) |
319
|
0 |
0 |
if ($locki->{'owner'} eq $clientvar->{'user'}) { } |
323
|
0 |
0 |
if ($clientvar->{'told_locked'}) |
330
|
0 |
0 |
unless $clientvar->{'owner'} |
337
|
0 |
0 |
if $clientvar->{'locked'} |
338
|
0 |
0 |
if $clientvar->{'error'} |
345
|
0 |
0 |
if $IPC::Locker::Server::Debug |
347
|
0 |
0 |
unless ($lock->{'locked'}) |
348
|
0 |
0 |
if $IPC::Locker::Server::Debug |
362
|
0 |
0 |
if $IPC::Locker::Server::Debug |
364
|
0 |
0 |
if ($locki and $locki->{'owner'} ne $clientvar->{'user'}) { } |
366
|
0 |
0 |
if ($locki->{'autounlock'} and $clientvar->{'autounlock'}) |
374
|
0 |
0 |
unless ($clientvar->{'locked'}) |
385
|
0 |
0 |
if $IPC::Locker::Server::Debug |
391
|
0 |
0 |
if $clientvar->{'locked'} |
395
|
0 |
0 |
if ($clientvar->{'locked'}) { } |
|
0 |
0 |
elsif (not $clientvar->{'block'}) { } |
404
|
0 |
0 |
if (not $clientvar->{'told_locked'} and $first_locki) |
417
|
0 |
0 |
if (my $locki = locki_find($lockname)) |
418
|
0 |
0 |
if ($locki->{'locked'}) |
419
|
0 |
0 |
if $IPC::Locker::Server::Debug |
434
|
0 |
0 |
if (my $locki = locki_find($lockname)) |
435
|
0 |
0 |
if ($locki->{'owner'} eq $clientvar->{'user'}) { } |
436
|
0 |
0 |
if $IPC::Locker::Server::Debug |
440
|
0 |
0 |
if $IPC::Locker::Server::Debug |
442
|
0 |
0 |
if ($locki->{'waiters'}[$n]{'user'} eq $clientvar->{'user'}) |
443
|
0 |
0 |
if $IPC::Locker::Server::Debug |
459
|
0 |
0 |
unless $clientfh |
460
|
0 |
0 |
if $IPC::Locker::Server::Debug |
465
|
0 |
0 |
unless ($status) |
466
|
0 |
0 |
if $IPC::Locker::Server::Debug |
489
|
0 |
0 |
if ($locki->{'locked'} and $locki->{'timelimit'}) |
492
|
0 |
0 |
if not defined $timelimit or $locki->{'timelimit'} <= $timelimit |
495
|
0 |
0 |
$timelimit ? : |
509
|
0 |
0 |
if $IPC::Locker::Server::Debug |
511
|
0 |
0 |
if (defined $pid and defined $exists and not $exists) |
513
|
0 |
0 |
if $IPC::Locker::Server::Debug |
524
|
0 |
0 |
if ($locki->{'locked'} and $locki->{'autounlock'} and $locki->{'hostname'} eq $host and $locki->{'pid'} == $pid) |
527
|
0 |
0 |
if $IPC::Locker::Server::Debug |
531
|
0 |
0 |
if $IPC::Locker::Server::Debug |
542
|
0 |
0 |
if $IPC::Locker::Server::Debug |
543
|
0 |
0 |
if (not $locki->{'locked'} and defined $locki->{'waiters'}[0]) { } |
|
0 |
0 |
elsif (not $locki->{'locked'} || defined $locki->{'waiters'}[0]) { } |
559
|
0 |
0 |
if $IPC::Locker::Server::Debug |
562
|
0 |
0 |
if ($clientvar->{'timeout'}) { } |
571
|
0 |
0 |
if ($clientvar->{'locked'} and $clientvar->{'locks'}[0] ne $locki->{'lock'}) { } |
574
|
0 |
0 |
if $IPC::Locker::Server::Debug |
581
|
0 |
0 |
if (client_status($clientvar)) |
587
|
0 |
0 |
if $IPC::Locker::Server::Debug |
611
|
0 |
0 |
if $IPC::Locker::Server::Debug |
619
|
0 |
0 |
if (($self->{'_recheck_locks_time'} || 0) < $time) |
632
|
0 |
0 |
if ($locki->{'locked'}) |
633
|
0 |
0 |
if ($locki->{'timelimit'} and $locki->{'timelimit'} <= $time) { } |
|
0 |
0 |
elsif ($locki->{'autounlock'}) { } |
634
|
0 |
0 |
if $IPC::Locker::Server::Debug |
638
|
0 |
0 |
if (($locki->{'autounlock_check_time'} || 0) < $time) |
647
|
0 |
0 |
if ($locki->{'hostname'} eq $IPC::Locker::Server::Hostname) |
649
|
0 |
0 |
if ($dead) |
650
|
0 |
0 |
if $IPC::Locker::Server::Debug |
654
|
0 |
0 |
if (not defined $dead) |
657
|
0 |
0 |
if $IPC::Locker::Server::Debug |
672
|
0 |
0 |
if ($locki = locki_find($lockname)) { } |
674
|
0 |
0 |
if ($locki->{'locked'} and $locki->{'owner'} eq $clientvar->{'user'}) { } |
675
|
0 |
0 |
if $IPC::Locker::Server::Debug |
682
|
0 |
0 |
if ($locki->{'waiters'}[$n]{'user'} eq $clientvar->{'user'}) |
683
|
0 |
0 |
if $IPC::Locker::Server::Debug |
689
|
0 |
0 |
unless ($found) |
690
|
0 |
0 |
if $IPC::Locker::Server::Debug |
703
|
0 |
0 |
if $IPC::Locker::Server::Debug |
716
|
0 |
0 |
if $IPC::Locker::Server::Debug |
717
|
0 |
0 |
if ($self->{'family'} eq "UNIX" and $self->{'unix_socket_created'}) |