Mercurial > stress-tester

changeset 1255:b4b1febc1058

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
SynchFlowWorker sleep bugfix
author Devel 2
date Thu, 02 Jul 2020 10:49:34 +0200
parents 9e0796bd75b1
children a9eb4c208539
files stress-tester/src/main/java/com/passus/st/client/SynchFlowWorker.java
diffstat 1 files changed, 3 insertions(+), 1 deletions(-) [+]
line wrap: on
line diff
--- a/stress-tester/src/main/java/com/passus/st/client/SynchFlowWorker.java	Thu Jul 02 09:41:32 2020 +0200
+++ b/stress-tester/src/main/java/com/passus/st/client/SynchFlowWorker.java	Thu Jul 02 10:49:34 2020 +0200
@@ -296,7 +296,7 @@
      * @return boolean
      */
     private void process(Event event) {
-        sleep(event);
+
         if (trace) {
             logger.trace("Event processing: {}", event);
         }
@@ -308,10 +308,12 @@
             }*/
 
             if (event.getType() == SessionStatusEvent.TYPE) {
+                sleep(event);
                 SessionStatusEvent statusEvent = (SessionStatusEvent) sessEvent;
                 processFlowSessionStatusEvent(statusEvent, true);
                 return;
             } else if (event.getType() == SessionPayloadEvent.TYPE) {
+                sleep(event);
                 FlowContext flowContext = flowContext(sessEvent);
                 if (flowContext != null) {
                     if (flowContext.blocked) {