org.apache.accumulo.fate.zookeeper
Class ZooQueueLock

java.lang.Object
  extended by org.apache.accumulo.fate.zookeeper.ZooQueueLock
All Implemented Interfaces:
DistributedReadWriteLock.QueueLock
Direct Known Subclasses:
ZooQueueLock

public class ZooQueueLock
extends Object
implements DistributedReadWriteLock.QueueLock


Constructor Summary
protected ZooQueueLock(IZooReaderWriter zrw, String path, boolean ephemeral)
           
  ZooQueueLock(String zookeepers, int timeInMillis, String scheme, byte[] auth, String path, boolean ephemeral)
           
 
Method Summary
 long addEntry(byte[] data)
           
 SortedMap<Long,byte[]> getEarlierEntries(long entry)
           
 void removeEntry(long entry)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ZooQueueLock

public ZooQueueLock(String zookeepers,
                    int timeInMillis,
                    String scheme,
                    byte[] auth,
                    String path,
                    boolean ephemeral)
             throws org.apache.zookeeper.KeeperException,
                    InterruptedException
Throws:
org.apache.zookeeper.KeeperException
InterruptedException

ZooQueueLock

protected ZooQueueLock(IZooReaderWriter zrw,
                       String path,
                       boolean ephemeral)
Method Detail

addEntry

public long addEntry(byte[] data)
Specified by:
addEntry in interface DistributedReadWriteLock.QueueLock

getEarlierEntries

public SortedMap<Long,byte[]> getEarlierEntries(long entry)
Specified by:
getEarlierEntries in interface DistributedReadWriteLock.QueueLock

removeEntry

public void removeEntry(long entry)
Specified by:
removeEntry in interface DistributedReadWriteLock.QueueLock


Copyright © 2013 Apache Accumulo Project. All Rights Reserved.