[jboss-remoting-commits] JBoss Remoting SVN: r6137 - remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote.

[jboss-remoting-commits at lists.jboss.org]

Author: ron.sigal at jboss.com
Date: 2010-11-12 12:45:40 -0500 (Fri, 12 Nov 2010)
New Revision: 6137

Modified:
   remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/InboundStream.java
Log:
JBREM-1251: Added flush() to Receiver interface, NioByteInputReceiver, and OutputStreamReceiver.

Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/InboundStream.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/InboundStream.java	2010-11-12 17:26:56 UTC (rev 6136)
+++ remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/InboundStream.java	2010-11-12 17:45:40 UTC (rev 6137)
@@ -81,6 +81,8 @@
         void pushEof();
 
         void pushException();
+        
+        void flush();
     }
 
     private void doSend(byte code) {
@@ -211,6 +213,9 @@
         public void returnBuffer(final ByteBuffer buffer) {
             remoteConnection.free(buffer);
         }
+        
+        public void flush() {
+        }
     }
 
     private class OutputStreamReceiver implements Receiver {
@@ -246,6 +251,15 @@
         public void pushException() {
             IoUtils.safeClose(outputStream);
         }
+        
+        public void flush() {
+        	try {
+        		outputStream.flush();
+        	} catch (IOException e) {
+        		log.trace("Output stream write failed: %s", e);
+        		sendAsyncException();
+        	}
+        }
     }
 
     interface ByteInputResult {