summaryrefslogtreecommitdiff
path: root/java/src/Ice/ObjectAdapterI.java
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2008-03-06 10:13:42 +0100
committerBenoit Foucher <benoit@zeroc.com>2008-03-06 10:13:42 +0100
commitc6dbd090d9691cc0116a2967b2827b858b184dfe (patch)
tree6d2ad80c98665c9090b16f97c400ab4b33c7ab73 /java/src/Ice/ObjectAdapterI.java
parentMerge branch 'master' of ssh://cvs.zeroc.com/home/git/ice (diff)
downloadice-c6dbd090d9691cc0116a2967b2827b858b184dfe.tar.bz2
ice-c6dbd090d9691cc0116a2967b2827b858b184dfe.tar.xz
ice-c6dbd090d9691cc0116a2967b2827b858b184dfe.zip
Removed thread-per-connection and added serialize mode
Diffstat (limited to 'java/src/Ice/ObjectAdapterI.java')
-rw-r--r--java/src/Ice/ObjectAdapterI.java29
1 files changed, 3 insertions, 26 deletions
diff --git a/java/src/Ice/ObjectAdapterI.java b/java/src/Ice/ObjectAdapterI.java
index 6998793fa06..9459d4bdb6a 100644
--- a/java/src/Ice/ObjectAdapterI.java
+++ b/java/src/Ice/ObjectAdapterI.java
@@ -725,15 +725,6 @@ public final class ObjectAdapterI implements ObjectAdapter
return _servantManager;
}
- public boolean
- getThreadPerConnection()
- {
- //
- // No mutex lock necessary, _threadPerConnection is immutable.
- //
- return _threadPerConnection;
- }
-
//
// Only for use by IceInternal.ObjectAdapterFactory
//
@@ -821,23 +812,12 @@ public final class ObjectAdapterI implements ObjectAdapter
try
{
- _threadPerConnection = properties.getPropertyAsInt(_name + ".ThreadPerConnection") > 0;
-
int threadPoolSize = properties.getPropertyAsInt(_name + ".ThreadPool.Size");
int threadPoolSizeMax = properties.getPropertyAsInt(_name + ".ThreadPool.SizeMax");
- if(_threadPerConnection && (threadPoolSize > 0 || threadPoolSizeMax > 0))
- {
- InitializationException ex = new InitializationException();
- ex.reason = "object adapter `" + _name + "' cannot be configured for both\n" +
- "thread pool and thread per connection";
- throw ex;
- }
-
- if(!_threadPerConnection && threadPoolSize == 0 && threadPoolSizeMax == 0)
- {
- _threadPerConnection = _instance.threadPerConnection();
- }
+ //
+ // Create the per-adapter thread pool, if necessary.
+ //
if(threadPoolSize > 0 || threadPoolSizeMax > 0)
{
_threadPool = new IceInternal.ThreadPool(_instance, _name + ".ThreadPool", 0);
@@ -1372,8 +1352,6 @@ public final class ObjectAdapterI implements ObjectAdapter
"ReplicaGroupId",
"Router",
"ProxyOptions",
- "ThreadPerConnection",
- "ThreadPerConnection.StackSize",
"ThreadPool.Size",
"ThreadPool.SizeMax",
"ThreadPool.SizeWarn",
@@ -1447,6 +1425,5 @@ public final class ObjectAdapterI implements ObjectAdapter
private boolean _destroying;
private boolean _destroyed;
private boolean _noConfig;
- private boolean _threadPerConnection;
private Identity _processId = null;
}