The London Perl and Raku Workshop takes place on 26th Oct 2024. If your company depends on Perl, please consider sponsoring and/or attending.

NAME

KinoSearch::Store::Lock - Abstract class representing an interprocess mutex lock.

SYNOPSIS

    my $lock = $lock_factory->make_lock(
        name    => 'write',
        timeout => 5000,
    );
    $lock->obtain or die "can't get lock for " . $lock->get_name;
    do_stuff();
    $lock->release;

DESCRIPTION

Abstract class representing an interprocess mutex lock.

The Lock class produces an interprocess mutex lock. The default subclass uses dot-lock files, but alternative implementations are possible.

Each lock must have a name which is unique per resource to be locked. Each lock also has an "hostname" which should be unique per machine; it is used to help clear away stale locks.

CONSTRUCTORS

new( [labeled params] )

    my $lock = KinoSearch::Store::Lock->new(
        name     => 'commit',     # required
        folder   => $folder,      # required
        hostname => $hostname,    # required
        timeout  => 5000,         # default: 0
        interval => 1000,         # default: 100
    );

Abstract constructor.

  • folder - A Folder.

  • name - File-system-friendly string identifying the resource to be locked.

  • hostname - A unique per-machine identifier.

  • timeout - Time in milliseconds to keep retrying before abandoning the attempt to obtain() a lock.

  • interval - Time in milliseconds between retries.

METHODS

obtain()

Call request() once per interval until request() returns success or the timeout has been reached.

Returns: true on success, false otherwise.

ABSTRACT METHODS

request()

Make one attempt to acquire the lock.

The semantics of request() differ depending on whether shared() returns true. If the Lock is shared(), then request() should not fail if another lock is held against the resource identified by name (though it might fail for other reasons). If it is not shared() -- i.e. it's an exclusive (write) lock -- then other locks should cause request() to fail.

Returns: true on success, false on failure.

release()

Release the lock.

is_locked()

Indicate whether the resource identified by this lock's name is currently locked.

Returns: true if the resource is locked, false otherwise.

clear_stale()

Release all locks that meet the following three conditions: the lock name matches, the hostname matches, and the process id that the lock was created under no longer identifies an active process.

INHERITANCE

KinoSearch::Store::Lock isa KinoSearch::Obj.

COPYRIGHT AND LICENSE

Copyright 2005-2009 Marvin Humphrey

This program is free software; you can redistribute it and/or modify it under the same terms as Perl itself.