--- src/org/jacorb/orb/iiop/IIOPProfile.java.orig 2006-07-11 14:16:46.000000000 -0400
+++ src/org/jacorb/orb/iiop/IIOPProfile.java 2007-06-01 10:41:14.000000000 -0400
@@ -1,515 +1,517 @@
-/*
- * JacORB - a free Java ORB
- *
- * Copyright (C) 1997-2004 Gerald Brose.
- *
- * This library is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Library General Public
- * License as published by the Free Software Foundation; either
- * version 2 of the License, or (at your option) any later version.
- *
- * This library is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Library General Public License for more details.
- *
- * You should have received a copy of the GNU Library General Public
- * License along with this library; if not, write to the Free
- * Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
- */
-package org.jacorb.orb.iiop;
-
-import java.util.*;
-
-import org.apache.avalon.framework.configuration.*;
-import org.apache.avalon.framework.logger.Logger;
-
-import org.jacorb.orb.CDRInputStream;
-import org.jacorb.orb.CDROutputStream;
-import org.jacorb.orb.TaggedComponentList;
-import org.jacorb.orb.etf.ProtocolAddressBase;
-
-import org.omg.ETF.*;
-import org.omg.IOP.*;
-import org.omg.SSLIOP.*;
-import org.omg.CORBA.INTERNAL;
-import org.omg.CSIIOP.*;
-
-/**
- * @author Andre Spiegel
- * @version $Id: IIOPProfile.java,v 1.26 2006/07/11 13:16:45 alphonse.bendt Exp $
- */
-public class IIOPProfile
- extends org.jacorb.orb.etf.ProfileBase implements Cloneable
-{
- private IIOPAddress primaryAddress = null;
- private Logger logger;
-
- public IIOPProfile()
- {
- super();
- }
-
- public IIOPProfile(byte[] data)
- {
- this();
-
- initFromProfileData(data);
- }
-
- public IIOPProfile(IIOPAddress address, byte[] objectKey, int minor)
- {
- this();
-
- this.version = new org.omg.GIOP.Version((byte)1,(byte)minor);
- this.primaryAddress = address;
- this.objectKey = objectKey;
- this.components = new TaggedComponentList();
- }
-
- public IIOPProfile(IIOPAddress address, byte[] objectKey)
- {
- this(address, objectKey, 2);
- }
-
- /**
- * Constructs an IIOPProfile from a corbaloc URL. Only to be used
- * from the corbaloc parser.
- */
- public IIOPProfile(String corbaloc)
- {
- this();
-
- this.version = null;
- this.primaryAddress = null;
- this.objectKey = null;
- this.components = null;
- this.corbalocStr = corbaloc;
- }
-
- public void configure(Configuration config)
- throws ConfigurationException
- {
- configuration = (org.jacorb.config.Configuration)config;
- logger = configuration.getNamedLogger("jacorb.iiop.profile");
- if (primaryAddress != null)
- {
- primaryAddress.configure(config);
- }
-
- if (corbalocStr != null)
- {
- try
- {
- decode_corbaloc(corbalocStr);
- }
- catch(Exception e)
- {
- logger.debug("unable to decode_corbaloc", e);
- }
- }
- }
-
- /**
- * An IPv6 corbaloc URL is of the format
- * corbaloc:iiop:[fe80:5443::3333%3]:2809/my_object
- * where the zone ID seperator is / or % depending on
- * what the underlying OS supports.
- *
- * This preserves compatilibility with TAO, and falls in
- * line with RFC 2732 and discussion on OMG news groups.
- */
- private void decode_corbaloc(final String address)
- {
- String addr = address;
- String host = "127.0.0.1"; //default to localhost
- short port = 2809; // default IIOP port
-
- int major = 1; // should be 1 by default. see 13.6.10.3
- int minor = 0; // should be 0 by default. see 13.6.10.3
-
- String errorstr =
- "Illegal IIOP protocol format in object address format: " + addr;
-
- int sep = addr.indexOf(':');
-
- String protocol_identifier = "";
- if( sep != 0)
- {
- protocol_identifier = addr.substring(0, sep);
- }
- if( sep + 1 == addr.length())
- {
- throw new IllegalArgumentException(errorstr);
- }
- addr = addr.substring(sep + 1);
- // decode optional version number
- sep = addr.indexOf( '@' );
- if( sep > -1)
- {
- String ver_str = addr.substring(0,sep);
- addr = addr.substring(sep+1);
- sep = ver_str.indexOf('.');
- if( sep != -1 )
- {
- try
- {
- major = Integer.parseInt(ver_str.substring(0,sep));
- minor = Integer.parseInt(ver_str.substring(sep+1));
- }
- catch( NumberFormatException nfe )
- {
- throw new IllegalArgumentException(errorstr);
- }
- }
- }
- version = new org.omg.GIOP.Version((byte)major,(byte)minor);
-
- int ipv6SeperatorStart = -1;
- int ipv6SeperatorEnd = -1;
- ipv6SeperatorStart = addr.indexOf('[');
- if (ipv6SeperatorStart != -1)
- {
- ipv6SeperatorEnd = addr.indexOf(']');
- if (ipv6SeperatorEnd == -1)
- {
- throw new IllegalArgumentException(errorstr);
- }
- }
-
- sep = addr.indexOf(':');
- if( sep != -1 )
- {
- if (ipv6SeperatorStart != -1) //IPv6
- {
- host=addr.substring(ipv6SeperatorStart + 1, ipv6SeperatorEnd);
- if (addr.charAt(ipv6SeperatorEnd+1) == ':')
- {
- port=(short)Integer.parseInt(addr.substring(ipv6SeperatorEnd+2));
- }
- else
- {
- throw new IllegalArgumentException(errorstr);
- }
- }
- else //IPv4 or hostname
- {
- try
- {
- port =(short)Integer.parseInt(addr.substring(sep+1));
- host = addr.substring(0, sep);
- }
- catch( NumberFormatException ill )
- {
- throw new IllegalArgumentException(errorstr);
- }
- }
- }
- primaryAddress = new IIOPAddress(host,port);
-
- try
- {
- primaryAddress.configure(configuration);
- }
- catch( ConfigurationException ce)
- {
- logger.warn("ConfigurationException", ce );
- }
- decode_extensions(protocol_identifier.toLowerCase());
- }
-
- private void decode_extensions(String ident)
- {
- this.components = new TaggedComponentList();
- if (ident.equals("ssliop"))
- {
- SSL ssl = new SSL();
- ssl.port = (short)primaryAddress.getPort();
- String propname =
- "jacorb.security.ssl.corbaloc_ssliop.supported_options";
- ssl.target_supports = get_ssl_options(propname);
- propname =
- "jacorb.security.ssl.corbaloc_ssliop.required_options";
- ssl.target_requires = get_ssl_options(propname);
-
- //create the tagged component containing the ssl struct
- final CDROutputStream out = new CDROutputStream();
- try
- {
- out.beginEncapsulatedArray();
- SSLHelper.write( out, ssl );
-
- // TAG_SSL_SEC_TRANS must be disambiguated in case OpenORB-generated
- // OMG classes are in the classpath.
- components.addComponent
- (new TaggedComponent( org.omg.SSLIOP.TAG_SSL_SEC_TRANS.value,
- out.getBufferCopy() )
- );
- }
- finally
- {
- out.close();
- }
- }
- }
-
- private short get_ssl_options(String propname)
- {
- //For the time being, we only use EstablishTrustInTarget,
- //because we don't handle any of the other options anyway.
- // So this makes a reasonable default.
-
- short value =
- (short)configuration.getAttributeAsInteger(propname,EstablishTrustInTarget.value);
- return value;
- }
-
-
- /**
- * Writes the bytes that would make up the ETF::AddressProfile bytes (new spec)
- * to a stream.
- * <p>
- * Writes GIOP version, host string, and port.
- */
- public void writeAddressProfile(CDROutputStream addressProfileStream)
- {
- org.omg.GIOP.VersionHelper.write( addressProfileStream, version);
- primaryAddress.write (addressProfileStream);
- }
-
- /**
- * Reads the bytes that make up the ETF::AddressProfile bytes (new spec)
- * from a stream.
- * <p>
- * Writes GIOP version, host string, and port.
- */
- public void readAddressProfile(CDRInputStream addressProfileStream)
- {
- this.version = org.omg.GIOP.VersionHelper.read(addressProfileStream);
- this.primaryAddress = IIOPAddress.read(addressProfileStream);
- if (configuration != null)
- {
- try
- {
- primaryAddress.configure(configuration);
- }
- catch( ConfigurationException ce)
- {
- logger.warn("ConfigurationException", ce );
- }
- }
- }
-
- /**
- * To improve the management of a large set of profile instances,
- * the author may provide a hash function using the data in a Profile
- * instance. The Profile shall always implement this function and either
- * return a hash number, or 0 (zero) if no hashing is supported.
- */
- public int hash()
- {
- return hashCode();
- }
-
- public Object clone() throws CloneNotSupportedException
- {
- IIOPProfile result = (IIOPProfile)super.clone(); // bitwise copy
-
- result.primaryAddress = new IIOPAddress(primaryAddress.getHostname(),
- primaryAddress.getPort());
-
- if (configuration != null)
- {
- try
- {
- result.primaryAddress.configure(configuration);
- }
- catch( ConfigurationException ce)
- {
- logger.warn("ConfigurationException", ce );
- }
- }
-
- result.version = new org.omg.GIOP.Version(this.version.major,
- this.version.minor);
-
- if (this.objectKey != null)
- {
- result.objectKey = new byte [this.objectKey.length];
- System.arraycopy(this.objectKey, 0, result.objectKey, 0,
- this.objectKey.length);
- }
-
- if (this.components != null)
- {
- result.components = (TaggedComponentList)this.components.clone();
- }
-
- return result;
- }
-
- /**
- * This function shall determine if the passed profile, prof, is a match
- * to this profile. The specifics of the match are left to the details
- * of the underlying transport, however profiles shall be considered a
- * match, if they would create connections that share the same attributes
- * relevant to the transport setup. Among others, this could include
- * address information (eg. host address) and transport layer
- * characteristics (eg. encryption levels). If a match is found, it
- * shall return true, or false otherwise.
- */
- public boolean is_match(Profile prof)
- {
- if (prof == null)
- {
- return false;
- }
-
- if (prof instanceof IIOPProfile)
- {
- IIOPProfile other = (IIOPProfile)prof;
- return
- (
- this.getSSLPort() == other.getSSLPort() &&
- this.primaryAddress.equals (other.primaryAddress) &&
- this.getAlternateAddresses().equals(other.getAlternateAddresses())
- );
- }
-
- return false;
- }
-
- public int tag()
- {
- return TAG_INTERNET_IOP.value;
- }
-
- public ProtocolAddressBase getAddress()
- {
- return primaryAddress;
- }
-
- /**
- * Replaces the host in this profile's primary address with newHost
- * (if it is not null), and the port with newPort (if it is not -1).
- */
- public void patchPrimaryAddress(ProtocolAddressBase replacement)
- {
- if (replacement instanceof IIOPAddress)
- {
- primaryAddress.replaceFrom((IIOPAddress)replacement);
- }
- }
-
- public List getAlternateAddresses()
- {
- return components.getComponents(TAG_ALTERNATE_IIOP_ADDRESS.value,
- IIOPAddress.class);
- }
-
- public SSL getSSL()
- {
- // TAG_SSL_SEC_TRANS must be disambiguated in case OpenORB-generated
- // OMG classes are in the classpath.
- return (SSL)components.getComponent( org.omg.SSLIOP.TAG_SSL_SEC_TRANS.value,
- SSLHelper.class );
- }
-
- /**
- * If there is a component tagged with TAG_CSI_SEC_MECH_LIST,
- * get the SSL port from this component. Return the SSL port in the
- * TAG_TLS_SEC_TRANS component encapsulated into the transport_mech
- * field of the first CompoundSecMech of the CSI_SEC_MECH_LIST.
- * Return -1 if there is no component tagged with TAG_CSI_SEC_MECH_LIST
- * or if this component specifies no SSL port.
- */
- public int getTLSPortFromCSIComponent()
- {
- CompoundSecMechList csmList =
- (CompoundSecMechList)components.getComponent(
- TAG_CSI_SEC_MECH_LIST.value,
- CompoundSecMechListHelper.class);
- if (csmList != null && csmList.mechanism_list.length > 0)
- {
- byte[] tlsSecTransData =
- csmList.mechanism_list[0].transport_mech.component_data;
- CDRInputStream in =
- new CDRInputStream((org.omg.CORBA.ORB)null, tlsSecTransData);
- try
- {
- in.openEncapsulatedArray();
- TLS_SEC_TRANS tls = TLS_SEC_TRANSHelper.read(in);
- if (tls.addresses.length > 0)
- {
- int ssl_port = tls.addresses[0].port;
- if (ssl_port != 0)
- {
- if (ssl_port < 0)
- {
- ssl_port += 65536;
- }
- return ssl_port;
- }
- }
- }
- catch ( Exception ex )
- {
- logger.debug("unexpected exception", ex);
- throw new INTERNAL(ex.toString());
- }
- }
- return -1;
-
- }
-
- /**
- * Returns the port on which SSL is available according to this profile,
- * or -1 if SSL is not supported.
- */
- public int getSSLPort()
- {
- SSL ssl = getSSL();
- if (ssl == null)
- {
- return getTLSPortFromCSIComponent();
- }
-
- int port = ssl.port;
- if (port < 0)
- {
- port += 65536;
- }
- return port;
- }
-
- /**
- * Returns a copy of this profile that is compatible with GIOP 1.0.
- */
- public IIOPProfile to_GIOP_1_0()
- {
- IIOPProfile result = new IIOPProfile(this.primaryAddress,
- this.objectKey);
- result.version.minor = 0;
- return result;
- }
-
- public boolean equals(Object other)
- {
- if (other instanceof org.omg.ETF.Profile)
- {
- return this.is_match((org.omg.ETF.Profile)other);
- }
-
- return false;
- }
-
- public int hashCode()
- {
- return primaryAddress.hashCode();
- }
-
- public String toString()
- {
- return primaryAddress.toString();
- }
-}
+/*
+ * JacORB - a free Java ORB
+ *
+ * Copyright (C) 1997-2004 Gerald Brose.
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Library General Public
+ * License as published by the Free Software Foundation; either
+ * version 2 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Library General Public License for more details.
+ *
+ * You should have received a copy of the GNU Library General Public
+ * License along with this library; if not, write to the Free
+ * Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+ */
+package org.jacorb.orb.iiop;
+
+import java.util.*;
+
+import org.apache.avalon.framework.configuration.*;
+import org.apache.avalon.framework.logger.Logger;
+
+import org.jacorb.orb.CDRInputStream;
+import org.jacorb.orb.CDROutputStream;
+import org.jacorb.orb.TaggedComponentList;
+import org.jacorb.orb.etf.ProtocolAddressBase;
+
+import org.omg.ETF.*;
+import org.omg.IOP.*;
+import org.omg.SSLIOP.*;
+import org.omg.CORBA.INTERNAL;
+import org.omg.CSIIOP.*;
+
+/**
+ * @author Andre Spiegel
+ * @version $Id: IIOPProfile.java,v 1.27 2007/06/01 02:27:13 francisco Exp $
+ */
+public class IIOPProfile
+ extends org.jacorb.orb.etf.ProfileBase implements Cloneable
+{
+ private IIOPAddress primaryAddress = null;
+ private Logger logger;
+
+ public IIOPProfile()
+ {
+ super();
+ }
+
+ public IIOPProfile(byte[] data)
+ {
+ this();
+
+ initFromProfileData(data);
+ }
+
+ public IIOPProfile(IIOPAddress address, byte[] objectKey, int minor)
+ {
+ this();
+
+ this.version = new org.omg.GIOP.Version((byte)1,(byte)minor);
+ this.primaryAddress = address;
+ this.objectKey = objectKey;
+ this.components = new TaggedComponentList();
+ }
+
+ public IIOPProfile(IIOPAddress address, byte[] objectKey)
+ {
+ this(address, objectKey, 2);
+ }
+
+ /**
+ * Constructs an IIOPProfile from a corbaloc URL. Only to be used
+ * from the corbaloc parser.
+ */
+ public IIOPProfile(String corbaloc)
+ {
+ this();
+
+ this.version = null;
+ this.primaryAddress = null;
+ this.objectKey = null;
+ this.components = null;
+ this.corbalocStr = corbaloc;
+ }
+
+ public void configure(Configuration config)
+ throws ConfigurationException
+ {
+ configuration = (org.jacorb.config.Configuration)config;
+ logger = configuration.getNamedLogger("jacorb.iiop.profile");
+ if (primaryAddress != null)
+ {
+ primaryAddress.configure(config);
+ }
+
+ if (corbalocStr != null)
+ {
+ try
+ {
+ decode_corbaloc(corbalocStr);
+ }
+ catch(Exception e)
+ {
+ logger.debug("unable to decode_corbaloc", e);
+ }
+ }
+ }
+
+ /**
+ * An IPv6 corbaloc URL is of the format
+ * corbaloc:iiop:[fe80:5443::3333%3]:2809/my_object
+ * where the zone ID seperator is / or % depending on
+ * what the underlying OS supports.
+ *
+ * This preserves compatilibility with TAO, and falls in
+ * line with RFC 2732 and discussion on OMG news groups.
+ */
+ private void decode_corbaloc(final String address)
+ {
+ String addr = address;
+ String host = "127.0.0.1"; //default to localhost
+ short port = 2809; // default IIOP port
+
+ int major = 1; // should be 1 by default. see 13.6.10.3
+ int minor = 0; // should be 0 by default. see 13.6.10.3
+
+ String errorstr =
+ "Illegal IIOP protocol format in object address format: " + addr;
+
+ int sep = addr.indexOf(':');
+
+ String protocol_identifier = "";
+ if( sep != 0)
+ {
+ protocol_identifier = addr.substring(0, sep);
+ }
+ if( sep + 1 == addr.length())
+ {
+ throw new IllegalArgumentException(errorstr);
+ }
+ addr = addr.substring(sep + 1);
+ // decode optional version number
+ sep = addr.indexOf( '@' );
+ if( sep > -1)
+ {
+ String ver_str = addr.substring(0,sep);
+ addr = addr.substring(sep+1);
+ sep = ver_str.indexOf('.');
+ if( sep != -1 )
+ {
+ try
+ {
+ major = Integer.parseInt(ver_str.substring(0,sep));
+ minor = Integer.parseInt(ver_str.substring(sep+1));
+ }
+ catch( NumberFormatException nfe )
+ {
+ throw new IllegalArgumentException(errorstr);
+ }
+ }
+ }
+ version = new org.omg.GIOP.Version((byte)major,(byte)minor);
+
+ int ipv6SeperatorStart = -1;
+ int ipv6SeperatorEnd = -1;
+ ipv6SeperatorStart = addr.indexOf('[');
+ if (ipv6SeperatorStart != -1)
+ {
+ ipv6SeperatorEnd = addr.indexOf(']');
+ if (ipv6SeperatorEnd == -1)
+ {
+ throw new IllegalArgumentException(errorstr);
+ }
+ }
+
+ sep = addr.indexOf(':');
+ if( sep != -1 )
+ {
+ if (ipv6SeperatorStart != -1) //IPv6
+ {
+ host=addr.substring(ipv6SeperatorStart + 1, ipv6SeperatorEnd);
+ if (addr.charAt(ipv6SeperatorEnd+1) == ':')
+ {
+ port=(short)Integer.parseInt(addr.substring(ipv6SeperatorEnd+2));
+ }
+ else
+ {
+ throw new IllegalArgumentException(errorstr);
+ }
+ }
+ else //IPv4 or hostname
+ {
+ try
+ {
+ port =(short)Integer.parseInt(addr.substring(sep+1));
+ host = addr.substring(0, sep);
+ }
+ catch( NumberFormatException ill )
+ {
+ throw new IllegalArgumentException(errorstr);
+ }
+ }
+ }
+ primaryAddress = new IIOPAddress(host,port);
+
+ try
+ {
+ primaryAddress.configure(configuration);
+ }
+ catch( ConfigurationException ce)
+ {
+ logger.warn("ConfigurationException", ce );
+ }
+ decode_extensions(protocol_identifier.toLowerCase());
+ }
+
+ private void decode_extensions(String ident)
+ {
+ this.components = new TaggedComponentList();
+ if (ident.equals("ssliop"))
+ {
+ SSL ssl = new SSL();
+ ssl.port = (short)primaryAddress.getPort();
+ String propname =
+ "jacorb.security.ssl.corbaloc_ssliop.supported_options";
+ ssl.target_supports = get_ssl_options(propname);
+ propname =
+ "jacorb.security.ssl.corbaloc_ssliop.required_options";
+ ssl.target_requires = get_ssl_options(propname);
+
+ //create the tagged component containing the ssl struct
+ final CDROutputStream out = new CDROutputStream();
+ try
+ {
+ out.beginEncapsulatedArray();
+ SSLHelper.write( out, ssl );
+
+ // TAG_SSL_SEC_TRANS must be disambiguated in case OpenORB-generated
+ // OMG classes are in the classpath.
+ components.addComponent
+ (new TaggedComponent( org.omg.SSLIOP.TAG_SSL_SEC_TRANS.value,
+ out.getBufferCopy() )
+ );
+ }
+ finally
+ {
+ out.close();
+ }
+ }
+ }
+
+ private short get_ssl_options(String propname)
+ {
+ //For the time being, we only use EstablishTrustInTarget,
+ //because we don't handle any of the other options anyway.
+ // So this makes a reasonable default.
+
+ short value =
+ (short)configuration.getAttributeAsInteger(propname,EstablishTrustInTarget.value);
+ return value;
+ }
+
+
+ /**
+ * Writes the bytes that would make up the ETF::AddressProfile bytes (new spec)
+ * to a stream.
+ * <p>
+ * Writes GIOP version, host string, and port.
+ */
+ public void writeAddressProfile(CDROutputStream addressProfileStream)
+ {
+ org.omg.GIOP.VersionHelper.write( addressProfileStream, version);
+ primaryAddress.write (addressProfileStream);
+ }
+
+ /**
+ * Reads the bytes that make up the ETF::AddressProfile bytes (new spec)
+ * from a stream.
+ * <p>
+ * Writes GIOP version, host string, and port.
+ */
+ public void readAddressProfile(CDRInputStream addressProfileStream)
+ {
+ this.version = org.omg.GIOP.VersionHelper.read(addressProfileStream);
+ this.primaryAddress = IIOPAddress.read(addressProfileStream);
+ if (configuration != null)
+ {
+ try
+ {
+ primaryAddress.configure(configuration);
+ }
+ catch( ConfigurationException ce)
+ {
+ logger.warn("ConfigurationException", ce );
+ }
+ }
+ }
+
+ /**
+ * To improve the management of a large set of profile instances,
+ * the author may provide a hash function using the data in a Profile
+ * instance. The Profile shall always implement this function and either
+ * return a hash number, or 0 (zero) if no hashing is supported.
+ */
+ public int hash()
+ {
+ return hashCode();
+ }
+
+ public Object clone() throws CloneNotSupportedException
+ {
+ IIOPProfile result = (IIOPProfile)super.clone(); // bitwise copy
+
+ result.primaryAddress = new IIOPAddress(primaryAddress.getHostname(),
+ primaryAddress.getPort());
+
+ if (configuration != null)
+ {
+ try
+ {
+ result.primaryAddress.configure(configuration);
+ }
+ catch( ConfigurationException ce)
+ {
+ logger.warn("ConfigurationException", ce );
+ }
+ }
+
+ result.version = new org.omg.GIOP.Version(this.version.major,
+ this.version.minor);
+
+ if (this.objectKey != null)
+ {
+ result.objectKey = new byte [this.objectKey.length];
+ System.arraycopy(this.objectKey, 0, result.objectKey, 0,
+ this.objectKey.length);
+ }
+
+ if (this.components != null)
+ {
+ result.components = (TaggedComponentList)this.components.clone();
+ }
+
+ return result;
+ }
+
+ /**
+ * This function shall determine if the passed profile, prof, is a match
+ * to this profile. The specifics of the match are left to the details
+ * of the underlying transport, however profiles shall be considered a
+ * match, if they would create connections that share the same attributes
+ * relevant to the transport setup. Among others, this could include
+ * address information (eg. host address) and transport layer
+ * characteristics (eg. encryption levels). If a match is found, it
+ * shall return true, or false otherwise.
+ */
+ public boolean is_match(Profile prof)
+ {
+ if (prof == null)
+ {
+ return false;
+ }
+
+ if (prof instanceof IIOPProfile)
+ {
+ IIOPProfile other = (IIOPProfile)prof;
+ return
+ (
+ this.getSSLPort() == other.getSSLPort() &&
+ this.primaryAddress.equals (other.primaryAddress) &&
+ this.getAlternateAddresses().equals(other.getAlternateAddresses())
+ );
+ }
+
+ return false;
+ }
+
+ public int tag()
+ {
+ return TAG_INTERNET_IOP.value;
+ }
+
+ public ProtocolAddressBase getAddress()
+ {
+ return primaryAddress;
+ }
+
+ /**
+ * Replaces the host in this profile's primary address with newHost
+ * (if it is not null), and the port with newPort (if it is not -1).
+ */
+ public void patchPrimaryAddress(ProtocolAddressBase replacement)
+ {
+ if (replacement instanceof IIOPAddress)
+ {
+ primaryAddress.replaceFrom((IIOPAddress)replacement);
+ }
+ }
+
+ public List getAlternateAddresses()
+ {
+ return components.getComponents(TAG_ALTERNATE_IIOP_ADDRESS.value,
+ IIOPAddress.class);
+ }
+
+ public SSL getSSL()
+ {
+ // TAG_SSL_SEC_TRANS must be disambiguated in case OpenORB-generated
+ // OMG classes are in the classpath.
+ return (SSL)components.getComponent( org.omg.SSLIOP.TAG_SSL_SEC_TRANS.value,
+ SSLHelper.class );
+ }
+
+ /**
+ * If there is a component tagged with TAG_CSI_SEC_MECH_LIST,
+ * get the SSL port from this component. Return the SSL port in the
+ * TAG_TLS_SEC_TRANS component encapsulated into the transport_mech
+ * field of the first CompoundSecMech of the CSI_SEC_MECH_LIST.
+ * Return -1 if there is no component tagged with TAG_CSI_SEC_MECH_LIST
+ * or if this component specifies no SSL port.
+ */
+ public int getTLSPortFromCSIComponent()
+ {
+ CompoundSecMechList csmList =
+ (CompoundSecMechList)components.getComponent(
+ TAG_CSI_SEC_MECH_LIST.value,
+ CompoundSecMechListHelper.class);
+ if (csmList != null && csmList.mechanism_list.length > 0 &&
+ csmList.mechanism_list[0].transport_mech.tag ==
+ TAG_TLS_SEC_TRANS.value)
+ {
+ byte[] tlsSecTransData =
+ csmList.mechanism_list[0].transport_mech.component_data;
+ CDRInputStream in =
+ new CDRInputStream((org.omg.CORBA.ORB)null, tlsSecTransData);
+ try
+ {
+ in.openEncapsulatedArray();
+ TLS_SEC_TRANS tls = TLS_SEC_TRANSHelper.read(in);
+ if (tls.addresses.length > 0)
+ {
+ int ssl_port = tls.addresses[0].port;
+ if (ssl_port != 0)
+ {
+ if (ssl_port < 0)
+ {
+ ssl_port += 65536;
+ }
+ return ssl_port;
+ }
+ }
+ }
+ catch ( Exception ex )
+ {
+ logger.debug("unexpected exception", ex);
+ throw new INTERNAL(ex.toString());
+ }
+ }
+ return -1;
+
+ }
+
+ /**
+ * Returns the port on which SSL is available according to this profile,
+ * or -1 if SSL is not supported.
+ */
+ public int getSSLPort()
+ {
+ SSL ssl = getSSL();
+ if (ssl == null)
+ {
+ return getTLSPortFromCSIComponent();
+ }
+
+ int port = ssl.port;
+ if (port < 0)
+ {
+ port += 65536;
+ }
+ return port;
+ }
+
+ /**
+ * Returns a copy of this profile that is compatible with GIOP 1.0.
+ */
+ public IIOPProfile to_GIOP_1_0()
+ {
+ IIOPProfile result = new IIOPProfile(this.primaryAddress,
+ this.objectKey);
+ result.version.minor = 0;
+ return result;
+ }
+
+ public boolean equals(Object other)
+ {
+ if (other instanceof org.omg.ETF.Profile)
+ {
+ return this.is_match((org.omg.ETF.Profile)other);
+ }
+
+ return false;
+ }
+
+ public int hashCode()
+ {
+ return primaryAddress.hashCode();
+ }
+
+ public String toString()
+ {
+ return primaryAddress.toString();
+ }
+}
