[ https://jira.jboss.org/browse/JBREM-1251?page=com.atlassian.jira.plugin.s... ] Ron Sigal resolved JBREM-1251. ------------------------------ Assignee: Ron Sigal Resolution: Done Added a STREAM_FLUSH facility: 1. added RemoteProtocol.STREAM_FLUSH 2. added OutboundStream.getFlushBuffer(), which creates a buffer initialized with RemoteProtocol.STREAM_FLUSH 3. updated flush() in NioByteOutput returned by PrimaryExternalizerFactory.readOutboundStream() to public void flush() throws IOException { ByteBuffer flushBuffer = outboundStream.getFlushBuffer(); flushBuffer.flip(); outboundStream.send(flushBuffer); } 4. In InboundStream a. added flush() to Receiver interface b. added public void flush() { } to InboundStream.NioByteInputReceiver c. added public void flush() { try { outputStream.flush(); } catch (IOException e) { log.trace("Output stream write failed: %s", e); sendAsyncException(); } } to InboundStream.OutputStreamReceiver 5. In WriterOutputStream, changed public void flush() throws IOException { if (closed) throw new IOException("Stream closed"); writer.flush(); } to public void flush() throws IOException { if (closed) throw new IOException("Stream closed"); doFlush(false); } so that all received bytes go into the Writer 6. Added case RemoteProtocol.STREAM_FLUSH: { log.info(this + " got STREAM_FLUSH"); final int sid = buffer.getInt(); final IntKeyMap<InboundStream> inboundStreams = connectionHandler.getInboundStreams(); final InboundStream inboundStream; synchronized (inboundStreams) { inboundStream = inboundStreams.get(sid); } if (inboundStream == null) { log.warn("Received stream-flush for unknown stream ID %d", Integer.valueOf(sid)); return; } inboundStream.getReceiver().flush(); return; } RemoteMessageHandler. -- This message is automatically generated by JIRA. - For more information on JIRA, see: http://www.atlassian.com/software/jira