diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2009-08-21 15:55:01 +0200 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2009-08-21 15:55:01 +0200 |
| commit | b9f2fa14fb3f222a6ec5e0a93bf25fe5ad12b56a (patch) | |
| tree | 183215e2dbeadfbc871b800ce09726e58af38b91 /java/src/IceInternal/ConnectRequestHandler.java | |
| parent | adding compression cookbook demo (diff) | |
| download | ice-b9f2fa14fb3f222a6ec5e0a93bf25fe5ad12b56a.tar.bz2 ice-b9f2fa14fb3f222a6ec5e0a93bf25fe5ad12b56a.tar.xz ice-b9f2fa14fb3f222a6ec5e0a93bf25fe5ad12b56a.zip | |
IOCP changes, bug 3501, 4200, 4156, 3101
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); |