Mercurial > stress-tester
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