04 Jul 2009 01:44:17 UTC
- Development release
- Distribution: KinoSearch
- Source (raw)
- Browse (raw)
- How to Contribute
- Issues (5)
- Testers (13 / 3 / 1)
- KwaliteeBus factor: 0
- License: perl_5
- Activity24 month
- Download (611.03KB)
- MetaCPAN Explorer
- Subscribe to distribution
- This version
- Latest versionCREAMYG Marvin Humphreyand 1 contributors
- Marvin Humphrey <marvin at rectangular dot com>
- LICENSE, DISCLAIMER, BUGS, etc.
KinoSearch::Store::Lock - Interprocess mutex lock.
my $lock = $lock_factory->make_lock( lock_name => 'commit', timeout => 5000, ); $lock->obtain or die "can't get lock on " . $lock->get_filename; do_stuff(); $lock->release;
The Lock class produces an interprocess mutex lock. It does not rely on flock, but creates a lock "file". What exactly constitutes that "file" depends on the Folder implementation.
Each lock must have a name which is unique per resource to be locked. The filename for the lockfile will be derived from it, e.g. "write" will produce a file "write.lock".
Each lock also has an "agent id", a string which should be unique per-host; it is used to help clear away stale lockfiles.
my $lock = KinoSearch::Store::Lock->new( lock_name => 'commit', # required timeout => 5000, # default: 0 folder => $folder, # required agent_id => $hostname, # required );
folder - The KinoSearch::Store::Folder where the lock file will reside.
lock_name - String identifying the resource to be locked.
agent_id - A per-machine identifier, usually the host name.
timeout - Time in milliseconds to keep retrying before abandoning the attempt to obtain() a lock.
Attempt to aquire lock once per second until the timeout has been reached.
Returns: true on success, false otherwise.
Release the lock.
Indicate whether the resource identified by this lock's name is currently locked.
Returns: true if the resource is locked, false otherwise.
Release all locks that meet the following three conditions: the lock name matches, the agent id matches, and the process id that the lock was created under no longer identifies an active process.
KinoSearch::Store::Lock isa KinoSearch::Obj.
Copyright 2005-2009 Marvin Humphrey
See KinoSearch version 0.30.