diff options
author | Mark Spruiell <mes@zeroc.com> | 2006-04-26 17:04:31 +0000 |
---|---|---|
committer | Mark Spruiell <mes@zeroc.com> | 2006-04-26 17:04:31 +0000 |
commit | 4b7ac6e8197a8e9e729d69fd04b75f327953943f (patch) | |
tree | eb07dc7faa9d7a1b6c09df90b796e8785d1284bb /java/src/IceSSL/ConnectorI.java | |
parent | more fixes for two-stage initialization (diff) | |
download | ice-4b7ac6e8197a8e9e729d69fd04b75f327953943f.tar.bz2 ice-4b7ac6e8197a8e9e729d69fd04b75f327953943f.tar.xz ice-4b7ac6e8197a8e9e729d69fd04b75f327953943f.zip |
refactoring to remove Context
Diffstat (limited to 'java/src/IceSSL/ConnectorI.java')
-rw-r--r-- | java/src/IceSSL/ConnectorI.java | 19 |
1 files changed, 12 insertions, 7 deletions
diff --git a/java/src/IceSSL/ConnectorI.java b/java/src/IceSSL/ConnectorI.java index cf197e1eb95..d7e8796f601 100644 --- a/java/src/IceSSL/ConnectorI.java +++ b/java/src/IceSSL/ConnectorI.java @@ -17,7 +17,12 @@ final class ConnectorI implements IceInternal.Connector // // The plugin may not be fully initialized. // - Context ctx = _instance.context(); + if(!_instance.initialized()) + { + Ice.PluginInitializationException ex = new Ice.PluginInitializationException(); + ex.reason = "IceSSL: plugin is not initialized"; + throw ex; + } if(_instance.networkTraceLevel() >= 2) { @@ -33,7 +38,7 @@ final class ConnectorI implements IceInternal.Connector // if(timeout >= 0) { - ConnectThread ct = new ConnectThread(ctx.sslContext(), _addr); + ConnectThread ct = new ConnectThread(_instance.context(), _addr); ct.start(); fd = ct.getFd(timeout == 0 ? 1 : timeout); if(fd == null) @@ -43,13 +48,13 @@ final class ConnectorI implements IceInternal.Connector } else { - javax.net.SocketFactory factory = ctx.sslContext().getSocketFactory(); + javax.net.SocketFactory factory = _instance.context().getSocketFactory(); fd = (javax.net.ssl.SSLSocket)factory.createSocket(_addr.getAddress(), _addr.getPort()); } fd.setUseClientMode(true); - String[] cipherSuites = ctx.filterCiphers(fd.getSupportedCipherSuites(), fd.getEnabledCipherSuites()); + String[] cipherSuites = _instance.filterCiphers(fd.getSupportedCipherSuites(), fd.getEnabledCipherSuites()); try { fd.setEnabledCipherSuites(cipherSuites); @@ -72,7 +77,7 @@ final class ConnectorI implements IceInternal.Connector _logger.trace(_instance.securityTraceCategory(), s.toString()); } - String[] protocols = ctx.getProtocols(); + String[] protocols = _instance.protocols(); if(protocols != null) { try @@ -125,7 +130,7 @@ final class ConnectorI implements IceInternal.Connector } } - if(!ctx.verifyPeer(fd, _host, false)) + if(!_instance.verifyPeer(fd, _host, false)) { Ice.SecurityException ex = new Ice.SecurityException(); ex.reason = "IceSSL: outgoing connection rejected by certificate verifier"; @@ -217,7 +222,7 @@ final class ConnectorI implements IceInternal.Connector if(_instance.securityTraceLevel() > 0) { - ctx.traceConnection(fd, false); + _instance.traceConnection(fd, false); } return new TransceiverI(_instance, fd); |