package Mail::SpamAssassin::Win32Locker;
use strict;
use bytes;
use Fcntl;
use Mail::SpamAssassin;
use Mail::SpamAssassin::Locker;
use Mail::SpamAssassin::Util;
use File::Spec;
use Time::Local;
use vars qw{
@ISA
};
@ISA = qw(Mail::SpamAssassin::Locker);
sub new {
my $class = shift;
my $self = $class->SUPER::new(@_);
$self;
}
use constant LOCK_MAX_AGE => 600;
sub safe_lock {
my ($self, $path, $max_retries) = @_;
my @stat;
$max_retries ||= 30;
my $lock_file = "$path.lock";
if (-e $lock_file && -M $lock_file > (LOCK_MAX_AGE / 86400)) {
dbg("lock: $$ breaking stale lock: $lock_file");
unlink($lock_file) || warn "lock: $$ unlink of lock file $lock_file failed: $!\n";
}
for (my $retries = 0; $retries < $max_retries; $retries++) {
if ($retries > 0) {
sleep(1);
}
dbg("lock: $$ trying to get lock on $path with $retries retries");
if (sysopen(LOCKFILE, $lock_file, O_RDWR|O_CREAT|O_EXCL)) {
dbg("lock: $$ link to $lock_file: sysopen ok");
close(LOCKFILE);
return 1;
}
dbg ("lock: $$ sysopen failed: $!");
my @stat = stat($lock_file);
my $age = ($ if ((!defined($age) && $retries > $max_retries / 2) ||
(defined($age) && (time - $age > LOCK_MAX_AGE)))
{
dbg("lock: $$ breaking stale lock: $lock_file");
unlink ($lock_file) || warn "lock: $$ unlink of lock file $lock_file failed: $!\n";
}
}
return 0;
}
sub safe_unlock {
my ($self, $path) = @_;
unlink ("$path.lock") || warn "unlock: $$ unlink failed: $path.lock\n";
dbg("unlock: $$ unlink $path.lock");
}
sub dbg { Mail::SpamAssassin::dbg (@_); }
1;