net.sf.hajdbc.lock.distributed

Class DistributedLockManager

java.lang.Object

net.sf.hajdbc.lock.distributed.DistributedLockManager

All Implemented Interfaces:

MembershipListener, Stateful, Lifecycle, LockCommandContext, LockManager

public class DistributedLockManager
extends Object
implements LockManager, LockCommandContext, Stateful, MembershipListener

Author:

Paul Ferraro

Constructor Summary

Constructors

Constructor and Description
DistributedLockManager(DatabaseCluster<Z,D> cluster, CommandDispatcherFactory dispatcherFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	added(Member member) Indicates that the specified member was added to the group.
Lock	getDistibutedLock(RemoteLockDescriptor descriptor)
Lock	getLock(LockDescriptor lock)
Map<LockDescriptor,Lock>	getRemoteLocks(Remote remote)
Lock	readLock(String id) Obtains a named read lock.
void	readState(ObjectInput input) Returns the state of this object.
void	removed(Member member) Indicates the the specified member was removed from the group.
void	start() Called upon database cluster start.
void	stop() Called when database cluster is stopped.
Lock	writeLock(String id) Obtains a named write lock.
void	writeState(ObjectOutput output) Sets the state of this object.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DistributedLockManager

public DistributedLockManager(DatabaseCluster<Z,D> cluster,
                      CommandDispatcherFactory dispatcherFactory)
                       throws Exception

Throws:

Exception

Method Detail

readLock

public Lock readLock(String id)

Obtains a named read lock.

Specified by:

readLock in interface LockManager

Parameters:

id - an object to lock

Returns:

a read lock

See Also:

LockManager.readLock(java.lang.String)

writeLock

public Lock writeLock(String id)

Obtains a named write lock.

Specified by:

writeLock in interface LockManager

Parameters:

id - an object to lock

Returns:

a write lock

See Also:

LockManager.writeLock(java.lang.String)

getLock

public Lock getLock(LockDescriptor lock)

Specified by:

getLock in interface LockCommandContext

See Also:

LockCommandContext.getLock(net.sf.hajdbc.lock.distributed.LockDescriptor)

getDistibutedLock

public Lock getDistibutedLock(RemoteLockDescriptor descriptor)

Specified by:

getDistibutedLock in interface LockCommandContext

See Also:

LockCommandContext.getDistibutedLock(net.sf.hajdbc.lock.distributed.RemoteLockDescriptor)

start

public void start()
           throws Exception

Called upon database cluster start.

Specified by:

start in interface Lifecycle

Throws:

Exception - if this service fails to start.

See Also:

Lifecycle.start()

stop

public void stop()

Called when database cluster is stopped.

Specified by:

stop in interface Lifecycle

See Also:

Lifecycle.stop()

getRemoteLocks

public Map<LockDescriptor,Lock> getRemoteLocks(Remote remote)

Specified by:

getRemoteLocks in interface LockCommandContext

See Also:

LockCommandContext.getRemoteLocks(net.sf.hajdbc.distributed.Remote)

writeState

public void writeState(ObjectOutput output)
                throws IOException

Sets the state of this object.

Specified by:

writeState in interface Stateful

Throws:

IOException

See Also:

Stateful.writeState(java.io.ObjectOutput)

readState

public void readState(ObjectInput input)
               throws IOException

Returns the state of this object.

Specified by:

readState in interface Stateful

Throws:

IOException

See Also:

Stateful.readState(java.io.ObjectInput)

added

public void added(Member member)

Indicates that the specified member was added to the group.

Specified by:

added in interface MembershipListener

Parameters:

member - the added member

See Also:

MembershipListener.added(net.sf.hajdbc.distributed.Member)

removed

public void removed(Member member)

Indicates the the specified member was removed from the group.

Specified by:

removed in interface MembershipListener

Parameters:

member - the removed member

See Also:

MembershipListener.removed(net.sf.hajdbc.distributed.Member)