Package org.apache.accumulo.fate.zookeeper

Class DistributedReadWriteLock

java.lang.Object

org.apache.accumulo.fate.zookeeper.DistributedReadWriteLock

All Implemented Interfaces:

ReadWriteLock

public class DistributedReadWriteLock
extends Object
implements ReadWriteLock

A ReadWriteLock that can be implemented in ZooKeeper. Features the ability to store data with the lock, and recover the lock using that data to find the lock.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	DistributedReadWriteLock.QueueLock

Constructor Summary

Constructors

Constructor	Description
DistributedReadWriteLock(DistributedReadWriteLock.QueueLock qlock, byte[] data)

Method Summary

Modifier and Type	Method	Description
Lock	readLock()
static Lock	recoverLock(DistributedReadWriteLock.QueueLock qlock, byte[] data)
Lock	writeLock()

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedReadWriteLock

public DistributedReadWriteLock(DistributedReadWriteLock.QueueLock qlock,
                                byte[] data)

Method Detail

recoverLock

public static Lock recoverLock(DistributedReadWriteLock.QueueLock qlock,
                               byte[] data)

readLock

public Lock readLock()

Specified by:

readLock in interface ReadWriteLock

writeLock

public Lock writeLock()

Specified by:

writeLock in interface ReadWriteLock