Package org.apache.hadoop.hbase.regionserver

Class TestRegionServerRejectDuringAbort.CallQueueTooBigThrowingQueue

java.lang.Object

org.apache.hadoop.hbase.ipc.PluggableBlockingQueue

org.apache.hadoop.hbase.ipc.TestPluggableQueueImpl

org.apache.hadoop.hbase.regionserver.TestRegionServerRejectDuringAbort.CallQueueTooBigThrowingQueue

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:

TestRegionServerRejectDuringAbort

public static final class TestRegionServerRejectDuringAbort.CallQueueTooBigThrowingQueue
extends TestPluggableQueueImpl

Field Summary

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

conf, maxQueueLength, priority

Constructor Summary

Constructors

Constructor	Description
CallQueueTooBigThrowingQueue(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

Methods inherited from interface java.lang.Iterable

forEach

Constructor Details

CallQueueTooBigThrowingQueue

public CallQueueTooBigThrowingQueue(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