File Coverage

src_bin/iqbi-damiq

Criterion	Covered	Total	%
statement	43	53	81.1
branch	19	42	45.2
condition	6	9	66.6
subroutine	11	11	100.0
pod			n/a
total	79	115	68.7

#!/usr/bin/env perl
#
# iqbi-damiq - launcher for Algorithm::EventsPerSecond::Sukkal

use 5.006;
use strict;
use warnings;
use Getopt::Long qw(GetOptions);
use Pod::Usage   qw(pod2usage);
use Algorithm::EventsPerSecond;
use Algorithm::EventsPerSecond::Sukkal;

my (
	$socket,      $window, $max_keys,  $max_key_length, $idle_timeout, $sweep_interval,
	$max_clients, $mode,   $daemonize, $pidfile,        $require_xs,
);

GetOptions(
	'socket|s=s'       => \$socket,
	'require-xs|x'     => \$require_xs,
	'window|w=i'       => \$window,
	'max-keys=i'       => \$max_keys,
	'max-key-length=i' => \$max_key_length,
	'idle-timeout=i'   => \$idle_timeout,
	'sweep-interval=i' => \$sweep_interval,
	'max-clients=i'    => \$max_clients,
	'mode|m=s'         => \$mode,
	'daemonize|d'      => \$daemonize,
	'pidfile|p=s'      => \$pidfile,
	'help|h'           => sub { pod2usage( -exitval => 0, -verbose => 1 ) },
	'version|v'        => sub {
		print "iqbi-damiq (Algorithm::EventsPerSecond::Sukkal) " . "$Algorithm::EventsPerSecond::Sukkal::VERSION\n";
		exit 0;
	},
) or pod2usage( -exitval => 2 );

pod2usage( -exitval => 2, -message => "iqbi-damiq: --socket is required\n" )
	unless defined $socket;

die "iqbi-damiq: --require-xs given but the " . Algorithm::EventsPerSecond->backend . " backend is loaded, not XS\n"
	if $require_xs && Algorithm::EventsPerSecond->backend ne 'XS';

my $sukkal = Algorithm::EventsPerSecond::Sukkal->new(
	socket => $socket,
	( defined $window         ? ( window         => $window )         : () ),
	( defined $max_keys       ? ( max_keys       => $max_keys )       : () ),
	( defined $max_key_length ? ( max_key_length => $max_key_length ) : () ),
	( defined $idle_timeout   ? ( idle_timeout   => $idle_timeout )   : () ),
	( defined $sweep_interval ? ( sweep_interval => $sweep_interval ) : () ),
	( defined $max_clients    ? ( max_clients    => $max_clients )    : () ),
	( defined $mode           ? ( socket_mode    => $mode )           : () ),
);

if ($daemonize) {
	require POSIX;

	defined( my $pid = fork ) or die "iqbi-damiq: cannot fork: $!\n";
	exit 0 if $pid;
	POSIX::setsid() != -1  or die "iqbi-damiq: setsid failed: $!\n";
	defined( $pid = fork ) or die "iqbi-damiq: cannot fork: $!\n";
	exit 0 if $pid;

	chdir '/';
	open STDIN,  '<', '/dev/null';
	open STDOUT, '>', '/dev/null';
	open STDERR, '>', '/dev/null';
} ## end if ($daemonize)

my $pidfile_owner;
if ( defined $pidfile ) {
	open my $fh, '>', $pidfile
		or die "iqbi-damiq: cannot write pidfile $pidfile: $!\n";
	print $fh "$$\n";
	close $fh;
	$pidfile_owner = $$;
}

END {
	unlink $pidfile
		if defined $pidfile && defined $pidfile_owner && $$ == $pidfile_owner;
}

$SIG{INT} = $SIG{TERM} = sub { $sukkal->stop };
$SIG{HUP} = 'IGNORE';

printf "iqbi-damiq: serving %s (window=%ds, backend=%s)\n",
	$socket, $sukkal->{window}, Algorithm::EventsPerSecond->backend
	unless $daemonize;

$sukkal->run;

print "iqbi-damiq: shut down\n" unless $daemonize;

exit 0;

__END__