com.bigdata.relation.accesspath

Class TestBlockingBuffer

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.relation.accesspath.TestBlockingBuffer

All Implemented Interfaces:

junit.framework.Test

public class TestBlockingBuffer
extends TestCase2

Test suite for BlockingBuffer and its IAsynchronousIterator.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from class junit.framework.TestCase2

TestCase2.MyProperties, TestCase2.RandomType

Field Summary

Fields inherited from class junit.framework.TestCase2

_randomType, log

Constructor Summary

Constructors

Constructor and Description
TestBlockingBuffer()
TestBlockingBuffer(String arg0)

Method Summary

Methods

Modifier and Type	Method and Description
void	_testStress_blockingBuffer_close() Stress test version of test_blockingBuffer_close().
protected void	tearDown()
void	test_blockingBuffer_close_noConsumer_closedThroughIterator() Test that a thread blocked on add() will be unblocked by BlockingBuffer.close().
void	test_blockingBuffer_close_noConsumer() Test that a thread blocked on add() will be unblocked by BlockingBuffer.close().
void	test_blockingBuffer_close() Test that threads blocked on add() will be unblocked by BlockingBuffer.close().
void	test_blockingBuffer() Basic test of the ability to add to a buffer with a fixed capacity queue and to drain the elements from the queue including tests of the non-blocking aspects of the API.

Methods inherited from class junit.framework.TestCase2

assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEqualsWithinUlps, assertSameArray, assertSameArray, assertSameBigDecimal, assertSameBigDecimal, assertSameBigInteger, assertSameBigInteger, assertSameIterator, assertSameIterator, assertSameIteratorAnyOrder, assertSameIteratorAnyOrder, assertSameValue, assertSameValue, assertZeroUlps, assertZeroUlps, fail, getInnerCause, getNormalInt, getProjectBuildPath, getProperties, getRandomObject, getRandomObject, getRandomOrder, getRandomString, getTestInputStream, getTestResource, getTestResource, getUlps, getUlps, isDEBUG, isDEBUG, isINFO, isINFO, isInnerCause, logProperties

Methods inherited from class junit.framework.TestCase

assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertTrue, assertTrue, countTestCases, createResult, fail, fail, failNotEquals, failNotSame, failSame, format, getName, run, run, runBare, runTest, setName, setUp, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

TestBlockingBuffer

public TestBlockingBuffer()

TestBlockingBuffer

public TestBlockingBuffer(String arg0)

Parameters:

arg0 -

Method Detail

tearDown

protected void tearDown()
                 throws Exception

Overrides:

tearDown in class junit.framework.TestCase

Throws:

Exception

test_blockingBuffer

public void test_blockingBuffer()
                         throws InterruptedException,
                                ExecutionException,
                                TimeoutException

Basic test of the ability to add to a buffer with a fixed capacity queue and to drain the elements from the queue including tests of the non-blocking aspects of the API.

Throws:

TimeoutException

ExecutionException

InterruptedException

test_blockingBuffer_close_noConsumer

public void test_blockingBuffer_close_noConsumer()
                                          throws Exception

Test that a thread blocked on add() will be unblocked by BlockingBuffer.close(). For this test, there is no consumer and there is a single producer. We just fill up the buffer and when it is full, we verify that the producer is blocked. We then use BlockingBuffer.close() to close the buffer and verify that the producer was woken up.

Throws:

Exception

See Also:

BlockingBuffer.close() does not unblock threads

test_blockingBuffer_close_noConsumer_closedThroughIterator

public void test_blockingBuffer_close_noConsumer_closedThroughIterator()
                                                                throws Exception

Test that a thread blocked on add() will be unblocked by BlockingBuffer.close(). For this test, there is no consumer and there is a single producer. We just fill up the buffer and when it is full, we verify that the producer is blocked. We then use the object returned by BlockingBuffer.iterator() to IAsynchronousIterator.close() to close the buffer and verify that the producer was woken up.

Throws:

Exception

See Also:

BlockingBuffer.close() does not unblock threads

test_blockingBuffer_close

public void test_blockingBuffer_close()
                               throws InterruptedException,
                                      ExecutionException,
                                      TimeoutException

Test that threads blocked on add() will be unblocked by BlockingBuffer.close(). A pool of producer threads run. A (smaller) pool of (slower) consumer thread(s) also runs. The BlockingBuffer is closed once the producer threads begin to block. We then verify that all producer threads are appropriately notified of the asynchronous cancellation of their request.

Throws:

InterruptedException

ExecutionException

TimeoutException

See Also:

BlockingBuffer.close() does not unblock threads

_testStress_blockingBuffer_close

public void _testStress_blockingBuffer_close()
                                      throws InterruptedException,
                                             ExecutionException,
                                             TimeoutException

Stress test version of test_blockingBuffer_close().

Throws:

InterruptedException

ExecutionException

TimeoutException