Changed some log level from info to debug
git-svn-id: https://svn.apache.org/repos/asf/mina/asyncweb/trunk@620752 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/server/src/main/java/org/apache/asyncweb/server/BasicServiceContainer.java b/server/src/main/java/org/apache/asyncweb/server/BasicServiceContainer.java
index a7c6a89..6cb41a4 100644
--- a/server/src/main/java/org/apache/asyncweb/server/BasicServiceContainer.java
+++ b/server/src/main/java/org/apache/asyncweb/server/BasicServiceContainer.java
@@ -221,11 +221,13 @@
public void start() throws ContainerLifecycleException {
if (!isStarted) {
- LOG.info("BasicServiceContainer starting");
+ if (LOG.isDebugEnabled())
+ LOG.debug("BasicServiceContainer starting");
startSessionAccessor();
startHandlers();
startTransports();
- LOG.info("BasicServiceContainer started");
+ if (LOG.isDebugEnabled())
+ LOG.debug("BasicServiceContainer started");
isStarted = true;
}
}
@@ -233,11 +235,13 @@
public void stop() {
if (isStarted) {
isStarted = false;
- LOG.info("BasicServiceContainer stopping");
+ if (LOG.isDebugEnabled())
+ LOG.debug("BasicServiceContainer stopping");
stopHandlers();
stopTransports();
stopSessionAccessor();
- LOG.info("BasicServiceContainer stopped");
+ if (LOG.isDebugEnabled())
+ LOG.debug("BasicServiceContainer stopped");
}
}
@@ -257,31 +261,37 @@
* Starts all added handlers
*/
private void startHandlers() {
- LOG.info("Starting handlers");
+ if (LOG.isDebugEnabled())
+ LOG.debug("Starting handlers");
synchronized (filters) {
for (HttpServiceFilter handler : filters) {
- handler.start();
- }
+ handler.start();
+ }
}
- LOG.info("Handlers started");
+ if (LOG.isDebugEnabled())
+ LOG.debug("Handlers started");
}
private void stopHandlers() {
- LOG.info("Stopping handlers");
+ if (LOG.isDebugEnabled())
+ LOG.debug("Stopping handlers");
synchronized (filters) {
for (HttpServiceFilter handler : filters) {
- LOG.info("Stopping handler '" + handler + "'");
- handler.stop();
- LOG.info("Handler '" + handler + "' stopped");
- }
+ LOG.info("Stopping handler '" + handler + "'");
+ handler.stop();
+ LOG.info("Handler '" + handler + "' stopped");
+ }
}
- LOG.info("Handlers stopped");
+ if (LOG.isDebugEnabled())
+ LOG.debug("Handlers stopped");
}
private void stopSessionAccessor() {
- LOG.info("Disposing session accessor");
+ if (LOG.isDebugEnabled())
+ LOG.debug("Disposing session accessor");
sessionAccessor.dispose();
- LOG.info("Session accessor disposed");
+ if (LOG.isDebugEnabled())
+ LOG.debug("Session accessor disposed");
}
/**
@@ -290,38 +300,42 @@
* @throws ContainerLifecycleException If we fail to start a transport
*/
private void startTransports() throws ContainerLifecycleException {
- LOG.info("Starting transports");
+ if (LOG.isDebugEnabled())
+ LOG.debug("Starting transports");
synchronized (transports) {
for (Transport transport : transports) {
- LOG.info("Starting transport '" + transport + "'");
- try {
- transport.start();
- } catch (TransportException e) {
- LOG.info("Transport '" + transport + "' failed to start");
- throw new ContainerLifecycleException(
- "Failed to start transport ' " + transport + "'", e);
+ LOG.info("Starting transport '" + transport + "'");
+ try {
+ transport.start();
+ } catch (TransportException e) {
+ LOG.info("Transport '" + transport + "' failed to start");
+ throw new ContainerLifecycleException(
+ "Failed to start transport ' " + transport + "'", e);
+ }
}
- }
}
- LOG.info("Transports started");
+ if (LOG.isDebugEnabled())
+ LOG.debug("Transports started");
}
private void stopTransports() {
- LOG.info("Stopping transports");
+ if (LOG.isDebugEnabled())
+ LOG.debug("Stopping transports");
boolean isError = false;
synchronized (transports) {
for (Transport transport : transports) {
- LOG.info("Stopping transport '" + transport + "'");
- try {
- transport.stop();
- LOG.info("Transport '" + transport + "' stopped");
- } catch (TransportException e) {
- LOG.warn("Failed to stop transport '" + transport + "'", e);
- isError = true;
+ LOG.info("Stopping transport '" + transport + "'");
+ try {
+ transport.stop();
+ LOG.info("Transport '" + transport + "' stopped");
+ } catch (TransportException e) {
+ LOG.warn("Failed to stop transport '" + transport + "'", e);
+ isError = true;
+ }
}
- }
}
String errorString = isError ? " (One or more errors encountered)" : "";
- LOG.info("Transports stopped" + errorString);
+ if (LOG.isDebugEnabled())
+ LOG.debug("Transports stopped" + errorString);
}
}
diff --git a/server/src/main/java/org/apache/asyncweb/server/HttpServiceHandler.java b/server/src/main/java/org/apache/asyncweb/server/HttpServiceHandler.java
index e523c1d..fbc7188 100644
--- a/server/src/main/java/org/apache/asyncweb/server/HttpServiceHandler.java
+++ b/server/src/main/java/org/apache/asyncweb/server/HttpServiceHandler.java
@@ -101,8 +101,8 @@
if (service == null) {
handleUnmappedRequest(context);
} else {
- if (LOG.isInfoEnabled()) {
- LOG.info("Mapped request [" + request.getRequestUri() + "] to "
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Mapped request [" + request.getRequestUri() + "] to "
+ "service '" + serviceName + "'");
}
service.handleRequest(context);
@@ -123,7 +123,8 @@
* Starts this handler.
*/
public void start() {
- LOG.info("HttpServiceHandler starting");
+ if (LOG.isDebugEnabled())
+ LOG.debug("HttpServiceHandler starting");
for (Entry<String, HttpService> entry : serviceMap
.entrySet()) {
String serviceName = entry.getKey();
diff --git a/server/src/main/java/org/apache/asyncweb/server/resolver/SimplePrefixResolver.java b/server/src/main/java/org/apache/asyncweb/server/resolver/SimplePrefixResolver.java
index 497ffaf..4a0d670 100644
--- a/server/src/main/java/org/apache/asyncweb/server/resolver/SimplePrefixResolver.java
+++ b/server/src/main/java/org/apache/asyncweb/server/resolver/SimplePrefixResolver.java
@@ -98,8 +98,8 @@
path = null;
}
}
- if (LOG.isInfoEnabled()) {
- LOG.info("Resolved request to service name: " + path);
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Resolved request to service name: " + path);
}
return path;
}
diff --git a/server/src/main/java/org/apache/asyncweb/server/session/SecureRandomKeyFactory.java b/server/src/main/java/org/apache/asyncweb/server/session/SecureRandomKeyFactory.java
index 909171a..1a44a1f 100644
--- a/server/src/main/java/org/apache/asyncweb/server/session/SecureRandomKeyFactory.java
+++ b/server/src/main/java/org/apache/asyncweb/server/session/SecureRandomKeyFactory.java
@@ -100,13 +100,14 @@
*/
public void start() {
isStarted = true;
- LOG.info("Attempting to obtain SecureRandom using algorithim: "
- + algorithm);
+ if (LOG.isDebugEnabled())
+ LOG.debug("Attempting to obtain SecureRandom using algorithim: "
+ + algorithm);
try {
secureRandom = SecureRandom.getInstance(algorithm);
- LOG.info("Ok - using algorithm: " + algorithm);
+ LOG.info("Using algorithm: " + algorithm);
} catch (NoSuchAlgorithmException e) {
- LOG.info("Failed to obtain secure random with algorithm: "
+ LOG.warn("Failed to obtain secure random with algorithm: "
+ algorithm + ". Resorting to default");
}
secureRandom = new SecureRandom();
diff --git a/server/src/main/java/org/apache/asyncweb/server/transport/mina/MinaTransport.java b/server/src/main/java/org/apache/asyncweb/server/transport/mina/MinaTransport.java
index 0faee24..1aaa361 100644
--- a/server/src/main/java/org/apache/asyncweb/server/transport/mina/MinaTransport.java
+++ b/server/src/main/java/org/apache/asyncweb/server/transport/mina/MinaTransport.java
@@ -186,7 +186,7 @@
if ( isLoggingTraffic )
{
- LOG.info( "Configuring traffic logging filter" );
+ LOG.debug( "Configuring traffic logging filter" );
IoFilter filter = new LoggingFilter();
acceptor.getFilterChain().addFirst( "LoggingFilter", filter );
}
@@ -205,7 +205,7 @@
}
success = true;
- LOG.info( "NIO HTTP Transport bound on port " + port );
+ LOG.debug( "NIO HTTP Transport bound on port " + port );
}
catch ( IOException e )
{
diff --git a/server/src/main/java/org/apache/asyncweb/server/transport/mina/SingleHttpSessionIoHandler.java b/server/src/main/java/org/apache/asyncweb/server/transport/mina/SingleHttpSessionIoHandler.java
index 94ec8b9..474e56e 100644
--- a/server/src/main/java/org/apache/asyncweb/server/transport/mina/SingleHttpSessionIoHandler.java
+++ b/server/src/main/java/org/apache/asyncweb/server/transport/mina/SingleHttpSessionIoHandler.java
@@ -105,19 +105,22 @@
public void sessionCreated()
{
- LOG.info( "Session created" );
+ if (LOG.isDebugEnabled())
+ LOG.debug( "Session created" );
}
public void sessionOpened()
{
- LOG.info( "Connection opened" );
+ if (LOG.isDebugEnabled())
+ LOG.debug( "Connection opened" );
}
public void sessionClosed()
{
- LOG.info( "Connection closed" );
+ if (LOG.isDebugEnabled())
+ LOG.debug( "Connection closed" );
if ( currentContext != null )
{
@@ -140,8 +143,8 @@
// LOG.info("Read idled out while parsing request. Scheduling timeout response");
// handleReadFailure(currentContext, HttpResponseStatus.REQUEST_TIMEOUT, "Timeout while reading request");
// } else {
-
- LOG.debug( "Session idle detected on context {} with idleType {}", currentContext, idleType );
+ if (LOG.isDebugEnabled())
+ LOG.debug( "Session idle detected on context {} with idleType {}", currentContext, idleType );
if ( currentContext != null )
{
@@ -152,13 +155,15 @@
}
else
{
- // TODO - look further into this - it may present serious issues when dealing with HTTP/1.1
- LOG.info( "Idled with no current request. Scheduling closure when pipeline empties" );
+ // TODO - look further into this - it may present serious issues when dealing with HTTP/1.1
+ if (LOG.isDebugEnabled())
+ LOG.debug( "Idled with no current request. Scheduling closure when pipeline empties" );
pipeline.runWhenEmpty( new Runnable()
{
public void run()
{
- LOG.info( "Pipeline empty after idle. Closing session" );
+ if (LOG.isDebugEnabled())
+ LOG.debug( "Pipeline empty after idle. Closing session" );
session.close();
}
});
@@ -371,7 +376,8 @@
Object message) throws Exception {
HttpServiceContext context = (HttpServiceContext) message;
if (pipeline.addRequest(context)) {
- LOG.debug("Allocated slot in request pipeline");
+ if (LOG.isDebugEnabled())
+ LOG.debug("Allocated slot in request pipeline");
nextFilter.messageReceived(session, message);
} else {
// The client has filled their pipeline. Currently, this
@@ -425,7 +431,8 @@
WriteFuture future = session.write( this );
if ( requiresClosure )
{
- LOG.debug( "Added CLOSE future listener." );
+ if (LOG.isDebugEnabled())
+ LOG.debug( "Added CLOSE future listener." );
future.addListener( IoFutureListener.CLOSE );
}
}
