changeset 1216:c4f9e819ebe0

SynchFlowWorker - more logs
author Devel 2
date Wed, 24 Jun 2020 09:32:09 +0200
parents afd31c0205e9
children 83f0366550e1
files stress-tester/src/main/java/com/passus/st/client/SynchFlowWorker.java
diffstat 1 files changed, 11 insertions(+), 0 deletions(-) [+]
line wrap: on
line diff
--- a/stress-tester/src/main/java/com/passus/st/client/SynchFlowWorker.java	Wed Jun 24 09:31:48 2020 +0200
+++ b/stress-tester/src/main/java/com/passus/st/client/SynchFlowWorker.java	Wed Jun 24 09:32:09 2020 +0200
@@ -120,6 +120,10 @@
             return null;
         }
 
+        if (logger.isDebugEnabled()) {
+            logger.debug("Registering flowContext for session: " + session);
+        }
+
         FlowContext flowContext = new FlowContext(session, new LinkedList<>());
         flowContext.createLock();
         FlowHandler flowHandler = clientFactory.create(session.getProtocolId());
@@ -153,6 +157,10 @@
         FlowContext flowContext = flowContext(session);
         if (flowContext != null) {
             if (flowContext.blocked) {
+                if (logger.isDebugEnabled()) {
+                    debug(logger, flowContext, "Blocked.");
+                }
+
                 return flowContext;
             }
 
@@ -185,6 +193,9 @@
                 }
             }
         }
+
+        System.out.println("SynchFlowWorker.sessions: " + sessions.size());
+        System.out.println("SynchFlowWorker.eventsQueue: " + eventsQueue.size());
     }
 
     @Override