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
|
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
use strict;
use warnings;
use Test::More tests => 14;
use Lucy::Test;
my $folder = Lucy::Store::RAMFolder->new;
my $lock = Lucy::Store::SharedLock->new(
folder => $folder,
name => 'ness',
timeout => 0,
host => 'nessie',
);
ok( !$lock->is_locked, "not locked yet" );
ok( $lock->obtain, "obtain" );
ok( $lock->is_locked, "is_locked" );
ok( $folder->exists('locks/ness-1.lock'), "lockfile exists" );
my $another_lock = Lucy::Store::SharedLock->new(
folder => $folder,
name => 'ness',
timeout => 0,
host => 'nessie',
);
ok( $another_lock->obtain, "got a second lock on the same resource" );
$lock->release;
ok( $lock->is_locked,
"first lock released but still is_locked because of other lock" );
my $ya_lock = Lucy::Store::SharedLock->new(
folder => $folder,
name => 'ness',
timeout => 0,
host => 'nessie',
);
ok( $ya_lock->obtain, "got yet another lock" );
ok( $lock->obtain, "got first lock again" );
is( $lock->get_lock_path, "locks/ness-3.lock",
"first lock uses a different lock_path now" );
# Rewrite lock file to spec a different pid.
my $content = $folder->slurp_file("locks/ness-3.lock");
$content =~ s/$$/123456789/;
$folder->delete('locks/ness-3.lock') or die "Can't delete 'ness-3.lock'";
my $outstream = $folder->open_out('locks/ness-3.lock')
or die Lucy->error;
$outstream->print($content);
$outstream->close;
$lock->release;
$another_lock->release;
$ya_lock->release;
ok( $lock->is_locked, "failed to release a lock with a different pid" );
$lock->clear_stale;
ok( !$lock->is_locked, "clear_stale" );
ok( $lock->obtain, "got lock again" );
ok( $lock->is_locked, "it's locked" );
# Rewrite lock file to spec a different host.
$content = $folder->slurp_file("locks/ness-1.lock");
$content =~ s/nessie/sting/;
$folder->delete('locks/ness-1.lock') or die "Can't delete 'ness-1.lock'";
$outstream = $folder->open_out('locks/ness-1.lock') or die Lucy->error;
$outstream->print($content);
$outstream->close;
$lock->release;
ok( $lock->is_locked, "don't delete lock belonging to another host" );
|
