You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@wink.apache.org by bl...@apache.org on 2009/09/27 21:18:33 UTC
svn commit: r819384 -
/incubator/wink/trunk/wink-server/src/main/java/org/apache/wink/server/internal/handlers/FlushResultHandler.java
Author: bluk
Date: Sun Sep 27 19:18:33 2009
New Revision: 819384
URL: http://svn.apache.org/viewvc?rev=819384&view=rev
Log:
Add more debug statements to FlushResultHandler
Modified:
incubator/wink/trunk/wink-server/src/main/java/org/apache/wink/server/internal/handlers/FlushResultHandler.java
Modified: incubator/wink/trunk/wink-server/src/main/java/org/apache/wink/server/internal/handlers/FlushResultHandler.java
URL: http://svn.apache.org/viewvc/incubator/wink/trunk/wink-server/src/main/java/org/apache/wink/server/internal/handlers/FlushResultHandler.java?rev=819384&r1=819383&r2=819384&view=diff
==============================================================================
--- incubator/wink/trunk/wink-server/src/main/java/org/apache/wink/server/internal/handlers/FlushResultHandler.java (original)
+++ incubator/wink/trunk/wink-server/src/main/java/org/apache/wink/server/internal/handlers/FlushResultHandler.java Sun Sep 27 19:18:33 2009
@@ -43,14 +43,14 @@
import javax.ws.rs.ext.RuntimeDelegate;
import javax.ws.rs.ext.RuntimeDelegate.HeaderDelegate;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
import org.apache.wink.common.internal.MultivaluedMapImpl;
import org.apache.wink.common.internal.i18n.Messages;
import org.apache.wink.common.internal.runtime.RuntimeContextTLS;
import org.apache.wink.server.handlers.AbstractHandler;
import org.apache.wink.server.handlers.MessageContext;
import org.apache.wink.server.internal.contexts.RequestImpl;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class FlushResultHandler extends AbstractHandler {
@@ -160,12 +160,23 @@
genericType,
declaredAnnotations,
responseMediaType);
+ if (logger.isDebugEnabled()) {
+ logger.debug("{}@{}.getSize({}, {}, {}, {}, {}) returned {}", new Object[] {
+ messageBodyWriter.getClass().getName(), Integer.toHexString(System.identityHashCode(messageBodyWriter)), entity,
+ rawType, genericType, declaredAnnotations, responseMediaType, size});
+ }
if (size >= 0) {
headers.putSingle(HttpHeaders.CONTENT_LENGTH, String.valueOf(size));
}
FlushHeadersOutputStream outputStream =
new FlushHeadersOutputStream(httpResponse, headers);
+ if (logger.isDebugEnabled()) {
+ logger.debug("{}@{}.writeTo({}, {}, {}, {}, {}, {}, {}) being called", new Object[] {
+ messageBodyWriter.getClass().getName(), Integer.toHexString(System.identityHashCode(messageBodyWriter)), entity,
+ rawType, genericType, declaredAnnotations, responseMediaType, httpHeaders,
+ outputStream});
+ }
messageBodyWriter.writeTo(entity,
rawType,
genericType,
@@ -173,6 +184,7 @@
responseMediaType,
httpHeaders,
outputStream);
+ logger.debug("Flushing headers if not written");
outputStream.flushHeaders();
return;
@@ -198,9 +210,18 @@
throw new WebApplicationException(500);
}
+ logger.debug("Serialization using data content handler {}", dataContentHandler.getClass()
+ .getName());
+
FlushHeadersOutputStream outputStream =
new FlushHeadersOutputStream(httpResponse, httpHeaders);
+ if (logger.isDebugEnabled()) {
+ logger.debug("{}.writeTo({}, {}, {}) being called", new Object[] {
+ Integer.toHexString(System.identityHashCode(dataContentHandler)), entity, rawType,
+ responseMediaType.toString(), outputStream});
+ }
dataContentHandler.writeTo(entity, responseMediaType.toString(), outputStream);
+ logger.debug("Flushing headers if not written");
outputStream.flushHeaders();
}