Package org.apache.hadoop.hbase.client

Class TestAsyncClientPauseForServerOverloaded.OverloadedQueue

java.lang.Object

org.apache.hadoop.hbase.ipc.PluggableBlockingQueue

org.apache.hadoop.hbase.ipc.TestPluggableQueueImpl

org.apache.hadoop.hbase.client.TestAsyncClientPauseForServerOverloaded.OverloadedQueue

All Implemented Interfaces:

Iterable<org.apache.hadoop.hbase.ipc.CallRunner>, Collection<org.apache.hadoop.hbase.ipc.CallRunner>, BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner>, Queue<org.apache.hadoop.hbase.ipc.CallRunner>, org.apache.hadoop.hbase.conf.ConfigurationObserver

Enclosing class:

TestAsyncClientPauseForServerOverloaded

public static final class TestAsyncClientPauseForServerOverloaded.OverloadedQueue
extends TestPluggableQueueImpl

Field Summary

Fields inherited from class org.apache.hadoop.hbase.ipc.PluggableBlockingQueue

conf, maxQueueLength, priority

Constructor Summary

Constructors

Constructor	Description
OverloadedQueue(int maxQueueLength, org.apache.hadoop.hbase.ipc.PriorityFunction priority, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
boolean	offer(org.apache.hadoop.hbase.ipc.CallRunner callRunner)

Methods inherited from class org.apache.hadoop.hbase.ipc.TestPluggableQueueImpl

add, addAll, clear, contains, containsAll, drainTo, drainTo, element, hasObservedARecentConfigurationChange, isEmpty, iterator, offer, onConfigurationChange, peek, poll, poll, put, remainingCapacity, remove, remove, removeAll, retainAll, size, take, toArray, toArray

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream, toArray

Methods inherited from interface java.lang.Iterable

forEach

Constructor Details

OverloadedQueue

public OverloadedQueue(int maxQueueLength,
 org.apache.hadoop.hbase.ipc.PriorityFunction priority,
 org.apache.hadoop.conf.Configuration conf)

Method Details

offer

public boolean offer(org.apache.hadoop.hbase.ipc.CallRunner callRunner)

Specified by:

offer in interface BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner>

Specified by:

offer in interface Queue<org.apache.hadoop.hbase.ipc.CallRunner>

Overrides:

offer in class TestPluggableQueueImpl