summaryrefslogtreecommitdiff
path: root/BKUOnline
diff options
context:
space:
mode:
Diffstat (limited to 'BKUOnline')
-rw-r--r--BKUOnline/src/main/java/at/gv/egiz/stal/service/impl/STALRequestBrokerImpl.java40
1 files changed, 20 insertions, 20 deletions
diff --git a/BKUOnline/src/main/java/at/gv/egiz/stal/service/impl/STALRequestBrokerImpl.java b/BKUOnline/src/main/java/at/gv/egiz/stal/service/impl/STALRequestBrokerImpl.java
index 6160c71e..7897f984 100644
--- a/BKUOnline/src/main/java/at/gv/egiz/stal/service/impl/STALRequestBrokerImpl.java
+++ b/BKUOnline/src/main/java/at/gv/egiz/stal/service/impl/STALRequestBrokerImpl.java
@@ -50,10 +50,10 @@ public class STALRequestBrokerImpl implements STALRequestBroker {
protected List<STALRequest> requests = null;
protected List<STALResponse> responses = null;
protected List<HashDataInput> currentHashDataInput;
- private boolean isHandlingRequest = false;
+// private boolean isHandlingRequest = false;
private boolean expectingResponse = false;
private boolean interrupted = false;
-
+
/**
* Produce requests (and HashDataInputCallback) and wait for responses.
* The next thread may enter once we consumed the responses.
@@ -69,17 +69,17 @@ public class STALRequestBrokerImpl implements STALRequestBroker {
return null;
}
try {
- long beforeWait = System.currentTimeMillis();
- while (isHandlingRequest) {
- log.trace("waiting to produce request");
- wait(TIMEOUT_MS);
- if (System.currentTimeMillis() - beforeWait >= TIMEOUT_MS) {
- log.warn("timeout while waiting to produce request");
- return Collections.singletonList((STALResponse) new ErrorResponse(ERR_6000));
- }
- }
+// long beforeWait = System.currentTimeMillis();
+// while (isHandlingRequest) {
+// log.trace("waiting to produce request");
+// wait(TIMEOUT_MS);
+// if (System.currentTimeMillis() - beforeWait >= TIMEOUT_MS) {
+// log.warn("timeout while waiting to produce request");
+// return Collections.singletonList((STALResponse) new ErrorResponse(ERR_6000));
+// }
+// }
log.trace("produce request");
- isHandlingRequest = true;
+// isHandlingRequest = true;
this.requests = requests;
currentHashDataInput = null;
@@ -100,7 +100,7 @@ public class STALRequestBrokerImpl implements STALRequestBroker {
log.trace("notifying request consumers");
notify();
- beforeWait = System.currentTimeMillis();
+ long beforeWait = System.currentTimeMillis();
while (this.responses == null) {
log.trace("waiting to consume response");
wait(TIMEOUT_MS);
@@ -108,7 +108,7 @@ public class STALRequestBrokerImpl implements STALRequestBroker {
log.warn("timeout while waiting to consume response");
this.requests = null;
currentHashDataInput = null;
- isHandlingRequest = false;
+// isHandlingRequest = false;
return Collections.singletonList((STALResponse) new ErrorResponse(ERR_6000));
}
}
@@ -118,9 +118,9 @@ public class STALRequestBrokerImpl implements STALRequestBroker {
log.trace("notifying response producers");
notify();
- isHandlingRequest = false;
- log.trace("notifying request producers");
- notify();
+// isHandlingRequest = false;
+// log.trace("notifying request producers");
+// notify();
return resps;
} catch (InterruptedException ex) {
@@ -186,9 +186,9 @@ public class STALRequestBrokerImpl implements STALRequestBroker {
List<STALRequest> reqs = requests;
requests = null;
if (reqs.size() > 0 && reqs.get(0) instanceof QuitRequest) {
- isHandlingRequest = false;
- log.trace("consumed QUIT, notifying request producers");
- notify();
+// isHandlingRequest = false;
+// log.trace("consumed QUIT, notifying request producers");
+// notify();
log.trace("expecting no response in next nextRequest()");
expectingResponse = false;
}