alright lets remove all the synchronization from the queue flushes

apache · Mar 1, 2024 · 62643fe · 62643fe
1 parent ed97be8
commit 62643fe
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/mina-core/src/main/java/org/apache/mina/filter/ssl/SSLHandlerG1.java b/mina-core/src/main/java/org/apache/mina/filter/ssl/SSLHandlerG1.java
@@ -761,19 +761,19 @@ synchronized protected void store_pending_error(SSLException sslException) {
     }
 
     protected void forward_received(NextFilter next) {
-        synchronized (mReceiveQueue) {
+        //synchronized (mReceiveQueue) {
             IoBuffer x;
             while ((x = mReceiveQueue.poll()) != null) {
                 if (LOGGER.isDebugEnabled()) {
                     LOGGER.debug("{} forward_received() - received {}", toString(), x);
                 }
                 next.messageReceived(mSession, x);
             }
-        }
+        //}
     }
 
     protected void forward_writes(NextFilter next) {
-        synchronized (mWriteQueue) {
+        //synchronized (mWriteQueue) {
             EncryptedWriteRequest x;
             while ((x = mWriteQueue.poll()) != null) {
                 if (LOGGER.isDebugEnabled()) {
@@ -782,19 +782,19 @@ protected void forward_writes(NextFilter next) {
                 mAckQueue.add(x);
                 next.filterWrite(mSession, x);
             }
-        }
+        //}
     }
 
     protected void forward_events(NextFilter next) {
-        synchronized (mEventQueue) {
+        //synchronized (mEventQueue) {
             FilterEvent x;
             while((x = mEventQueue.poll()) != null) {
                 if (LOGGER.isDebugEnabled()) {
                     LOGGER.debug("{} forward_events() - dispatching event {}", toString(), x);
                 }
                 next.event(mSession, x);
             }
-        }
+        //}
     }
 
     /**