org.apache.accumulo.server.zookeeper
Class ZooQueueLock

java.lang.Object
  extended by org.apache.accumulo.server.zookeeper.ZooQueueLock
All Implemented Interfaces:
DistributedReadWriteLock.QueueLock

public class ZooQueueLock
extends Object
implements DistributedReadWriteLock.QueueLock


Constructor Summary
ZooQueueLock(String path, boolean ephemeral)
           
 
Method Summary
 long addEntry(byte[] data)
           
 SortedMap<Long,byte[]> getEarlierEntries(long entry)
           
static void main(String[] args)
           
 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 path,
                    boolean ephemeral)
             throws org.apache.zookeeper.KeeperException,
                    InterruptedException
Throws:
org.apache.zookeeper.KeeperException
InterruptedException
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

main

public static void main(String[] args)
                 throws InterruptedException,
                        org.apache.zookeeper.KeeperException
Throws:
InterruptedException
org.apache.zookeeper.KeeperException


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.