Author: hiranya
Date: Thu Aug 15 01:49:23 2013
New Revision: 1514124
URL: http://svn.apache.org/r1514124
Log:
No need to check for hasData() - HttpCore handles it correctly
Modified:
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/SourceHandler.java
Modified:
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/SourceHandler.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/SourceHandler.java?rev=1514124&r1=1514123&r2=1514124&view=diff
==============================================================================
---
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/SourceHandler.java
(original)
+++
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/SourceHandler.java
Thu Aug 15 01:49:23 2013
@@ -193,11 +193,9 @@ public class SourceHandler implements NH
synchronized (conn.getContext()) {
// SimpleOutputBuffer is not thread safe
// Explicit synchronization required
- if (outBuf.hasData()) {
- int bytesWritten = outBuf.produceContent(encoder);
- if (metrics != null && bytesWritten > 0) {
- metrics.incrementBytesSent(bytesWritten);
- }
+ int bytesWritten = outBuf.produceContent(encoder);
+ if (metrics != null && bytesWritten > 0) {
+ metrics.incrementBytesSent(bytesWritten);
}
conn.requestInput();