[gruntmaster-daemon.git] / lib / Gruntmaster / Daemon / Base.pm

package Gruntmaster::Daemon::Base;

use 5.014000;
use strict;
use warnings;
use parent qw/Exporter/;
our @EXPORT_OK = qw/watch/;
our $VERSION = '0.001';

use Fcntl qw/O_WRONLY O_EXCL O_CREAT/;
use Linux::Inotify2;
use Log::Log4perl qw/get_logger/;

##################################################

sub process{
  my ($name, $dir, $cb) = @_;
  my $logger = get_logger;
  $logger->debug("Taking job $name...");
  if (sysopen my $file, "$dir/$name/pidfile", O_WRONLY | O_EXCL | O_CREAT){
	$logger->debug("Successfully taken job $name, executing callback");
	$cb->("$dir/$name");
  } else {
	$logger->debug("Job $name already taken");
  }
}

sub watch{
  my ($dir, $cb) = @_;
  for (<$dir/*>) {
	s,$dir/,,;
	process $_, $dir, $cb;
  }

  my $logger = Log::Log4perl->get_logger(__PACKAGE__);
  my $inotify = Linux::Inotify2->new or $logger->logdie("Unable to create Linux::Inotify2 object: $!");
  $inotify->watch($dir, IN_MOVED_TO, sub { process $_[0]->name, $dir, $cb }) or $logger->logdie("Error watching $dir: $!");
  1 while $inotify->poll;
  $logger->logdie("Inotify polling stopped: $!");
}

1
Commit	Line	Data
5c5cd38a MG	1	package Gruntmaster::Daemon::Base;
	2
	3	use 5.014000;
	4	use strict;
	5	use warnings;
	6	use parent qw/Exporter/;
	7	our @EXPORT_OK = qw/watch/;
	8	our $VERSION = '0.001';
	9
	10	use Fcntl qw/O_WRONLY O_EXCL O_CREAT/;
	11	use Linux::Inotify2;
	12	use Log::Log4perl qw/get_logger/;
	13
	14	##################################################
	15
	16	sub process{
	17	my ($name, $dir, $cb) = @_;
	18	my $logger = get_logger;
	19	$logger->debug("Taking job $name...");
	20	if (sysopen my $file, "$dir/$name/pidfile", O_WRONLY \| O_EXCL \| O_CREAT){
	21	$logger->debug("Successfully taken job $name, executing callback");
	22	$cb->("$dir/$name");
	23	} else {
	24	$logger->debug("Job $name already taken");
	25	}
	26	}
	27
	28	sub watch{
	29	my ($dir, $cb) = @_;
	30	for (<$dir/*>) {
	31	s,$dir/,,;
	32	process $_, $dir, $cb;
	33	}
	34
	35	my $logger = Log::Log4perl->get_logger(__PACKAGE__);
	36	my $inotify = Linux::Inotify2->new or $logger->logdie("Unable to create Linux::Inotify2 object: $!");
	37	$inotify->watch($dir, IN_MOVED_TO, sub { process $_[0]->name, $dir, $cb }) or $logger->logdie("Error watching $dir: $!");
	38	1 while $inotify->poll;
	39	$logger->logdie("Inotify polling stopped: $!");
	40	}
	41
	42	1