summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/OutgoingAsyncMessageCallback.java
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2009-08-21 15:55:01 +0200
committerBenoit Foucher <benoit@zeroc.com>2009-08-21 15:55:01 +0200
commitb9f2fa14fb3f222a6ec5e0a93bf25fe5ad12b56a (patch)
tree183215e2dbeadfbc871b800ce09726e58af38b91 /java/src/IceInternal/OutgoingAsyncMessageCallback.java
parentadding compression cookbook demo (diff)
downloadice-b9f2fa14fb3f222a6ec5e0a93bf25fe5ad12b56a.tar.bz2
ice-b9f2fa14fb3f222a6ec5e0a93bf25fe5ad12b56a.tar.xz
ice-b9f2fa14fb3f222a6ec5e0a93bf25fe5ad12b56a.zip
IOCP changes, bug 3501, 4200, 4156, 3101
Diffstat (limited to 'java/src/IceInternal/OutgoingAsyncMessageCallback.java')
-rw-r--r--java/src/IceInternal/OutgoingAsyncMessageCallback.java14
1 files changed, 4 insertions, 10 deletions
diff --git a/java/src/IceInternal/OutgoingAsyncMessageCallback.java b/java/src/IceInternal/OutgoingAsyncMessageCallback.java
index d47147f6e35..3f875de3336 100644
--- a/java/src/IceInternal/OutgoingAsyncMessageCallback.java
+++ b/java/src/IceInternal/OutgoingAsyncMessageCallback.java
@@ -105,9 +105,9 @@ abstract public class OutgoingAsyncMessageCallback
__os.instance().clientThreadPool().execute(new ThreadPoolWorkItem()
{
public void
- execute(ThreadPool threadPool)
+ execute(ThreadPoolCurrent current)
{
- threadPool.promoteFollower(null);
+ current.ioCompleted();
__exception(ex);
}
});
@@ -149,14 +149,8 @@ abstract public class OutgoingAsyncMessageCallback
{
if(instance.initializationData().properties.getPropertyAsIntWithDefault("Ice.Warn.AMICallback", 1) > 0)
{
- java.io.StringWriter sw = new java.io.StringWriter();
- java.io.PrintWriter pw = new java.io.PrintWriter(sw);
- IceUtilInternal.OutputBase out = new IceUtilInternal.OutputBase(pw);
- out.setUseTab(false);
- out.print("exception raised by AMI callback:\n");
- ex.printStackTrace(pw);
- pw.flush();
- instance.initializationData().logger.warning(sw.toString());
+ String s = "exception raised by AMI callback:\n" + Ex.toString(ex);
+ instance.initializationData().logger.warning(s);
}
}