line |
true |
false |
branch |
87
|
0 |
0 |
if (defined $ENV{'CLACKS_SIMULATED_TIME_OFFSET'}) |
104
|
0 |
0 |
if (defined $ENV{'PC_CONFIG_PATHS'}) { } |
115
|
0 |
0 |
if ($path ne "" and not $path =~ m[/$]u) |
119
|
0 |
0 |
unless -f $fullfname |
125
|
0 |
0 |
unless $varname =~ /^PC\_/u |
134
|
0 |
0 |
if (not defined $filedata or $filedata eq "") |
144
|
0 |
0 |
if (defined $config->{'hosts'}{$hname}) |
152
|
0 |
0 |
unless (defined $self->{'config'}{'throttle'}{'maxsleep'}) |
155
|
0 |
0 |
unless (defined $self->{'config'}{'throttle'}{'step'}) |
161
|
0 |
0 |
unless (defined $self->{'config'}{'ssl'} and defined $self->{'config'}{'ssl'}{'cert'} and defined $self->{'config'}{'ssl'}{'key'}) |
166
|
0 |
0 |
unless (-f $self->{'config'}{'ssl'}{'cert'}) |
169
|
0 |
0 |
unless (-f $self->{'config'}{'ssl'}{'key'}) |
173
|
0 |
0 |
unless (defined $self->{'config'}{'username'}) |
176
|
0 |
0 |
unless (defined $self->{'config'}{'password'}) |
181
|
0 |
0 |
if (defined $self->{'config'}{'persistancefile'}) { } |
187
|
0 |
0 |
if (not defined $self->{'config'}{'persistanceinterval'}) { } |
193
|
0 |
0 |
unless (defined $self->{'config'}{'interclacksreconnecttimeout'}) |
197
|
0 |
0 |
unless (defined $self->{'config'}{'authtimeout'}) |
201
|
0 |
0 |
unless (defined $self->{'config'}{'deletedcachetime'}) |
204
|
0 |
0 |
unless (defined $self->{'config'}{'stalecachetime'}) |
210
|
0 |
0 |
if (defined $config->{'ip'}) |
215
|
0 |
0 |
unless my $tcp = "IO::Socket::IP"->new("LocalHost", $ip, "LocalPort", $config->{'port'}, "Listen", 1, "Blocking", 0, "ReuseAddr", 1, "Proto", "tcp") |
226
|
0 |
0 |
if (defined $config->{'socket'} or defined $self->{'config'}{'master'}{'socket'}) |
232
|
0 |
0 |
unless ($udsloaded) |
255
|
0 |
0 |
if (defined $config->{'socket'}) |
257
|
0 |
0 |
if (-S $socket) |
261
|
0 |
0 |
unless my $tcp = "IO::Socket::UNIX"->new("Type", 1, "Local", $socket, "Listen", 1) |
272
|
0 |
0 |
if (defined $config->{'socketchmod'} and $config->{'socketchmod'} ne "") |
296
|
0 |
0 |
if (open my $ifh, '<', $fname) { } |
308
|
0 |
0 |
if (not defined $endline and $accesstimeline eq 'ENDBYTES') { } |
316
|
0 |
0 |
if (not defined $line && defined $timestampline or $endline ne "ENDBYTES") |
323
|
0 |
0 |
if ($line ne "") |
329
|
0 |
0 |
unless ($loadok) |
342
|
0 |
0 |
if ($timestampline ne "") |
349
|
0 |
0 |
if (not $loadok) { } |
360
|
0 |
0 |
if ($needupgrade) { } |
|
0 |
0 |
elsif ($accesstimeline ne '') { } |
372
|
0 |
0 |
if (not $loadok) { } |
417
|
0 |
0 |
if ($self->{'persistance'}) |
421
|
0 |
0 |
if (-f $self->{'config'}{'persistancefile'}) |
424
|
0 |
0 |
if (defined $cc and ref $cc eq "HASH") |
433
|
0 |
0 |
if (not $loadok and -f $previousfname) |
436
|
0 |
0 |
if (defined $cc and ref $cc eq "HASH") |
444
|
0 |
0 |
if (not $loadok and -f $tempfname) |
447
|
0 |
0 |
if (defined $cc and ref $cc eq "HASH") |
456
|
0 |
0 |
if (not $loadok) { } |
468
|
0 |
0 |
if ($shutdowntime and $shutdowntime < &Net::Clacks::Server::time()) |
474
|
0 |
0 |
if ($savecache and $now > $lastsavecache + $self->{'persistanceinterval'}) |
481
|
0 |
0 |
if (defined $self->{'config'}{'master'}{'socket'} or defined $self->{'config'}{'master'}{'ip'}) |
483
|
0 |
0 |
if (defined $self->{'config'}{'master'}{'socket'}) { } |
488
|
0 |
0 |
if (not defined $clients{$mcid} and $nextinterclackscheck < $now) |
494
|
0 |
0 |
if (defined $self->{'config'}{'master'}{'socket'}) { } |
507
|
0 |
0 |
if (not defined $msocket) { } |
512
|
0 |
0 |
if (ref $msocket ne "IO::Socket::UNIX") |
518
|
0 |
0 |
unless ($encrypted) |
552
|
0 |
0 |
if (defined $self->{'config'}{'master'}{'ip'}) |
567
|
0 |
0 |
if (defined $clientsocket) |
570
|
0 |
0 |
if (ref $tcpsocket eq 'IO::Socket::UNIX') { } |
579
|
0 |
0 |
if ($clients{$debugcid}{'mirror'}) |
584
|
0 |
0 |
if (ref $clientsocket ne "IO::Socket::UNIX") |
605
|
0 |
0 |
unless ($encrypted) |
656
|
0 |
0 |
unless ($clients{$cid}{'socket'}->connected) |
660
|
0 |
0 |
if (not $clients{$cid}{'interclacks'}) { } |
661
|
0 |
0 |
if ($clients{$cid}{'lastping'} > 0 and $clients{$cid}{'lastping'} < $pingtime) |
667
|
0 |
0 |
if ($clients{$cid}{'lastping'} < $interclackspingtime) |
674
|
0 |
0 |
if ($clients{$cid}{'interclacks'} and $clients{$cid}{'lastinterclacksping'} < $interclackspinginterval) |
679
|
0 |
0 |
if (not $clients{$cid}{'authok'} and $clients{$cid}{'authtimeout'} < $now) |
688
|
0 |
0 |
if (defined $clients{$cid}) |
691
|
0 |
0 |
if ($clients{$debugcid}{'mirror'}) |
696
|
0 |
0 |
if ($clients{$cid}{'interclacksclient'} and $interclackslock) |
708
|
0 |
0 |
unless (scalar keys %clients) |
717
|
0 |
0 |
if (length $clients{$cid}{'buffer'} > 0) |
724
|
0 |
0 |
if ($hasoutbufferwork) |
741
|
0 |
0 |
unless ($readok) |
745
|
0 |
0 |
if (defined $rawbuffer and length $rawbuffer) |
749
|
0 |
0 |
unless ($readchunksleft) |
760
|
0 |
0 |
if ($totalread) { } |
765
|
0 |
0 |
if ($clients{$cid}{'failcount'} > 5) |
778
|
0 |
0 |
if ($buf eq "\r") { } |
|
0 |
0 |
elsif ($buf eq "\n") { } |
781
|
0 |
0 |
if $clients{$cid}{'buffer'} eq "" |
794
|
0 |
0 |
if ($interclackslock and not $clients{$cid}{'interclacksclient'}) |
809
|
0 |
0 |
if $clients{$cid}{'inmessages'}[0]{'releasetime'} > $now |
814
|
0 |
0 |
if ($inmsg =~ /^CLACKS\ (.+)/u) |
825
|
0 |
0 |
if ($inmsg =~ /^OVERHEAD\ (.+?)\ (.+)/u) |
832
|
0 |
0 |
if (contains($key, \@flagparts)) { } |
841
|
0 |
0 |
if ($parsedflags{'auth_token'}) |
842
|
0 |
0 |
if ($value eq $self->{'authtoken'}) { } |
857
|
0 |
0 |
unless ($clients{$cid}{'authok'}) |
861
|
0 |
0 |
if ($parsedflags{'timestamp'}) |
868
|
0 |
0 |
if ($parsedflags{'lock_for_sync'} and $clients{$cid}{'interclacksclient'}) |
869
|
0 |
0 |
if ($value) { } |
882
|
0 |
0 |
if defined $self->{'clackscache'}{$ckey} |
890
|
0 |
0 |
if ($parsedflags{'close_all_connections'} and $value) |
892
|
0 |
0 |
if ($clients{$closecid}{'interclacks'} and $parsedflags{'forward_message'}) |
901
|
0 |
0 |
if ($parsedflags{'shutdown_service'}) |
903
|
0 |
0 |
if ($value > 0) |
908
|
0 |
0 |
if ($parsedflags{'discard_message'}) |
911
|
0 |
0 |
if ($parsedflags{'no_logging'}) |
915
|
0 |
0 |
if ($parsedflags{'error_message'}) |
919
|
0 |
0 |
if ($parsedflags{'set_interclacks_mode'}) |
923
|
0 |
0 |
if ($value) { } |
940
|
0 |
0 |
if defined $self->{'clackscache'}{$ckey} |
956
|
0 |
0 |
if $key eq "Z" |
957
|
0 |
0 |
if ($newflags{$overheadflags{$key}}) |
961
|
0 |
0 |
if ($newflagstring eq "") |
965
|
0 |
0 |
if ($parsedflags{'forward_message'}) |
967
|
0 |
0 |
if $cid eq $overheadcid and not $parsedflags{'return_to_sender'} |
975
|
0 |
0 |
unless ($clients{$cid}{'authok'}) |
979
|
0 |
0 |
unless ($nodebug) |
990
|
0 |
0 |
if ($discardafterlogging) |
995
|
0 |
0 |
if ($inmsg =~ /^OVERHEAD\ /u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^LISTEN\ (.*)/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^UNLISTEN\ (.*)/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^MONITOR/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^UNMONITOR/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^QUIT/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^TIMEOUT/u and $clients{$cid}{'interclacks'}) { } |
|
0 |
0 |
elsif ($inmsg =~ /^PING/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^NOPING/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^NOTIFY\ (.*)/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^SET\ (.+?)\=(.*)/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^KEYSYNC\ (.+?)\ (.+?)\ (.+?)\ (.+?)\=(.*)/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^STORE\ (.+?)\=(.*)/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^SETANDSTORE\ (.+?)\=(.*)/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^RETRIEVE\ (.+)/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^REMOVE\ (.+)/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^INCREMENT\ (.+)/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^DECREMENT\ (.+)/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^KEYLIST/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^CLEARCACHE/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^CLIENTLIST/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^CLIENTDISCONNECT\ (.+)/u) { } |
|
0 |
0 |
elsif ($inmsg =~ /^FLUSH\ (.+)/u) { } |
1045
|
0 |
0 |
if ($atimestamp) |
1049
|
0 |
0 |
unless (defined $self->{'clackscachetime'}{$ckey}) |
1052
|
0 |
0 |
if (not defined $self->{'clackscachetime'}{$ckey} or $ctimestamp > $self->{'clackscachetime'}{$ckey}) |
1054
|
0 |
0 |
if ($cmode eq 'U') { } |
1060
|
0 |
0 |
if (defined $self->{'clackscache'}{$ckey}) |
1063
|
0 |
0 |
if (defined $self->{'clackscacheaccesstime'}{$ckey}) |
1091
|
0 |
0 |
if (defined $self->{'clackscache'}{$ckey}) { } |
1101
|
0 |
0 |
if (defined $self->{'clackscache'}{$ckey}) |
1105
|
0 |
0 |
if (defined $self->{'clackscacheaccesstime'}{$ckey}) |
1112
|
0 |
0 |
if ($ckey =~ /(.+)\=(.+)/u) |
1116
|
0 |
0 |
if (defined $self->{'clackscache'}{$ckey}) { } |
1127
|
0 |
0 |
if ($ckey =~ /(.+)\=(.+)/u) |
1131
|
0 |
0 |
if (defined $self->{'clackscache'}{$ckey}) { } |
1172
|
0 |
0 |
if (defined $clients{$lmccid}) |
1189
|
0 |
0 |
if ($sendinterclacks) |
1191
|
0 |
0 |
if ($cid eq $interclackscid or not $clients{$interclackscid}{'interclacks'}) |
1205
|
0 |
0 |
if $self->{'clackscachetime'}{$key} > $stillvalidtime |
1206
|
0 |
0 |
if (defined $self->{'clackscache'}{$key}) |
1216
|
0 |
0 |
if $self->{'clackscacheaccesstime'}{$key} > $stillvalidtime |
1218
|
0 |
0 |
if (defined $self->{'clackscache'}) |
1221
|
0 |
0 |
if (defined $self->{'clackscachetime'}) |
1240
|
0 |
0 |
if ($line->{'type'} eq "DEBUG" and $clients{$cid}{'mirror'}) |
1244
|
0 |
0 |
if ($cid eq $line->{'sender'}) |
1248
|
0 |
0 |
if ($line->{'type'} ne "DEBUG" and defined $clients{$cid}{'listening'}{$line->{'name'}}) |
1250
|
0 |
0 |
if ($line->{'type'} eq 'NOTIFY') { } |
|
0 |
0 |
elsif ($line->{'type'} eq 'SET') { } |
|
0 |
0 |
elsif ($line->{'type'} eq 'SETANDSTORE') { } |
1257
|
0 |
0 |
if ($clients{$cid}{'interclacks'}) { } |
1271
|
0 |
0 |
if $clients{$cid}{'outmessages'}[0]{'releasetime'} > $now |
1274
|
0 |
0 |
if ($outmsg->{'message'} eq 'EXIT') { } |
1292
|
0 |
0 |
if (length $clients{$cid}{'outbuffer'}) { } |
|
0 |
0 |
elsif ($clients{$cid}{'lastmessage'} + 60 < $now) { } |
1300
|
0 |
0 |
unless length $clients{$cid}{'outbuffer'} |
1308
|
0 |
0 |
if ($Net::Clacks::Server::EVAL_ERROR) |
1313
|
0 |
0 |
if (not $clients{$cid}{'socket'}->opened or $clients{$cid}{'socket'}->error or $Net::Clacks::Server::ERRNO ne "" and not $Net::Clacks::Server::ERRNO{'EWOULDBLOCK'}) |
1319
|
0 |
0 |
if (defined $written and $written) |
1320
|
0 |
0 |
if (length $clients{$cid}{'outbuffer'} == $written) { } |
1328
|
0 |
0 |
if ($workCount) { } |
|
0 |
0 |
elsif ($self->{'usleep'} < $self->{'config'}{'throttle'}{'maxsleep'}) { } |
1333
|
0 |
0 |
if ($self->{'usleep'}) |
1359
|
0 |
0 |
unless ($self->{'persistance'}) |
1373
|
0 |
0 |
if ($savecache == 1) |
1378
|
0 |
0 |
if (open my $ofh, ">", $tempfname) |
1387
|
0 |
0 |
if ($savecache == 2) |
1398
|
0 |
0 |
unless defined $val |
1402
|
0 |
0 |
unless defined $val |
1411
|
0 |
0 |
unless length $buffer |
1419
|
0 |
0 |
if ($Net::Clacks::Server::EVAL_ERROR or not $ok) |
1441
|
0 |
0 |
unless open my $fh, "<", $fname |