You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directory.apache.org by tr...@apache.org on 2005/12/23 12:47:29 UTC

svn commit: r358795 - /directory/network/trunk/src/java/org/apache/mina/filter/codec/support/SimpleProtocolEncoderOutput.java

Author: trustin
Date: Fri Dec 23 03:47:24 2005
New Revision: 358795

URL: http://svn.apache.org/viewcvs?rev=358795&view=rev
Log:
Fixed: concurrency issue when user writes messages from multiple threads at the same time

Modified:
    directory/network/trunk/src/java/org/apache/mina/filter/codec/support/SimpleProtocolEncoderOutput.java

Modified: directory/network/trunk/src/java/org/apache/mina/filter/codec/support/SimpleProtocolEncoderOutput.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/filter/codec/support/SimpleProtocolEncoderOutput.java?rev=358795&r1=358794&r2=358795&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/filter/codec/support/SimpleProtocolEncoderOutput.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/filter/codec/support/SimpleProtocolEncoderOutput.java Fri Dec 23 03:47:24 2005
@@ -27,12 +27,12 @@
         return bufferQueue;
     }
     
-    public void write( ByteBuffer buf )
+    public synchronized void write( ByteBuffer buf )
     {
         bufferQueue.push( buf );
     }
     
-    public void mergeAll()
+    public synchronized void mergeAll()
     {
         int sum = 0;
         final int size = bufferQueue.size();
@@ -70,7 +70,7 @@
         bufferQueue.push(newBuf);
     }
     
-    public WriteFuture flush()
+    public synchronized WriteFuture flush()
     {
         Queue bufferQueue = this.bufferQueue;
         WriteFuture future = null;