Skip to content
Snippets Groups Projects
Commit e4f9ac10 authored by Christian Wulf's avatar Christian Wulf
Browse files

Merge branch 'checkstyle-solved' into 'master'

Checkstyle solved

Solved a whole bunch of issues regarding checkstyle. For e.g. renamed interfaces to match I[A-Z0-9].* and abstract classes to match Abstract[A-Z0-9].*

See merge request !16
parents 6ff65096 bec9f5bc
No related branches found
No related tags found
No related merge requests found
Showing
with 80 additions and 72 deletions
package teetime.framework; package teetime.framework;
public abstract class ConsumerStage<I> extends AbstractStage { public abstract class AbstractConsumerStage<I> extends AbstractStage {
protected final InputPort<I> inputPort = this.createInputPort(); protected final InputPort<I> inputPort = this.createInputPort();
...@@ -10,7 +10,7 @@ public abstract class ConsumerStage<I> extends AbstractStage { ...@@ -10,7 +10,7 @@ public abstract class ConsumerStage<I> extends AbstractStage {
@Override @Override
public void executeWithPorts() { public void executeWithPorts() {
I element = this.getInputPort().receive(); final I element = this.getInputPort().receive();
this.execute(element); this.execute(element);
} }
......
...@@ -9,7 +9,7 @@ package teetime.framework; ...@@ -9,7 +9,7 @@ package teetime.framework;
* the type of the default output port * the type of the default output port
* *
*/ */
public abstract class ProducerStage<O> extends AbstractStage implements Stage { public abstract class AbstractProducerStage<O> extends AbstractStage implements IStage {
protected final OutputPort<O> outputPort = this.createOutputPort(); protected final OutputPort<O> outputPort = this.createOutputPort();
......
...@@ -14,7 +14,7 @@ import teetime.framework.pipe.IPipe; ...@@ -14,7 +14,7 @@ import teetime.framework.pipe.IPipe;
import teetime.framework.signal.ISignal; import teetime.framework.signal.ISignal;
import teetime.framework.validation.InvalidPortConnection; import teetime.framework.validation.InvalidPortConnection;
public abstract class AbstractStage implements Stage { public abstract class AbstractStage implements IStage {
private final String id; private final String id;
/** /**
...@@ -22,7 +22,7 @@ public abstract class AbstractStage implements Stage { ...@@ -22,7 +22,7 @@ public abstract class AbstractStage implements Stage {
*/ */
protected final Logger logger; // NOPMD protected final Logger logger; // NOPMD
private Stage parentStage; private IStage parentStage;
private final List<InputPort<?>> inputPortList = new ArrayList<InputPort<?>>(); private final List<InputPort<?>> inputPortList = new ArrayList<InputPort<?>>();
private final List<OutputPort<?>> outputPortList = new ArrayList<OutputPort<?>>(); private final List<OutputPort<?>> outputPortList = new ArrayList<OutputPort<?>>();
...@@ -75,12 +75,12 @@ public abstract class AbstractStage implements Stage { ...@@ -75,12 +75,12 @@ public abstract class AbstractStage implements Stage {
} }
@Override @Override
public Stage getParentStage() { public IStage getParentStage() {
return this.parentStage; return this.parentStage;
} }
@Override @Override
public void setParentStage(final Stage parentStage, final int index) { public void setParentStage(final IStage parentStage, final int index) {
this.parentStage = parentStage; this.parentStage = parentStage;
} }
...@@ -126,18 +126,18 @@ public abstract class AbstractStage implements Stage { ...@@ -126,18 +126,18 @@ public abstract class AbstractStage implements Stage {
} }
public void onTerminating() throws Exception { public void onTerminating() throws Exception {
terminate(); this.terminate();
} }
protected <T> InputPort<T> createInputPort() { protected <T> InputPort<T> createInputPort() {
InputPort<T> inputPort = new InputPort<T>(this); final InputPort<T> inputPort = new InputPort<T>(this);
// inputPort.setType(portType); // inputPort.setType(portType);
this.inputPortList.add(inputPort); this.inputPortList.add(inputPort);
return inputPort; return inputPort;
} }
protected <T> OutputPort<T> createOutputPort() { protected <T> OutputPort<T> createOutputPort() {
OutputPort<T> outputPort = new OutputPort<T>(); final OutputPort<T> outputPort = new OutputPort<T>();
// outputPort.setType(portType); // outputPort.setType(portType);
this.outputPortList.add(outputPort); this.outputPortList.add(outputPort);
return outputPort; return outputPort;
...@@ -146,12 +146,12 @@ public abstract class AbstractStage implements Stage { ...@@ -146,12 +146,12 @@ public abstract class AbstractStage implements Stage {
@Override @Override
public void validateOutputPorts(final List<InvalidPortConnection> invalidPortConnections) { public void validateOutputPorts(final List<InvalidPortConnection> invalidPortConnections) {
for (OutputPort<?> outputPort : this.getOutputPorts()) { for (OutputPort<?> outputPort : this.getOutputPorts()) {
IPipe pipe = outputPort.getPipe(); final IPipe pipe = outputPort.getPipe();
if (null != pipe) { // if output port is connected with another one if (null != pipe) { // if output port is connected with another one
Class<?> sourcePortType = outputPort.getType(); final Class<?> sourcePortType = outputPort.getType();
Class<?> targetPortType = pipe.getTargetPort().getType(); final Class<?> targetPortType = pipe.getTargetPort().getType();
if (null == sourcePortType || !sourcePortType.equals(targetPortType)) { if (null == sourcePortType || !sourcePortType.equals(targetPortType)) {
InvalidPortConnection invalidPortConnection = new InvalidPortConnection(outputPort, pipe.getTargetPort()); final InvalidPortConnection invalidPortConnection = new InvalidPortConnection(outputPort, pipe.getTargetPort());
invalidPortConnections.add(invalidPortConnection); invalidPortConnections.add(invalidPortConnection);
} }
} }
......
...@@ -28,9 +28,9 @@ public class Analysis implements UncaughtExceptionHandler { ...@@ -28,9 +28,9 @@ public class Analysis implements UncaughtExceptionHandler {
} }
public void init() { public void init() {
List<Stage> threadableStageJobs = this.configuration.getThreadableStageJobs(); final List<IStage> threadableStageJobs = this.configuration.getThreadableStageJobs();
for (Stage stage : threadableStageJobs) { for (IStage stage : threadableStageJobs) {
Thread thread = new Thread(new RunnableStage(stage)); final Thread thread = new Thread(new RunnableStage(stage));
switch (stage.getTerminationStrategy()) { switch (stage.getTerminationStrategy()) {
case BY_SIGNAL: case BY_SIGNAL:
this.consumerThreads.add(thread); this.consumerThreads.add(thread);
...@@ -41,6 +41,8 @@ public class Analysis implements UncaughtExceptionHandler { ...@@ -41,6 +41,8 @@ public class Analysis implements UncaughtExceptionHandler {
case BY_INTERRUPT: case BY_INTERRUPT:
this.infiniteProducerThreads.add(thread); this.infiniteProducerThreads.add(thread);
break; break;
default:
break;
} }
} }
......
...@@ -8,15 +8,16 @@ import teetime.framework.pipe.PipeFactoryRegistry; ...@@ -8,15 +8,16 @@ import teetime.framework.pipe.PipeFactoryRegistry;
public class AnalysisConfiguration { public class AnalysisConfiguration {
protected static final PipeFactoryRegistry PIPE_FACTORY_REGISTRY = PipeFactoryRegistry.INSTANCE; protected static final PipeFactoryRegistry PIPE_FACTORY_REGISTRY = PipeFactoryRegistry.INSTANCE;
private final List<IStage> threadableStageJobs = new LinkedList<IStage>();
private final List<Stage> threadableStageJobs = new LinkedList<Stage>(); public AnalysisConfiguration() {}
List<Stage> getThreadableStageJobs() { List<IStage> getThreadableStageJobs() {
return threadableStageJobs; return this.threadableStageJobs;
} }
public void addThreadableStage(final Stage stage) { public void addThreadableStage(final IStage stage) {
threadableStageJobs.add(stage); this.threadableStageJobs.add(stage);
} }
} }
...@@ -5,15 +5,15 @@ import java.util.List; ...@@ -5,15 +5,15 @@ import java.util.List;
import teetime.framework.signal.ISignal; import teetime.framework.signal.ISignal;
import teetime.framework.validation.InvalidPortConnection; import teetime.framework.validation.InvalidPortConnection;
public interface Stage extends Terminable { public interface IStage extends ITerminable {
String getId(); String getId();
void executeWithPorts(); void executeWithPorts();
Stage getParentStage(); IStage getParentStage();
void setParentStage(Stage parentStage, int index); void setParentStage(IStage parentStage, int index);
void onSignal(ISignal signal, InputPort<?> inputPort); void onSignal(ISignal signal, InputPort<?> inputPort);
......
package teetime.framework; package teetime.framework;
interface Terminable { interface ITerminable {
TerminationStrategy getTerminationStrategy(); TerminationStrategy getTerminationStrategy();
......
...@@ -4,22 +4,22 @@ import teetime.framework.pipe.IPipe; ...@@ -4,22 +4,22 @@ import teetime.framework.pipe.IPipe;
public class InputPort<T> extends AbstractPort<T> { public class InputPort<T> extends AbstractPort<T> {
private final Stage owningStage; private final IStage owningStage;
InputPort(final Stage owningStage) { InputPort(final IStage owningStage) {
super(); super();
this.owningStage = owningStage; this.owningStage = owningStage;
} }
public T receive() { public T receive() {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
T element = (T) this.pipe.removeLast(); final T element = (T) this.pipe.removeLast();
return element; return element;
} }
public T read() { public T read() {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
T element = (T) this.pipe.readLast(); final T element = (T) this.pipe.readLast();
return element; return element;
} }
...@@ -33,7 +33,7 @@ public class InputPort<T> extends AbstractPort<T> { ...@@ -33,7 +33,7 @@ public class InputPort<T> extends AbstractPort<T> {
this.pipe = pipe; this.pipe = pipe;
} }
public Stage getOwningStage() { public IStage getOwningStage() {
return this.owningStage; return this.owningStage;
} }
......
...@@ -11,11 +11,11 @@ import teetime.framework.validation.AnalysisNotValidException; ...@@ -11,11 +11,11 @@ import teetime.framework.validation.AnalysisNotValidException;
@SuppressWarnings("PMD.BeanMembersShouldSerialize") @SuppressWarnings("PMD.BeanMembersShouldSerialize")
public class RunnableStage implements Runnable { public class RunnableStage implements Runnable {
private final Stage stage; private final IStage stage;
private final Logger logger; // NOPMD private final Logger logger; // NOPMD
private boolean validationEnabled; private boolean validationEnabled;
public RunnableStage(final Stage stage) { public RunnableStage(final IStage stage) {
this.stage = stage; this.stage = stage;
this.logger = LoggerFactory.getLogger(stage.getClass()); this.logger = LoggerFactory.getLogger(stage.getClass());
} }
...@@ -25,7 +25,7 @@ public class RunnableStage implements Runnable { ...@@ -25,7 +25,7 @@ public class RunnableStage implements Runnable {
this.logger.debug("Executing runnable stage..."); this.logger.debug("Executing runnable stage...");
if (this.validationEnabled) { if (this.validationEnabled) {
ValidatingSignal validatingSignal = new ValidatingSignal(); final ValidatingSignal validatingSignal = new ValidatingSignal();
this.stage.onSignal(validatingSignal, null); this.stage.onSignal(validatingSignal, null);
if (validatingSignal.getInvalidPortConnections().size() > 0) { if (validatingSignal.getInvalidPortConnections().size() > 0) {
throw new AnalysisNotValidException(validatingSignal.getInvalidPortConnections()); throw new AnalysisNotValidException(validatingSignal.getInvalidPortConnections());
...@@ -33,23 +33,23 @@ public class RunnableStage implements Runnable { ...@@ -33,23 +33,23 @@ public class RunnableStage implements Runnable {
} }
try { try {
StartingSignal startingSignal = new StartingSignal(); final StartingSignal startingSignal = new StartingSignal();
this.stage.onSignal(startingSignal, null); this.stage.onSignal(startingSignal, null);
do { do {
this.stage.executeWithPorts(); this.stage.executeWithPorts();
} while (!this.stage.shouldBeTerminated()); } while (!this.stage.shouldBeTerminated());
TerminatingSignal terminatingSignal = new TerminatingSignal(); final TerminatingSignal terminatingSignal = new TerminatingSignal();
this.stage.onSignal(terminatingSignal, null); this.stage.onSignal(terminatingSignal, null);
} catch (Error e) { } catch (Error e) {
this.logger.error("Terminating thread due to the following exception: ", e); this.logger.error("Terminating thread due to the following exception: ", e);
throw e; throw e;
} catch (RuntimeException e) { } // catch (RuntimeException e) {
this.logger.error("Terminating thread due to the following exception: ", e); // this.logger.error("Terminating thread due to the following exception: ", e);
throw e; // throw e;
} // }
this.logger.debug("Finished runnable stage. (" + this.stage.getId() + ")"); this.logger.debug("Finished runnable stage. (" + this.stage.getId() + ")");
} }
......
...@@ -11,11 +11,11 @@ import teetime.framework.InputPort; ...@@ -11,11 +11,11 @@ import teetime.framework.InputPort;
import teetime.framework.OutputPort; import teetime.framework.OutputPort;
import teetime.framework.signal.ISignal; import teetime.framework.signal.ISignal;
public abstract class InterThreadPipe extends AbstractPipe { public abstract class AbstractInterThreadPipe extends AbstractPipe {
private final Queue<ISignal> signalQueue = QueueFactory.newQueue(new ConcurrentQueueSpec(1, 1, 0, Ordering.FIFO, Preference.THROUGHPUT)); private final Queue<ISignal> signalQueue = QueueFactory.newQueue(new ConcurrentQueueSpec(1, 1, 0, Ordering.FIFO, Preference.THROUGHPUT));
<T> InterThreadPipe(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) { <T> AbstractInterThreadPipe(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
super(sourcePort, targetPort); super(sourcePort, targetPort);
} }
......
...@@ -4,9 +4,10 @@ import teetime.framework.InputPort; ...@@ -4,9 +4,10 @@ import teetime.framework.InputPort;
import teetime.framework.OutputPort; import teetime.framework.OutputPort;
import teetime.framework.signal.ISignal; import teetime.framework.signal.ISignal;
public abstract class IntraThreadPipe extends AbstractPipe { public abstract class AbstractIntraThreadPipe extends AbstractPipe {
<T> IntraThreadPipe(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
<T> AbstractIntraThreadPipe(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
super(sourcePort, targetPort); super(sourcePort, targetPort);
} }
......
package teetime.framework.pipe; package teetime.framework.pipe;
import teetime.framework.IStage;
import teetime.framework.InputPort; import teetime.framework.InputPort;
import teetime.framework.OutputPort; import teetime.framework.OutputPort;
import teetime.framework.Stage;
public abstract class AbstractPipe implements IPipe { public abstract class AbstractPipe implements IPipe {
private InputPort<?> targetPort;
/** /**
* Performance cache: Avoids the following method chain * Performance cache: Avoids the following method chain
* *
...@@ -15,7 +13,9 @@ public abstract class AbstractPipe implements IPipe { ...@@ -15,7 +13,9 @@ public abstract class AbstractPipe implements IPipe {
* this.getPipe().getTargetPort().getOwningStage() * this.getPipe().getTargetPort().getOwningStage()
* </pre> * </pre>
*/ */
protected Stage cachedTargetStage; protected IStage cachedTargetStage;
private InputPort<?> targetPort;
protected <T> AbstractPipe(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) { protected <T> AbstractPipe(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
this.targetPort = targetPort; this.targetPort = targetPort;
......
...@@ -4,7 +4,7 @@ import teetime.framework.InputPort; ...@@ -4,7 +4,7 @@ import teetime.framework.InputPort;
import teetime.framework.OutputPort; import teetime.framework.OutputPort;
import teetime.util.list.CommittableResizableArrayQueue; import teetime.util.list.CommittableResizableArrayQueue;
public final class CommittablePipe extends IntraThreadPipe { public final class CommittablePipe extends AbstractIntraThreadPipe {
private final CommittableResizableArrayQueue<Object> elements = new CommittableResizableArrayQueue<Object>(null, 4); private final CommittableResizableArrayQueue<Object> elements = new CommittableResizableArrayQueue<Object>(null, 4);
...@@ -14,13 +14,13 @@ public final class CommittablePipe extends IntraThreadPipe { ...@@ -14,13 +14,13 @@ public final class CommittablePipe extends IntraThreadPipe {
@Deprecated @Deprecated
public static <T> void connect(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) { public static <T> void connect(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
IPipe pipe = new CommittablePipe(null, null); final IPipe pipe = new CommittablePipe(null, null);
pipe.connectPorts(sourcePort, targetPort); pipe.connectPorts(sourcePort, targetPort);
} }
/* /*
* (non-Javadoc) * (non-Javadoc)
* *
* @see teetime.examples.throughput.methodcall.IPipe#add(T) * @see teetime.examples.throughput.methodcall.IPipe#add(T)
*/ */
@Override @Override
...@@ -32,19 +32,19 @@ public final class CommittablePipe extends IntraThreadPipe { ...@@ -32,19 +32,19 @@ public final class CommittablePipe extends IntraThreadPipe {
/* /*
* (non-Javadoc) * (non-Javadoc)
* *
* @see teetime.examples.throughput.methodcall.IPipe#removeLast() * @see teetime.examples.throughput.methodcall.IPipe#removeLast()
*/ */
@Override @Override
public Object removeLast() { public Object removeLast() {
Object element = this.elements.removeFromHeadUncommitted(); final Object element = this.elements.removeFromHeadUncommitted();
this.elements.commit(); this.elements.commit();
return element; return element;
} }
/* /*
* (non-Javadoc) * (non-Javadoc)
* *
* @see teetime.examples.throughput.methodcall.IPipe#isEmpty() * @see teetime.examples.throughput.methodcall.IPipe#isEmpty()
*/ */
@Override @Override
...@@ -54,7 +54,7 @@ public final class CommittablePipe extends IntraThreadPipe { ...@@ -54,7 +54,7 @@ public final class CommittablePipe extends IntraThreadPipe {
/* /*
* (non-Javadoc) * (non-Javadoc)
* *
* @see teetime.examples.throughput.methodcall.IPipe#readLast() * @see teetime.examples.throughput.methodcall.IPipe#readLast()
*/ */
@Override @Override
......
...@@ -13,6 +13,8 @@ import teetime.framework.signal.ISignal; ...@@ -13,6 +13,8 @@ import teetime.framework.signal.ISignal;
@SuppressWarnings("rawtypes") @SuppressWarnings("rawtypes")
public final class DummyPipe implements IPipe { public final class DummyPipe implements IPipe {
public DummyPipe() {}
@Override @Override
public boolean add(final Object element) { public boolean add(final Object element) {
return false; return false;
......
...@@ -4,7 +4,7 @@ import teetime.framework.InputPort; ...@@ -4,7 +4,7 @@ import teetime.framework.InputPort;
import teetime.framework.OutputPort; import teetime.framework.OutputPort;
import teetime.util.concurrent.workstealing.CircularArray; import teetime.util.concurrent.workstealing.CircularArray;
public final class OrderedGrowableArrayPipe extends IntraThreadPipe { public final class OrderedGrowableArrayPipe extends AbstractIntraThreadPipe {
private final CircularArray<Object> elements; private final CircularArray<Object> elements;
private int head; private int head;
...@@ -17,7 +17,7 @@ public final class OrderedGrowableArrayPipe extends IntraThreadPipe { ...@@ -17,7 +17,7 @@ public final class OrderedGrowableArrayPipe extends IntraThreadPipe {
@Deprecated @Deprecated
public static <T> void connect(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) { public static <T> void connect(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
IPipe pipe = new OrderedGrowableArrayPipe(sourcePort, targetPort, 4); final IPipe pipe = new OrderedGrowableArrayPipe(sourcePort, targetPort, 4);
pipe.connectPorts(sourcePort, targetPort); pipe.connectPorts(sourcePort, targetPort);
} }
......
...@@ -7,9 +7,11 @@ import teetime.framework.pipe.PipeFactoryRegistry.ThreadCommunication; ...@@ -7,9 +7,11 @@ import teetime.framework.pipe.PipeFactoryRegistry.ThreadCommunication;
public class OrderedGrowableArrayPipeFactory implements IPipeFactory { public class OrderedGrowableArrayPipeFactory implements IPipeFactory {
public OrderedGrowableArrayPipeFactory() {}
@Override @Override
public <T> IPipe create(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) { public <T> IPipe create(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
return create(sourcePort, targetPort, 4); return this.create(sourcePort, targetPort, 4);
} }
@Override @Override
......
...@@ -5,7 +5,7 @@ import java.util.LinkedList; ...@@ -5,7 +5,7 @@ import java.util.LinkedList;
import teetime.framework.InputPort; import teetime.framework.InputPort;
import teetime.framework.OutputPort; import teetime.framework.OutputPort;
public class OrderedGrowablePipe extends IntraThreadPipe { public class OrderedGrowablePipe extends AbstractIntraThreadPipe {
private final LinkedList<Object> elements; private final LinkedList<Object> elements;
...@@ -16,7 +16,7 @@ public class OrderedGrowablePipe extends IntraThreadPipe { ...@@ -16,7 +16,7 @@ public class OrderedGrowablePipe extends IntraThreadPipe {
@Deprecated @Deprecated
public static <T> void connect(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) { public static <T> void connect(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
IPipe pipe = new OrderedGrowablePipe(null, null, 100000); final IPipe pipe = new OrderedGrowablePipe(null, null, 100000);
pipe.connectPorts(sourcePort, targetPort); pipe.connectPorts(sourcePort, targetPort);
} }
......
...@@ -23,18 +23,18 @@ public final class PipeFactoryLoader { ...@@ -23,18 +23,18 @@ public final class PipeFactoryLoader {
} }
public static List<IPipeFactory> loadFromStream(final InputStream stream) throws IOException { public static List<IPipeFactory> loadFromStream(final InputStream stream) throws IOException {
List<IPipeFactory> pipeFactories = new LinkedList<IPipeFactory>(); final List<IPipeFactory> pipeFactories = new LinkedList<IPipeFactory>();
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(stream, "UTF-8")); final BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(stream, "UTF-8"));
try { try {
String line; String line;
while (null != (line = bufferedReader.readLine())) { while (null != (line = bufferedReader.readLine())) {
try { try {
line = line.trim(); line = line.trim();
if (!line.isEmpty()) { if (!line.isEmpty()) {
Class<?> clazz = Class.forName(line); final Class<?> clazz = Class.forName(line);
Class<? extends IPipeFactory> pipeFactoryClass = clazz.asSubclass(IPipeFactory.class); final Class<? extends IPipeFactory> pipeFactoryClass = clazz.asSubclass(IPipeFactory.class);
IPipeFactory pipeFactory = pipeFactoryClass.newInstance(); final IPipeFactory pipeFactory = pipeFactoryClass.newInstance();
pipeFactories.add(pipeFactory); pipeFactories.add(pipeFactory);
} }
} catch (ClassNotFoundException e) { } catch (ClassNotFoundException e) {
...@@ -65,10 +65,10 @@ public final class PipeFactoryLoader { ...@@ -65,10 +65,10 @@ public final class PipeFactoryLoader {
} }
public static List<IPipeFactory> mergeFiles(final List<URL> files) { public static List<IPipeFactory> mergeFiles(final List<URL> files) {
ArrayList<IPipeFactory> list = new ArrayList<IPipeFactory>(); final List<IPipeFactory> list = new ArrayList<IPipeFactory>();
for (URL url : files) { for (URL url : files) {
try { try {
InputStream is = url.openStream(); final InputStream is = url.openStream();
list.addAll(loadFromStream(is)); list.addAll(loadFromStream(is));
is.close(); is.close();
} catch (IOException e) { } catch (IOException e) {
......
...@@ -48,7 +48,7 @@ public final class PipeFactoryRegistry { ...@@ -48,7 +48,7 @@ public final class PipeFactoryRegistry {
public static final PipeFactoryRegistry INSTANCE = new PipeFactoryRegistry("pipe-factories.conf"); public static final PipeFactoryRegistry INSTANCE = new PipeFactoryRegistry("pipe-factories.conf");
private PipeFactoryRegistry(final String configFileName) { private PipeFactoryRegistry(final String configFileName) {
List<IPipeFactory> pipeFactories = PipeFactoryLoader.loadPipeFactoriesFromClasspath(configFileName); final List<IPipeFactory> pipeFactories = PipeFactoryLoader.loadPipeFactoriesFromClasspath(configFileName);
for (IPipeFactory pipeFactory : pipeFactories) { for (IPipeFactory pipeFactory : pipeFactories) {
this.register(pipeFactory); this.register(pipeFactory);
} }
...@@ -67,8 +67,8 @@ public final class PipeFactoryRegistry { ...@@ -67,8 +67,8 @@ public final class PipeFactoryRegistry {
* A PipeFactory, which provides suitable pipes. * A PipeFactory, which provides suitable pipes.
*/ */
public IPipeFactory getPipeFactory(final ThreadCommunication tc, final PipeOrdering ordering, final boolean growable) { public IPipeFactory getPipeFactory(final ThreadCommunication tc, final PipeOrdering ordering, final boolean growable) {
String key = this.buildKey(tc, ordering, growable); final String key = this.buildKey(tc, ordering, growable);
IPipeFactory pipeFactory = this.pipeFactories.get(key); final IPipeFactory pipeFactory = this.pipeFactories.get(key);
if (null == pipeFactory) { if (null == pipeFactory) {
throw new CouldNotFindPipeImplException(key); throw new CouldNotFindPipeImplException(key);
} }
...@@ -84,7 +84,7 @@ public final class PipeFactoryRegistry { ...@@ -84,7 +84,7 @@ public final class PipeFactoryRegistry {
* A PipeFactory which will be added to the registry * A PipeFactory which will be added to the registry
*/ */
public void register(final IPipeFactory pipeFactory) { public void register(final IPipeFactory pipeFactory) {
String key = this.buildKey(pipeFactory.getThreadCommunication(), pipeFactory.getOrdering(), pipeFactory.isGrowable()); final String key = this.buildKey(pipeFactory.getThreadCommunication(), pipeFactory.getOrdering(), pipeFactory.isGrowable());
this.pipeFactories.put(key, pipeFactory); this.pipeFactories.put(key, pipeFactory);
LOGGER.info("Registered pipe factory: " + pipeFactory.getClass().getCanonicalName()); LOGGER.info("Registered pipe factory: " + pipeFactory.getClass().getCanonicalName());
} }
......
...@@ -2,7 +2,7 @@ package teetime.framework.pipe; ...@@ -2,7 +2,7 @@ package teetime.framework.pipe;
import teetime.util.ConstructorClosure; import teetime.util.ConstructorClosure;
public final class RelayTestPipe<T> extends InterThreadPipe { public final class RelayTestPipe<T> extends AbstractInterThreadPipe {
private int numInputObjects; private int numInputObjects;
private final ConstructorClosure<T> inputObjectCreator; private final ConstructorClosure<T> inputObjectCreator;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment