Skip to content
Snippets Groups Projects
Commit 93896917 authored by Nelson Tavares de Sousa's avatar Nelson Tavares de Sousa
Browse files

changes modifier and set methods final

parent 8c281cc3
No related branches found
No related tags found
No related merge requests found
......@@ -204,7 +204,7 @@ public final class Analysis<T extends AnalysisConfiguration> implements Uncaught
}
@SuppressWarnings("rawtypes")
public void colorAndConnectStages(final Integer i, final Map<Stage, Integer> colors, final Stage threadableStage) {
private void colorAndConnectStages(final Integer i, final Map<Stage, Integer> colors, final Stage threadableStage) {
Set<Stage> threadableStageJobs = configuration.getThreadableStageJobs();
for (OutputPort outputPort : threadableStage.getOutputPorts()) {
if (outputPort.pipe != null) {
......
......@@ -59,7 +59,7 @@ public abstract class AnalysisConfiguration {
* @param stage
* A arbitrary stage, which will be added to the configuration and executed in a thread.
*/
protected void addThreadableStage(final Stage stage) {
protected final void addThreadableStage(final Stage stage) {
this.threadableStageJobs.add(stage);
}
......@@ -69,7 +69,7 @@ public abstract class AnalysisConfiguration {
* @param stage
* A arbitrary CompositeStage, which will be added to the configuration and executed in a thread.
*/
protected void addThreadableStage(final AbstractCompositeStage stage) {
protected final void addThreadableStage(final AbstractCompositeStage stage) {
this.threadableStageJobs.add(stage.getFirstStage());
for (Stage threadableStage : stage.getThreadableStageJobs()) {
this.addThreadableStage(threadableStage);
......@@ -161,7 +161,7 @@ public abstract class AnalysisConfiguration {
* @param targetPort
* port from the receiving stage
*/
protected <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
protected final <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
connectPorts(sourcePort, targetPort, 4);
}
......@@ -175,7 +175,7 @@ public abstract class AnalysisConfiguration {
* @param capacity
* the pipe is set to this capacity, if the value is greater than 0. If it is 0, than the pipe is unbounded, thus growing of the pipe is enabled.
*/
protected <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort, final int capacity) {
protected final <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort, final int capacity) {
new InstantiationPipe<T>(sourcePort, targetPort, capacity);
// connections.add(new Connection<T>(sourcePort, targetPort, capacity));
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment