com.bigdata.service.ndx.pipeline

Class TestMasterTaskIdleTimeout

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.service.ndx.pipeline.AbstractMasterTestCase

com.bigdata.service.ndx.pipeline.TestMasterTaskIdleTimeout

All Implemented Interfaces:

junit.framework.Test

public class TestMasterTaskIdleTimeout
extends AbstractMasterTestCase

Unit tests of the idle timeout behavior for AbstractMasterTask and friends.

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
TestMasterTaskIdleTimeout()
TestMasterTaskIdleTimeout(String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	test_idleTimeout_LT_chunkTimeout() Unit test verifies that an idle timeout may be LT the chunk timeout and that the sink will be closed by the idle timeout if chunks do not appear in a timely manner.
void	test_idleTimeout_LT_chunkTimeout2() Unit test verifies that a sink whose source iterator is not empty always resets the idle timeout (that is, if chunks continue to appear in a timely manner than the sink will not be closed by an idle timeout).
void	test_idleTimeout_with_infiniteChunkTimeout() Unit test verifies that an idle timeout will cause a sink to flush its buffer without waiting to combine additional chunks even though it has an infinite chunkTimeout.
void	test_idleTimeout() Unit test to verify that output buffers are not closed too quickly.
void	test_idleTimeoutInfinite_chunkTimeoutInfinite() Unit test verifies correct shutdown when writing chunks onto a master whose subtask has an infinite chunk timeout and an infinite idle timeout.

Methods inherited from class com.bigdata.service.ndx.pipeline.AbstractMasterTestCase

awaitChunksOut, tearDown

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

TestMasterTaskIdleTimeout

public TestMasterTaskIdleTimeout()

TestMasterTaskIdleTimeout

public TestMasterTaskIdleTimeout(String name)

Method Detail

test_idleTimeout

public void test_idleTimeout()
                      throws InterruptedException,
                             ExecutionException

Unit test to verify that output buffers are not closed too quickly. This also verifies that a buffer automatically re-opened if it was closed by a timeout.

Throws:

InterruptedException

ExecutionException

test_idleTimeout_LT_chunkTimeout

public void test_idleTimeout_LT_chunkTimeout()
                                      throws InterruptedException,
                                             ExecutionException

Unit test verifies that an idle timeout may be LT the chunk timeout and that the sink will be closed by the idle timeout if chunks do not appear in a timely manner.

Throws:

InterruptedException

ExecutionException

test_idleTimeout_LT_chunkTimeout2

public void test_idleTimeout_LT_chunkTimeout2()
                                       throws InterruptedException,
                                              ExecutionException

Unit test verifies that a sink whose source iterator is not empty always resets the idle timeout (that is, if chunks continue to appear in a timely manner than the sink will not be closed by an idle timeout).

Throws:

InterruptedException

ExecutionException

test_idleTimeoutInfinite_chunkTimeoutInfinite

public void test_idleTimeoutInfinite_chunkTimeoutInfinite()
                                                   throws InterruptedException,
                                                          ExecutionException

Unit test verifies correct shutdown when writing chunks onto a master whose subtask has an infinite chunk timeout and an infinite idle timeout. In this situation the subtask must notice that the master's input buffer has been closed and close its input buffer so that it will process any elements remaining in that buffer and then terminate.

Throws:

InterruptedException

ExecutionException

test_idleTimeout_with_infiniteChunkTimeout

public void test_idleTimeout_with_infiniteChunkTimeout()
                                                throws InterruptedException,
                                                       ExecutionException,
                                                       TimeoutException

Unit test verifies that an idle timeout will cause a sink to flush its buffer without waiting to combine additional chunks even though it has an infinite chunkTimeout.

Throws:

InterruptedException

ExecutionException

TimeoutException