From c90c1c340cfb15546a23dc9488b99100425d2e22 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Fri, 6 Jun 2014 09:10:30 +0200
Subject: [PATCH] removed comments
---
src/main/java/teetime/framework/concurrent/WorkerThread.java | 2 +-
src/main/java/teetime/framework/core/AbstractFilter.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/main/java/teetime/framework/concurrent/WorkerThread.java b/src/main/java/teetime/framework/concurrent/WorkerThread.java
index feb78b68..ca1e5e77 100644
--- a/src/main/java/teetime/framework/concurrent/WorkerThread.java
+++ b/src/main/java/teetime/framework/concurrent/WorkerThread.java
@@ -73,7 +73,7 @@ public class WorkerThread extends Thread {
// beforeStageExecutionStopWatch.end();
this.startStageExecution(stage);
- // stageExecutionStopWatch.start(); // expensive: takes 1/3 of overall time
+ // stageExecutionStopWatch.start();
final boolean executedSuccessfully = stage.execute();
// stageExecutionStopWatch.end();
this.finishStageExecution(stage, executedSuccessfully);
diff --git a/src/main/java/teetime/framework/core/AbstractFilter.java b/src/main/java/teetime/framework/core/AbstractFilter.java
index 83b6b989..16b7cabb 100644
--- a/src/main/java/teetime/framework/core/AbstractFilter.java
+++ b/src/main/java/teetime/framework/core/AbstractFilter.java
@@ -178,7 +178,7 @@ public abstract class AbstractFilter<S extends IStage> extends AbstractStage imp
@Override
public void onPortIsClosed(final IInputPort<S, ?> inputPort) {
// inputPort.setState(IInputPort.State.CLOSING);
- this.enabledInputPorts--;
+ this.enabledInputPorts--; // FIXME not thread-safe
// this.logger.info("Closed " + "(" + this.enabledInputPorts + " remaining) " + inputPort + " of " + this);
if (this.enabledInputPorts < 0) {
--
GitLab