diff options
Diffstat (limited to 'java/src/IceInternal/IncomingConnectionFactory.java')
| -rw-r--r-- | java/src/IceInternal/IncomingConnectionFactory.java | 29 |
1 files changed, 19 insertions, 10 deletions
diff --git a/java/src/IceInternal/IncomingConnectionFactory.java b/java/src/IceInternal/IncomingConnectionFactory.java index 061e1c90b82..82862a9f79c 100644 --- a/java/src/IceInternal/IncomingConnectionFactory.java +++ b/java/src/IceInternal/IncomingConnectionFactory.java @@ -199,8 +199,7 @@ public class IncomingConnectionFactory extends EventHandler */ public - IncomingConnectionFactory(Instance instance, Endpoint endpoint, - Ice.ObjectAdapter adapter) + IncomingConnectionFactory(Instance instance, Endpoint endpoint, Ice.ObjectAdapter adapter) { super(instance); _endpoint = endpoint; @@ -213,6 +212,7 @@ public class IncomingConnectionFactory extends EventHandler _state = StateHolding; _warn = _instance.properties().getPropertyAsInt("Ice.ConnectionWarnings") > 0 ? true : false; _finished = false; + _registeredWithPool = false; try { @@ -358,12 +358,16 @@ public class IncomingConnectionFactory extends EventHandler { if (_acceptor != null) { - if (_serverThreadPool == null) - { - _serverThreadPool = _instance.serverThreadPool(); - assert(_serverThreadPool != null); - } - _serverThreadPool._register(_acceptor.fd(), this); + if (!_registeredWithPool) + { + if (_serverThreadPool == null) + { + _serverThreadPool = _instance.serverThreadPool(); + assert(_serverThreadPool != null); + } + _serverThreadPool._register(_acceptor.fd(), this); + _registeredWithPool = true; + } } } @@ -372,8 +376,12 @@ public class IncomingConnectionFactory extends EventHandler { if (_acceptor != null) { - assert(_serverThreadPool != null); - _serverThreadPool.unregister(_acceptor.fd()); + if (!_registeredWithPool) + { + assert(_serverThreadPool != null); + _serverThreadPool.unregister(_acceptor.fd()); + _registeredWithPool = true; + } } } @@ -397,4 +405,5 @@ public class IncomingConnectionFactory extends EventHandler private int _state; private boolean _warn; private boolean _finished; + private boolean _registeredWithPool; } |