summaryrefslogtreecommitdiff
path: root/java/src/IceSSL/ConnectorI.java
diff options
context:
space:
mode:
authorMark Spruiell <mes@zeroc.com>2006-04-26 17:04:31 +0000
committerMark Spruiell <mes@zeroc.com>2006-04-26 17:04:31 +0000
commit4b7ac6e8197a8e9e729d69fd04b75f327953943f (patch)
treeeb07dc7faa9d7a1b6c09df90b796e8785d1284bb /java/src/IceSSL/ConnectorI.java
parentmore fixes for two-stage initialization (diff)
downloadice-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.java19
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);