//
// ========================================================================
-// Copyright (c) 1995-2014 Mort Bay Consulting Pty. Ltd.
+// Copyright (c) 1995-2016 Mort Bay Consulting Pty. Ltd.
// ------------------------------------------------------------------------
// All rights reserved. This program and the accompanying materials
// are made available under the terms of the Eclipse Public License v1.0
{
boolean wasEmpty = _inputQ.isEmpty();
_inputQ.add(item);
- LOG.debug("{} queued {}", this, item);
+ if (LOG.isDebugEnabled())
+ LOG.debug("{} queued {}", this, item);
if (wasEmpty)
{
if (!onAsyncRead())
{
_inputQ.pollUnsafe();
onContentConsumed(item);
- LOG.debug("{} consumed {}", this, item);
+ if (LOG.isDebugEnabled())
+ LOG.debug("{} consumed {}", this, item);
item = _inputQ.peekUnsafe();
}
return item;
{
try
{
- LOG.debug("{} waiting for content", this);
+ if (LOG.isDebugEnabled())
+ LOG.debug("{} waiting for content", this);
lock().wait();
}
catch (InterruptedException e)