diff options
Diffstat (limited to 'java/src/IceInternal/ConnectRequestHandler.java')
| -rw-r--r-- | java/src/IceInternal/ConnectRequestHandler.java | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/java/src/IceInternal/ConnectRequestHandler.java b/java/src/IceInternal/ConnectRequestHandler.java index e5eb47d7957..b7b55502eea 100644 --- a/java/src/IceInternal/ConnectRequestHandler.java +++ b/java/src/IceInternal/ConnectRequestHandler.java @@ -297,9 +297,9 @@ public class ConnectRequestHandler _reference.getInstance().clientThreadPool().execute(new ThreadPoolWorkItem() { public void - execute(ThreadPool threadPool) + execute(ThreadPoolCurrent current) { - threadPool.promoteFollower(null); + current.ioCompleted(); flushRequestsWithException(ex); }; }); @@ -430,13 +430,13 @@ public class ConnectRequestHandler { request.os.pos(0); os.writeBlob(request.os.readBlob(request.os.size())); - _connection.finishBatchRequest(os, _compress); } catch(Ice.LocalException ex) { _connection.abortBatchRequest(); throw ex; } + _connection.finishBatchRequest(os, _compress); } p.remove(); } @@ -450,9 +450,9 @@ public class ConnectRequestHandler _reference.getInstance().clientThreadPool().execute(new ThreadPoolWorkItem() { public void - execute(ThreadPool threadPool) + execute(ThreadPoolCurrent current) { - threadPool.promoteFollower(null); + current.ioCompleted(); flushRequestsWithException(ex); }; }); @@ -467,9 +467,9 @@ public class ConnectRequestHandler _reference.getInstance().clientThreadPool().execute(new ThreadPoolWorkItem() { public void - execute(ThreadPool threadPool) + execute(ThreadPoolCurrent current) { - threadPool.promoteFollower(null); + current.ioCompleted(); flushRequestsWithException(ex); }; }); @@ -482,9 +482,9 @@ public class ConnectRequestHandler instance.clientThreadPool().execute(new ThreadPoolWorkItem() { public void - execute(ThreadPool threadPool) + execute(ThreadPoolCurrent current) { - threadPool.promoteFollower(null); + current.ioCompleted(); for(OutgoingAsyncMessageCallback callback : sentCallbacks) { callback.__sent(instance); |