From 658596ff79202c829f93064712dcf6b38f5d588d Mon Sep 17 00:00:00 2001 From: Jonathan Cobb Date: Wed, 26 Aug 2020 12:46:47 -0400 Subject: [PATCH] log handler count --- .../util/io/multi/MultiUnderflowHandlerMonitor.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/src/main/java/org/cobbzilla/util/io/multi/MultiUnderflowHandlerMonitor.java b/src/main/java/org/cobbzilla/util/io/multi/MultiUnderflowHandlerMonitor.java index ba402f2..fbcbd65 100644 --- a/src/main/java/org/cobbzilla/util/io/multi/MultiUnderflowHandlerMonitor.java +++ b/src/main/java/org/cobbzilla/util/io/multi/MultiUnderflowHandlerMonitor.java @@ -29,24 +29,25 @@ public class MultiUnderflowHandlerMonitor extends SimpleDaemon { @Override protected long getSleepTime() { return checkInterval; } @Override protected void process() { - if (log.isTraceEnabled()) log.trace("process: examining "+handlers.size()+" underflow handlers"); + final String prefix = "process("+handlers.size()+" handlers): "; + if (log.isTraceEnabled()) log.trace(prefix+"examining underflow handlers"); for (Iterator iter = handlers.values().iterator(); iter.hasNext(); ) { final MultiUnderflowHandler underflow = iter.next(); if (underflow.closed()) { - if (log.isDebugEnabled()) log.debug("process: removing closed handler: name="+underflow.getHandlerName()+" thread="+underflow.getThread()); + if (log.isDebugEnabled()) log.debug(prefix+"removing closed handler: name="+underflow.getHandlerName()+" thread="+underflow.getThread()); iter.remove(); } else if (underflow.getLastRead() > 0 && !underflow.getThread().isAlive()) { - if (log.isDebugEnabled()) log.debug("process: removing dead thread: name="+underflow.getHandlerName()+" thread="+underflow.getThread()); + if (log.isDebugEnabled()) log.debug(prefix+"removing dead thread: name="+underflow.getHandlerName()+" thread="+underflow.getThread()); iter.remove(); } else if (now() - underflow.getLastRead() > underflow.getUnderflowTimeout()) { iter.remove(); if (terminateThreadFunc == null || terminateThreadFunc.apply(underflow.getThread())) { - if (log.isErrorEnabled()) log.error("process: underflow timed out, terminating: name=" + underflow.getHandlerName() + " thread=" + underflow.getThread()); + if (log.isErrorEnabled()) log.error(prefix+"underflow timed out, terminating: name=" + underflow.getHandlerName() + " thread=" + underflow.getThread()); terminate(underflow.getThread(), TERMINATE_TIMEOUT); } else { - if (log.isErrorEnabled()) log.error("process: underflow timed out, removing but NOT terminating: name=" + underflow.getHandlerName() + " thread=" + underflow.getThread()); + if (log.isErrorEnabled()) log.error(prefix+"underflow timed out, removing but NOT terminating: name=" + underflow.getHandlerName() + " thread=" + underflow.getThread()); } } }