Author: [log in to unmask]
Date: Thu Apr 16 15:57:59 2015
New Revision: 2728
Log:
End event processing if interrupt occurs.
Modified:
java/trunk/record-util/src/main/java/org/hps/record/composite/EventProcessingThread.java
Modified: java/trunk/record-util/src/main/java/org/hps/record/composite/EventProcessingThread.java
=============================================================================
--- java/trunk/record-util/src/main/java/org/hps/record/composite/EventProcessingThread.java (original)
+++ java/trunk/record-util/src/main/java/org/hps/record/composite/EventProcessingThread.java Thu Apr 16 15:57:59 2015
@@ -36,22 +36,35 @@
// Keep looping until the event processing is done.
while (true) {
+ // System.out.println("EventProcessingThread - top of loop");
+ // System.out.println("EventProcessingThread - loop state: " + this.loop.getState());
+
// If the loop was started and now is in the IDLE state, it means
// that STOP was executed, so break from the processing while loop.
if (started && this.loop.getState().equals(RecordLoop.State.IDLE)) {
+ // System.out.println("EventProcessingThread - breaking because IDLE");
// Stop record processing.
+ break;
+ }
+
+ if (this.isInterrupted()) {
+ // System.out.println("EventProcessingThread - breaking because interrupted");
break;
}
// Is the processing not paused?
if (!this.loop.isPaused()) {
+ // System.out.println("EventProcessingThread - not paused");
+
// Set a flag to indicate that looping has started.
started = true;
// Loop until done, error occurs, or pause is requested.
// FIXME: The maximum number of records should be used here instead.
+ // System.out.println("EventProcessingThread - looping");
this.loop.loop(-1);
+ // System.out.println("EventProcessingThread - done looping");
}
}
}
|