net.sf.hajdbc.distributable

Class DistributableLockManager

java.lang.Object

net.sf.hajdbc.distributable.AbstractMembershipListener

net.sf.hajdbc.distributable.DistributableLockManager

All Implemented Interfaces:

Lifecycle, LockManager, org.jgroups.MembershipListener, org.jgroups.MessageListener

public class DistributableLockManager
extends AbstractMembershipListener
implements LockManager, org.jgroups.MessageListener

LockManager implementation that leverages a JGroups 2-phase voting adapter for obtain remote write locks.

Author:

Paul Ferraro

Field Summary

Fields

Modifier and Type	Field and Description
protected org.jgroups.blocks.RpcDispatcher	dispatcher
protected int	timeout

Fields inherited from class net.sf.hajdbc.distributable.AbstractMembershipListener

channel

Fields inherited from interface net.sf.hajdbc.LockManager

GLOBAL

Constructor Summary

Constructors

Constructor and Description
DistributableLockManager(DatabaseCluster<D> databaseCluster, DistributableDatabaseClusterDecorator decorator) Constructs a new DistributableLock.

Method Summary

Modifier and Type	Method and Description
byte[]	getState()
protected void	memberJoined(org.jgroups.Address address)
protected void	memberLeft(org.jgroups.Address address)
java.util.concurrent.locks.Lock	readLock(java.lang.String object) Read locks are local.
void	receive(org.jgroups.Message message)
void	setState(byte[] arg0)
void	start() Called upon database cluster start.
void	stop() Called when database cluster is stopped.
boolean	vote(LockDecree decree) Votes on the specified decree.
java.util.concurrent.locks.Lock	writeLock(java.lang.String object) Write locks are distributed.

Methods inherited from class net.sf.hajdbc.distributable.AbstractMembershipListener

block, getMembershipSize, isMembershipEmpty, suspect, viewAccepted

Methods inherited from class java.lang.Object

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

Field Detail

dispatcher

protected org.jgroups.blocks.RpcDispatcher dispatcher

timeout

protected int timeout

Constructor Detail

DistributableLockManager

public DistributableLockManager(DatabaseCluster<D> databaseCluster,
                                DistributableDatabaseClusterDecorator decorator)
                         throws java.lang.Exception

Constructs a new DistributableLock.

Type Parameters:

D - either java.sql.Driver or javax.sql.Datasource

Parameters:

databaseCluster - a database cluster

decorator - a decorator

Throws:

java.lang.Exception

Method Detail

start

public void start()
           throws java.lang.Exception

Description copied from interface: Lifecycle

Called upon database cluster start.

Specified by:

start in interface Lifecycle

Throws:

java.lang.Exception - if this service fails to start.

See Also:

Lifecycle.start()

stop

public void stop()

Description copied from interface: Lifecycle

Called when database cluster is stopped.

Specified by:

stop in interface Lifecycle

See Also:

Lifecycle.stop()

readLock

public java.util.concurrent.locks.Lock readLock(java.lang.String object)

Read locks are local.

Specified by:

readLock in interface LockManager

Parameters:

object - an object to lock

Returns:

a read lock

See Also:

LockManager.readLock(java.lang.String)

writeLock

public java.util.concurrent.locks.Lock writeLock(java.lang.String object)

Write locks are distributed.

Specified by:

writeLock in interface LockManager

Parameters:

object - an object to lock

Returns:

a write lock

See Also:

LockManager.writeLock(java.lang.String)

vote

public boolean vote(LockDecree decree)

Votes on the specified decree.

Parameters:

decree - a lock decree

Returns:

true, if success, false if failure

memberJoined

protected void memberJoined(org.jgroups.Address address)

Specified by:

memberJoined in class AbstractMembershipListener

See Also:

AbstractMembershipListener.memberJoined(org.jgroups.Address)

memberLeft

protected void memberLeft(org.jgroups.Address address)

Specified by:

memberLeft in class AbstractMembershipListener

See Also:

AbstractMembershipListener.memberLeft(org.jgroups.Address)

getState

public byte[] getState()

Specified by:

getState in interface org.jgroups.MessageListener

See Also:

MessageListener.getState()

receive

public void receive(org.jgroups.Message message)

Specified by:

receive in interface org.jgroups.MessageListener

See Also:

MessageListener.receive(org.jgroups.Message)

setState

public void setState(byte[] arg0)

Specified by:

setState in interface org.jgroups.MessageListener

See Also:

MessageListener.setState(byte[])