From c3cba62fa0b7217e6e548662fd6187d83797d625 Mon Sep 17 00:00:00 2001
From: markt <markt@13f79535-47bb-0310-9956-ffa450edef68>
Date: Thu, 11 Nov 2010 12:51:35 +0000
Subject: [PATCH] Fix https://issues.apache.org/bugzilla/show_bug.cgi?id=50183
 BIO sender was not scheduling tasks to the executor during normal operation.
 Patch provided by Ariel.

git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@1033920 13f79535-47bb-0310-9956-ffa450edef68
---
 java/org/apache/catalina/tribes/transport/bio/BioReceiver.java      | 1 +
 .../apache/catalina/tribes/transport/bio/BioReplicationTask.java    | 3 +--
 webapps/docs/changelog.xml                                          | 6 +++++-
 3 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/java/org/apache/catalina/tribes/transport/bio/BioReceiver.java b/java/org/apache/catalina/tribes/transport/bio/BioReceiver.java
index 2685f9a36..45aeb9607 100644
--- a/java/org/apache/catalina/tribes/transport/bio/BioReceiver.java
+++ b/java/org/apache/catalina/tribes/transport/bio/BioReceiver.java
@@ -152,6 +152,7 @@ public class BioReceiver extends ReceiverBase implements Runnable {
             socket.setSoTimeout(getTimeout());
             ObjectReader reader = new ObjectReader(socket);
             task.serviceSocket(socket,reader);
+            getExecutor().execute(task);
         }//while
     }
     
diff --git a/java/org/apache/catalina/tribes/transport/bio/BioReplicationTask.java b/java/org/apache/catalina/tribes/transport/bio/BioReplicationTask.java
index b0edbbbda..50a0edf18 100644
--- a/java/org/apache/catalina/tribes/transport/bio/BioReplicationTask.java
+++ b/java/org/apache/catalina/tribes/transport/bio/BioReplicationTask.java
@@ -65,7 +65,7 @@ public class BioReplicationTask extends AbstractRxTask {
         try {
             drainSocket();
         } catch ( Exception x ) {
-            log.error("Unable to service bio socket");
+            log.error("Unable to service bio socket", x);
         }finally {
             try {socket.close();}catch ( Exception e){/* Ignore */}
             try {reader.close();}catch ( Exception e){/* Ignore */}
@@ -80,7 +80,6 @@ public class BioReplicationTask extends AbstractRxTask {
     public synchronized void serviceSocket(Socket socket, ObjectReader reader) {
         this.socket = socket;
         this.reader = reader;
-        this.notify();      // awaken the thread
     }
     
     protected void execute(ObjectReader reader) throws Exception{
diff --git a/webapps/docs/changelog.xml b/webapps/docs/changelog.xml
index 2c49144c4..93c6ede9a 100644
--- a/webapps/docs/changelog.xml
+++ b/webapps/docs/changelog.xml
@@ -183,9 +183,13 @@
         (kfujino)
       </fix>
       <fix>
+        <bug>50183</bug>: BIO sender was not scheduling tasks to the executor
+        during normal operation. Patch provided by Ariel. (markt)
+      </fix>
+      <fix>
         <bug>50184</bug>: Add an option to the RpcChannel to enable the Channel
         send options to be set for the reply message. Based on a patch by Ariel.
-        (markt))
+        (markt)
       </fix>
     </changelog>
   </subsection>
-- 
2.11.0