| line |
stmt |
bran |
cond |
sub |
pod |
time |
code |
|
1
|
|
|
|
|
|
|
package File::Flock::Tiny; |
|
2
|
|
|
|
|
|
|
|
|
3
|
5
|
|
|
5
|
|
119641
|
use 5.008; |
|
|
5
|
|
|
|
|
20
|
|
|
|
5
|
|
|
|
|
187
|
|
|
4
|
5
|
|
|
5
|
|
29
|
use strict; |
|
|
5
|
|
|
|
|
5
|
|
|
|
5
|
|
|
|
|
150
|
|
|
5
|
5
|
|
|
5
|
|
28
|
use warnings; |
|
|
5
|
|
|
|
|
15
|
|
|
|
5
|
|
|
|
|
116
|
|
|
6
|
5
|
|
|
5
|
|
21
|
use Carp; |
|
|
5
|
|
|
|
|
10
|
|
|
|
5
|
|
|
|
|
541
|
|
|
7
|
5
|
|
|
5
|
|
6215
|
use IO::Handle; |
|
|
5
|
|
|
|
|
43613
|
|
|
|
5
|
|
|
|
|
274
|
|
|
8
|
5
|
|
|
5
|
|
39
|
use Fcntl qw(:flock); |
|
|
5
|
|
|
|
|
12
|
|
|
|
5
|
|
|
|
|
2338
|
|
|
9
|
|
|
|
|
|
|
|
|
10
|
|
|
|
|
|
|
=head1 NAME |
|
11
|
|
|
|
|
|
|
|
|
12
|
|
|
|
|
|
|
File::Flock::Tiny - yet another flock package |
|
13
|
|
|
|
|
|
|
|
|
14
|
|
|
|
|
|
|
=cut |
|
15
|
|
|
|
|
|
|
|
|
16
|
|
|
|
|
|
|
our $VERSION = '0.14'; |
|
17
|
|
|
|
|
|
|
$VERSION = eval $VERSION; |
|
18
|
|
|
|
|
|
|
|
|
19
|
|
|
|
|
|
|
=head1 SYNOPSIS |
|
20
|
|
|
|
|
|
|
|
|
21
|
|
|
|
|
|
|
my $lock = File::Flock::Tiny->lock($file); |
|
22
|
|
|
|
|
|
|
... # do something |
|
23
|
|
|
|
|
|
|
$lock->release; |
|
24
|
|
|
|
|
|
|
|
|
25
|
|
|
|
|
|
|
=head1 DESCRIPTION |
|
26
|
|
|
|
|
|
|
|
|
27
|
|
|
|
|
|
|
Simple wrapper around L for ease of use. |
|
28
|
|
|
|
|
|
|
|
|
29
|
|
|
|
|
|
|
=head1 CLASS METHODS |
|
30
|
|
|
|
|
|
|
|
|
31
|
|
|
|
|
|
|
=cut |
|
32
|
|
|
|
|
|
|
|
|
33
|
|
|
|
|
|
|
sub _open_file { |
|
34
|
39
|
|
|
39
|
|
82
|
my $file = shift; |
|
35
|
39
|
|
|
|
|
64
|
my $fh; |
|
36
|
39
|
100
|
100
|
|
|
766
|
if ( ref $file && ( ref $file eq 'GLOB' || $file->isa("IO::Handle") ) ) { |
|
|
|
|
66
|
|
|
|
|
|
37
|
8
|
50
|
|
|
|
52
|
$fh = IO::Handle->new_from_fd( $file, ">>" ) or croak "Coundn't dupe file: $!"; |
|
38
|
|
|
|
|
|
|
} |
|
39
|
|
|
|
|
|
|
else { |
|
40
|
31
|
50
|
|
|
|
565
|
open $fh, ">>", $file or croak "Couldn't open file: $!"; |
|
41
|
|
|
|
|
|
|
} |
|
42
|
39
|
|
|
|
|
4163
|
return $fh; |
|
43
|
|
|
|
|
|
|
} |
|
44
|
|
|
|
|
|
|
|
|
45
|
|
|
|
|
|
|
=head2 File::Flock::Tiny->lock($file) |
|
46
|
|
|
|
|
|
|
|
|
47
|
|
|
|
|
|
|
Acquire exclusive lock on the file. I<$file> may be a file name or an opened |
|
48
|
|
|
|
|
|
|
file handler. If a filename given and the file doesn't exist it will be |
|
49
|
|
|
|
|
|
|
created. The method returns a lock object, the file remains locked until this |
|
50
|
|
|
|
|
|
|
object goes out of the scope, or till you call I method on it. |
|
51
|
|
|
|
|
|
|
|
|
52
|
|
|
|
|
|
|
=cut |
|
53
|
|
|
|
|
|
|
|
|
54
|
|
|
|
|
|
|
sub lock { |
|
55
|
23
|
|
|
23
|
1
|
52906
|
my $fh = _open_file( $_[1] ); |
|
56
|
23
|
50
|
|
|
|
199
|
flock $fh, LOCK_EX or croak $!; |
|
57
|
23
|
|
|
|
|
133
|
return bless $fh, "File::Flock::Tiny::Lock"; |
|
58
|
|
|
|
|
|
|
} |
|
59
|
|
|
|
|
|
|
|
|
60
|
|
|
|
|
|
|
=head2 File::Flock::Tiny->trylock($file) |
|
61
|
|
|
|
|
|
|
|
|
62
|
|
|
|
|
|
|
Same as I, but doesn't block and returns immediately, if the lock can not |
|
63
|
|
|
|
|
|
|
be acquired returns undef. |
|
64
|
|
|
|
|
|
|
|
|
65
|
|
|
|
|
|
|
=cut |
|
66
|
|
|
|
|
|
|
|
|
67
|
|
|
|
|
|
|
sub trylock { |
|
68
|
16
|
|
|
16
|
1
|
9486
|
my $fh = _open_file( $_[1] ); |
|
69
|
16
|
|
|
|
|
64
|
bless $fh, "File::Flock::Tiny::Lock"; |
|
70
|
16
|
100
|
|
|
|
176
|
return unless flock $fh, LOCK_EX | LOCK_NB; |
|
71
|
10
|
|
|
|
|
34
|
return $fh; |
|
72
|
|
|
|
|
|
|
} |
|
73
|
|
|
|
|
|
|
|
|
74
|
|
|
|
|
|
|
=head2 File::Flock::Tiny->write_pid($file) |
|
75
|
|
|
|
|
|
|
X |
|
76
|
|
|
|
|
|
|
|
|
77
|
|
|
|
|
|
|
Try to lock the file and save the process ID into it. Returns the lock object, |
|
78
|
|
|
|
|
|
|
or undef if the file was already locked. The lock returned by I will |
|
79
|
|
|
|
|
|
|
be automatically released when the object goes out of the scope in the process |
|
80
|
|
|
|
|
|
|
that locked the pid file, in child processes you can release the lock |
|
81
|
|
|
|
|
|
|
explicitely. |
|
82
|
|
|
|
|
|
|
|
|
83
|
|
|
|
|
|
|
=cut |
|
84
|
|
|
|
|
|
|
|
|
85
|
|
|
|
|
|
|
sub write_pid { |
|
86
|
4
|
|
|
4
|
1
|
419622
|
my ( $class, $file ) = @_; |
|
87
|
4
|
|
|
|
|
300
|
my $lock = $class->trylock($file); |
|
88
|
4
|
100
|
|
|
|
30
|
$lock->write_pid if $lock; |
|
89
|
4
|
|
|
|
|
72
|
return $lock; |
|
90
|
|
|
|
|
|
|
} |
|
91
|
|
|
|
|
|
|
|
|
92
|
|
|
|
|
|
|
package File::Flock::Tiny::Lock; |
|
93
|
5
|
|
|
5
|
|
5379
|
use parent 'IO::Handle'; |
|
|
5
|
|
|
|
|
1544
|
|
|
|
5
|
|
|
|
|
32
|
|
|
94
|
5
|
|
|
5
|
|
301
|
use Fcntl qw(:flock); |
|
|
5
|
|
|
|
|
15
|
|
|
|
5
|
|
|
|
|
1513
|
|
|
95
|
|
|
|
|
|
|
|
|
96
|
|
|
|
|
|
|
=head1 LOCK OBJECT METHODS |
|
97
|
|
|
|
|
|
|
|
|
98
|
|
|
|
|
|
|
Here is the list of methods that you can invoke on a lock object. |
|
99
|
|
|
|
|
|
|
|
|
100
|
|
|
|
|
|
|
=head2 $lock->write_pid |
|
101
|
|
|
|
|
|
|
|
|
102
|
|
|
|
|
|
|
Truncates locked file and saves PID into it. Also marks the lock object as tied |
|
103
|
|
|
|
|
|
|
to the current process, so it only will be automatically released when goes out |
|
104
|
|
|
|
|
|
|
of scope in the current process but not in any of the child processes created |
|
105
|
|
|
|
|
|
|
after this call. This method may be used to create pid files for daemons, you |
|
106
|
|
|
|
|
|
|
can lock file in parent process to ensure that there is no another copy of the |
|
107
|
|
|
|
|
|
|
daemon running already, and then fork and write pid of the child into the file. |
|
108
|
|
|
|
|
|
|
Here is the simplified example of daemonizing code: |
|
109
|
|
|
|
|
|
|
|
|
110
|
|
|
|
|
|
|
my $pid = File::Flock::Tiny->trylock('daemon.pid') |
|
111
|
|
|
|
|
|
|
or die "Daemon already running"; |
|
112
|
|
|
|
|
|
|
if ( fork == 0 ) { |
|
113
|
|
|
|
|
|
|
setsid; |
|
114
|
|
|
|
|
|
|
if (fork) { |
|
115
|
|
|
|
|
|
|
# intermediate process |
|
116
|
|
|
|
|
|
|
$pid->close; |
|
117
|
|
|
|
|
|
|
exit 0; |
|
118
|
|
|
|
|
|
|
} |
|
119
|
|
|
|
|
|
|
} |
|
120
|
|
|
|
|
|
|
else { |
|
121
|
|
|
|
|
|
|
# parent process |
|
122
|
|
|
|
|
|
|
$pid->close; |
|
123
|
|
|
|
|
|
|
exit 0; |
|
124
|
|
|
|
|
|
|
} |
|
125
|
|
|
|
|
|
|
# daemon process |
|
126
|
|
|
|
|
|
|
# perhaps you want to close all opened files here, do not close $pid! |
|
127
|
|
|
|
|
|
|
$pid->write_pid; |
|
128
|
|
|
|
|
|
|
|
|
129
|
|
|
|
|
|
|
It is importand to remember to close the lock file in the parent and |
|
130
|
|
|
|
|
|
|
intermediate processes, otherwise the lock will be released during destruction |
|
131
|
|
|
|
|
|
|
of the variable. |
|
132
|
|
|
|
|
|
|
|
|
133
|
|
|
|
|
|
|
=cut |
|
134
|
|
|
|
|
|
|
|
|
135
|
|
|
|
|
|
|
sub write_pid { |
|
136
|
2
|
|
|
2
|
|
8
|
my $lock = shift; |
|
137
|
2
|
|
|
|
|
60
|
$lock->truncate(0); |
|
138
|
2
|
|
|
|
|
216
|
$lock->print("$$\n"); |
|
139
|
2
|
|
|
|
|
142
|
$lock->flush; |
|
140
|
2
|
|
|
|
|
14
|
*$lock->{destroy_only_in} = $$; |
|
141
|
2
|
|
|
|
|
16
|
return; |
|
142
|
|
|
|
|
|
|
} |
|
143
|
|
|
|
|
|
|
|
|
144
|
|
|
|
|
|
|
=head2 $lock->release |
|
145
|
|
|
|
|
|
|
|
|
146
|
|
|
|
|
|
|
Release lock and close the file |
|
147
|
|
|
|
|
|
|
|
|
148
|
|
|
|
|
|
|
=cut |
|
149
|
|
|
|
|
|
|
|
|
150
|
|
|
|
|
|
|
sub release { |
|
151
|
50
|
|
|
50
|
|
4172
|
my $lock = shift; |
|
152
|
50
|
100
|
|
|
|
203
|
if ( $lock->opened ) { |
|
153
|
35
|
|
|
|
|
503
|
flock $lock, LOCK_UN; |
|
154
|
35
|
|
|
|
|
678
|
close $lock; |
|
155
|
|
|
|
|
|
|
} |
|
156
|
|
|
|
|
|
|
} |
|
157
|
|
|
|
|
|
|
|
|
158
|
|
|
|
|
|
|
sub DESTROY { |
|
159
|
39
|
|
|
39
|
|
832897
|
my $lock = shift; |
|
160
|
39
|
100
|
100
|
|
|
1704
|
unless ( *$lock->{destroy_only_in} && *$lock->{destroy_only_in} != $$ ) { |
|
161
|
38
|
|
|
|
|
147
|
$lock->release; |
|
162
|
|
|
|
|
|
|
} |
|
163
|
|
|
|
|
|
|
} |
|
164
|
|
|
|
|
|
|
|
|
165
|
|
|
|
|
|
|
=head2 $lock->close |
|
166
|
|
|
|
|
|
|
|
|
167
|
|
|
|
|
|
|
Close the locked filehandle, but do not release the lock. Normally if you closed |
|
168
|
|
|
|
|
|
|
the file it will be unlocked, but if you forked after locking the file and when |
|
169
|
|
|
|
|
|
|
closed the lock in the parent process, the file will still be locked even after |
|
170
|
|
|
|
|
|
|
the lock went out of the scope in the parent process. The following example |
|
171
|
|
|
|
|
|
|
demonstrates the use for this method: |
|
172
|
|
|
|
|
|
|
|
|
173
|
|
|
|
|
|
|
{ |
|
174
|
|
|
|
|
|
|
my $lock = File::Flock::Tiny->lock("lockfile"); |
|
175
|
|
|
|
|
|
|
my $pid = fork; |
|
176
|
|
|
|
|
|
|
if( $pid == 0 ) { |
|
177
|
|
|
|
|
|
|
# We are in child process |
|
178
|
|
|
|
|
|
|
do_something(); |
|
179
|
|
|
|
|
|
|
} |
|
180
|
|
|
|
|
|
|
$lock->close; |
|
181
|
|
|
|
|
|
|
} |
|
182
|
|
|
|
|
|
|
# file still locked by child. Without $lock->close, |
|
183
|
|
|
|
|
|
|
# it would be unlocked by parent when $lock went out |
|
184
|
|
|
|
|
|
|
# of the scope |
|
185
|
|
|
|
|
|
|
|
|
186
|
|
|
|
|
|
|
Note, that this behaviour is not portable! It works on Linux and BSD, but on |
|
187
|
|
|
|
|
|
|
Solaris locks are not inherited by child processes, so the file will be |
|
188
|
|
|
|
|
|
|
unlocked as soon as the parent process will close it. See also description of |
|
189
|
|
|
|
|
|
|
L. |
|
190
|
|
|
|
|
|
|
|
|
191
|
|
|
|
|
|
|
=cut |
|
192
|
|
|
|
|
|
|
|
|
193
|
|
|
|
|
|
|
1; |
|
194
|
|
|
|
|
|
|
|
|
195
|
|
|
|
|
|
|
__END__ |