org.apache.hadoop.hbase.client

Class TestAsyncProcess

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncProcess

public class TestAsyncProcess
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
Timeout	timeout

Constructor Summary

Constructors

Constructor and Description
TestAsyncProcess()

Method Summary

Modifier and Type	Method and Description
static void	beforeClass()
void	testBatch()
void	testCallQueueTooLarge()
void	testErrorsServers()
void	testFail()
void	testFailAndSuccess()
void	testFlush()
void	testGlobalErrors()
void	testHTableFailedPutAndNewPut()
void	testHTableFailedPutWithBuffer()
void	testHTableFailedPutWithoutBuffer()
void	testHTablePutSuccess()
void	testMaxTask()
void	testReplicaAllCallsFailForOneRegion()
void	testReplicaMainFailsBeforeReplicaCalls()
void	testReplicaParallelCallsSucceed()
void	testReplicaPartialReplicaCall()
void	testReplicaPrimarySuccessWoReplicaCalls()
void	testReplicaReplicaSuccess()
void	testReplicaReplicaSuccessWithParallelFailures()
void	testSubmit()
void	testSubmitBusyRegion()
void	testSubmitBusyRegionServer()
void	testSubmitTrue()
void	testSubmitWithCB()
void	testThreadCreation() This test simulates multiple regions on 2 servers.
void	testWaitForMaximumCurrentTasks()

Methods inherited from class java.lang.Object

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

Field Detail

timeout

public Timeout timeout

Constructor Detail

TestAsyncProcess

public TestAsyncProcess()

Method Detail

beforeClass

public static void beforeClass()

testSubmit

public void testSubmit()
                throws Exception

Throws:

Exception

testSubmitWithCB

public void testSubmitWithCB()
                      throws Exception

Throws:

Exception

testSubmitBusyRegion

public void testSubmitBusyRegion()
                          throws Exception

Throws:

Exception

testSubmitBusyRegionServer

public void testSubmitBusyRegionServer()
                                throws Exception

Throws:

Exception

testFail

public void testFail()
              throws Exception

Throws:

Exception

testSubmitTrue

public void testSubmitTrue()
                    throws IOException

Throws:

IOException

testFailAndSuccess

public void testFailAndSuccess()
                        throws Exception

Throws:

Exception

testFlush

public void testFlush()
               throws Exception

Throws:

Exception

testMaxTask

public void testMaxTask()
                 throws Exception

Throws:

Exception

testHTablePutSuccess

public void testHTablePutSuccess()
                          throws Exception

Throws:

Exception

testHTableFailedPutWithBuffer

public void testHTableFailedPutWithBuffer()
                                   throws Exception

Throws:

Exception

testHTableFailedPutWithoutBuffer

public void testHTableFailedPutWithoutBuffer()
                                      throws Exception

Throws:

Exception

testHTableFailedPutAndNewPut

public void testHTableFailedPutAndNewPut()
                                  throws Exception

Throws:

Exception

testBatch

public void testBatch()
               throws IOException,
                      InterruptedException

Throws:

IOException

InterruptedException

testErrorsServers

public void testErrorsServers()
                       throws IOException

Throws:

IOException

testGlobalErrors

public void testGlobalErrors()
                      throws IOException

Throws:

IOException

testCallQueueTooLarge

public void testCallQueueTooLarge()
                           throws IOException

Throws:

IOException

testThreadCreation

public void testThreadCreation()
                        throws Exception

This test simulates multiple regions on 2 servers. We should have 2 multi requests and 2 threads: 1 per server, this whatever the number of regions.

Throws:

Exception

testReplicaReplicaSuccess

public void testReplicaReplicaSuccess()
                               throws Exception

Throws:

Exception

testReplicaPrimarySuccessWoReplicaCalls

public void testReplicaPrimarySuccessWoReplicaCalls()
                                             throws Exception

Throws:

Exception

testReplicaParallelCallsSucceed

public void testReplicaParallelCallsSucceed()
                                     throws Exception

Throws:

Exception

testReplicaPartialReplicaCall

public void testReplicaPartialReplicaCall()
                                   throws Exception

Throws:

Exception

testReplicaMainFailsBeforeReplicaCalls

public void testReplicaMainFailsBeforeReplicaCalls()
                                            throws Exception

Throws:

Exception

testReplicaReplicaSuccessWithParallelFailures

public void testReplicaReplicaSuccessWithParallelFailures()
                                                   throws Exception

Throws:

Exception

testReplicaAllCallsFailForOneRegion

public void testReplicaAllCallsFailForOneRegion()
                                         throws Exception

Throws:

Exception

testWaitForMaximumCurrentTasks

public void testWaitForMaximumCurrentTasks()
                                    throws Exception

Throws:

Exception