1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.commons.pipeline.driver;
19
20 import java.util.concurrent.LinkedBlockingQueue;
21
22 import junit.framework.Test;
23 import junit.framework.TestSuite;
24
25 import org.apache.commons.logging.Log;
26 import org.apache.commons.logging.LogFactory;
27 import org.apache.commons.pipeline.Feeder;
28 import org.apache.commons.pipeline.StageDriver.State;
29
30
31
32
33
34 public class DedicatedThreadStageDriverTest extends AbstractStageDriverTest {
35 private Log log;
36
37 public DedicatedThreadStageDriverTest(String testName) {
38 super(testName);
39 this.log = LogFactory.getLog(DedicatedThreadStageDriverTest.class);
40 }
41
42 public static Test suite() {
43 TestSuite suite = new TestSuite(DedicatedThreadStageDriverTest.class);
44
45 return suite;
46 }
47
48
49
50 public void testGetFeeder() {
51 log.debug("testGetFeeder ---------------------------------------------");
52 DedicatedThreadStageDriver instance = new DedicatedThreadStageDriver(stage, context, new LinkedBlockingQueue<Object>(), 500, FaultTolerance.NONE);
53
54 Feeder feeder = instance.getFeeder();
55 assertNotNull(feeder);
56 }
57
58
59
60
61
62
63
64 public void testStartFinish() throws Exception {
65 log.debug("testStartFinish -------------------------------------------");
66 DedicatedThreadStageDriver instance = new DedicatedThreadStageDriver(stage, context, new LinkedBlockingQueue<Object>(), 500, FaultTolerance.NONE);
67
68 assertEquals(State.STOPPED, instance.getState());
69
70 instance.start();
71
72 assertTrue(instance.getState() == State.STARTED || instance.getState() == State.RUNNING);
73
74 instance.finish();
75
76 assertEquals(State.STOPPED, instance.getState());
77 }
78
79
80
81
82
83
84 public void testSingleStage() throws Exception {
85 log.debug("testSingleStage -------------------------------------------");
86 StageDriverTestUtils.testSingleStage(this, new DedicatedThreadStageDriverFactory());
87 }
88
89 public void testMultiStage() throws Exception {
90 log.debug("testMultiStage --------------------------------------------");
91 StageDriverTestUtils.testMultiStage(this, new DedicatedThreadStageDriverFactory());
92 }
93
94 public void testMultiFaultingStage() throws Exception {
95 log.debug("testMultiFaultingStage ------------------------------------");
96 DedicatedThreadStageDriverFactory factory = new DedicatedThreadStageDriverFactory();
97 factory.setFaultTolerance(FaultTolerance.CHECKED);
98
99 StageDriverTestUtils.testMultiFaultingStage(this, factory);
100 }
101 }