summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/Connection.java
diff options
context:
space:
mode:
authorMark Spruiell <mes@zeroc.com>2002-01-03 21:55:36 +0000
committerMark Spruiell <mes@zeroc.com>2002-01-03 21:55:36 +0000
commitaab366f5238bcb4e00dfc40ea127dd6415e26749 (patch)
treec8668bc729fb6c795e8da1ecc22427b652462aef /java/src/IceInternal/Connection.java
parentupdate dependencies. (diff)
downloadice-aab366f5238bcb4e00dfc40ea127dd6415e26749.tar.bz2
ice-aab366f5238bcb4e00dfc40ea127dd6415e26749.tar.xz
ice-aab366f5238bcb4e00dfc40ea127dd6415e26749.zip
server fixes
Diffstat (limited to 'java/src/IceInternal/Connection.java')
-rw-r--r--java/src/IceInternal/Connection.java40
1 files changed, 20 insertions, 20 deletions
diff --git a/java/src/IceInternal/Connection.java b/java/src/IceInternal/Connection.java
index 065c5a03a2d..45ae6ecfcf5 100644
--- a/java/src/IceInternal/Connection.java
+++ b/java/src/IceInternal/Connection.java
@@ -368,18 +368,19 @@ public final class Connection extends EventHandler
{
if (_state == StateClosing)
{
- TraceUtil.traceRequest("received batch request " +
- "during closing\n" +
- "(ignored by server, " +
- "client will retry)",
- stream, _logger,
- _traceLevels);
+ TraceUtil.traceBatchRequest("received batch " +
+ "request during " +
+ "closing\n" +
+ "(ignored by server, " +
+ "client will retry)",
+ stream, _logger,
+ _traceLevels);
}
else
{
- TraceUtil.traceRequest("received batch request",
- stream, _logger,
- _traceLevels);
+ TraceUtil.traceBatchRequest("received batch " +
+ "request", stream,
+ _logger, _traceLevels);
invoke = true;
batch = true;
}
@@ -523,6 +524,9 @@ public final class Connection extends EventHandler
return;
}
+ //
+ // Fill in the message size
+ //
os.pos(3);
final int sz = os.size();
os.writeInt(sz);
@@ -541,16 +545,8 @@ public final class Connection extends EventHandler
}
catch (Ice.LocalException ex)
{
- _mutex.lock();
- try
- {
- setState(StateClosed, ex);
- return;
- }
- finally
- {
- _mutex.unlock();
- }
+ setState(StateClosed, ex);
+ return;
}
}
finally
@@ -760,7 +756,11 @@ public final class Connection extends EventHandler
{
if (_warn)
{
- String s = "connection exception:\n" + ex + '\n' +
+ java.io.StringWriter sw = new java.io.StringWriter();
+ java.io.PrintWriter pw = new java.io.PrintWriter(sw);
+ ex.printStackTrace(pw);
+ pw.flush();
+ String s = "connection exception:\n" + sw.toString() + '\n' +
_transceiver.toString();
_logger.warning(s);
}