summaryrefslogtreecommitdiff
path: root/java/src
diff options
context:
space:
mode:
authorMarc Laukien <marc@zeroc.com>2004-02-16 14:50:37 +0000
committerMarc Laukien <marc@zeroc.com>2004-02-16 14:50:37 +0000
commit8582bf17281769d6b58618018f2119f9dd520ac7 (patch)
treef714107e952bcb13c288b417c95cf6722825c2b4 /java/src
parentfix (diff)
downloadice-8582bf17281769d6b58618018f2119f9dd520ac7.tar.bz2
ice-8582bf17281769d6b58618018f2119f9dd520ac7.tar.xz
ice-8582bf17281769d6b58618018f2119f9dd520ac7.zip
fixes
Diffstat (limited to 'java/src')
-rw-r--r--java/src/IceInternal/Connection.java5
-rw-r--r--java/src/IceInternal/Instance.java20
-rw-r--r--java/src/IceInternal/ThreadPool.java21
3 files changed, 16 insertions, 30 deletions
diff --git a/java/src/IceInternal/Connection.java b/java/src/IceInternal/Connection.java
index b30de100d37..3b063682c2f 100644
--- a/java/src/IceInternal/Connection.java
+++ b/java/src/IceInternal/Connection.java
@@ -1497,6 +1497,11 @@ public final class Connection extends EventHandler
os.writeByte(Protocol.closeConnectionMsg);
os.writeByte((byte)0); // Compression status.
os.writeInt(Protocol.headerSize); // Message size.
+
+ //
+ // Send the message.
+ //
+ TraceUtil.traceHeader("sending close connection", os, _logger, _traceLevels);
_transceiver.write(os, _endpoint.timeout());
_transceiver.shutdown();
}
diff --git a/java/src/IceInternal/Instance.java b/java/src/IceInternal/Instance.java
index ad1704c253b..57791047dc5 100644
--- a/java/src/IceInternal/Instance.java
+++ b/java/src/IceInternal/Instance.java
@@ -189,26 +189,6 @@ public class Instance
if(_clientThreadPool == null) // Lazy initialization.
{
-// Not necessary anymore, this is now the default for every thread pool
-/*
- //
- // Make sure that the client thread pool defaults are
- // correctly.
- //
- if(_properties.getProperty("Ice.ThreadPool.Client.Size") == "")
- {
- _properties.setProperty("Ice.ThreadPool.Client.Size", "1");
- }
- if(_properties.getProperty("Ice.ThreadPool.Client.SizeMax") == "")
- {
- _properties.setProperty("Ice.ThreadPool.Client.SizeMax", "1");
- }
- if(_properties.getProperty("Ice.ThreadPool.Client.SizeWarn") == "")
- {
- _properties.setProperty("Ice.ThreadPool.Client.SizeWarn", "0");
- }
-*/
-
_clientThreadPool = new ThreadPool(this, "Ice.ThreadPool.Client", 0);
}
diff --git a/java/src/IceInternal/ThreadPool.java b/java/src/IceInternal/ThreadPool.java
index 9bdb06ea3ac..11adfb87527 100644
--- a/java/src/IceInternal/ThreadPool.java
+++ b/java/src/IceInternal/ThreadPool.java
@@ -73,26 +73,27 @@ public final class ThreadPool
//
// We use just one thread as the default. This is the fastest
- // possible setting, still allows one level of nesting, and
+ // psossible setting, still allows one level of nesting, and
// doesn't require to make the servants thread safe.
//
int size = _instance.properties().getPropertyAsIntWithDefault(_prefix + ".Size", 1);
if(size < 1)
{
size = 1;
- }
- _size = size;
-
- int sizeMax = _instance.properties().getPropertyAsIntWithDefault(_prefix + ".SizeMax", _size * 10);
- if(sizeMax < _size)
+ }
+
+ int sizeMax = _instance.properties().getPropertyAsIntWithDefault(_prefix + ".SizeMax", size);
+ if(sizeMax < size)
{
- sizeMax = _size;
+ sizeMax = size;
}
- _sizeMax = sizeMax;
+
+ int sizeWarn = _instance.properties().getPropertyAsIntWithDefault(_prefix + ".SizeWarn", sizeMax * 80 / 100);
- int sizeWarn = _instance.properties().getPropertyAsIntWithDefault(_prefix + ".SizeWarn", _sizeMax * 80 / 100);
+ _size = size;
+ _sizeMax = sizeMax;
_sizeWarn = sizeWarn;
-
+
_messageSizeMax = _instance.messageSizeMax();
try