1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
# Copyrights 2001-2014 by [Mark Overmeer].
# For other contributors see ChangeLog.
# See the manual pages for details on the licensing terms.
# Pod stripped from pm file by OODoc 2.01.
use strict;
package Mail::Box::Locker::Mutt;
use vars '$VERSION';
$VERSION = '2.117';
use base 'Mail::Box::Locker';
use POSIX qw/sys_wait_h/;
sub init($)
{ my ($self, $args) = @_;
$self->SUPER::init($args);
$self->{MBLM_exe} = $args->{exe} || 'mutt_dotlock';
$self;
}
sub name() {'MUTT'}
sub lockfile() { shift->filename . '.lock' }
sub exe() {shift->{MBLM_exe}}
sub unlock()
{ my $self = shift;
$self->{MBL_has_lock}
or return $self;
unless(system($self->exe, '-u', $self->filename))
{ my $folder = $self->folder;
$self->log(WARNING => "Couldn't remove mutt-unlock $folder: $!");
}
delete $self->{MBL_has_lock};
$self;
}
#-------------------------------------------
sub lock()
{ my $self = shift;
my $folder = $self->folder;
if($self->hasLock)
{ $self->log(WARNING => "Folder $folder already mutt-locked");
return 1;
}
my $filename = $self->filename;
my $lockfn = $self->lockfile;
my $end = $self->{MBL_timeout} eq 'NOTIMEOUT' ? -1
: $self->{MBL_timeout};
my $expire = $self->{MBL_expires}/86400; # in days for -A
my $exe = $self->exe;
while(1)
{
if(system($exe, '-p', '-r', 1, $filename))
{ unless(WIFEXITED($?) && WEXITSTATUS($?)==3)
{ $self->log(ERROR => "Will never get a mutt-lock: $!");
return 0;
}
}
else
{ return $self->{MBL_has_lock} = 1;
}
if(-e $lockfn && -A $lockfn > $expire)
{
if(system($exe, '-f', '-u', $filename))
{ $self->log(ERROR =>
"Failed to remove expired mutt-lock $lockfn: $!");
last;
}
else
{ $self->log(WARNING => "Removed expired mutt-lock $lockfn");
redo;
}
}
last unless --$end;
sleep 1;
}
return 0;
}
#-------------------------------------------
sub isLocked()
{ my $self = shift;
system($self->exe, '-t', $self->filename);
WIFEXITED($?) && WEXITSTATUS($?)==3;
}
#-------------------------------------------
1;
|
