corba/src/share/classes/com/sun/corba/se/impl/orb/ORBDataParserImpl.java - edge/openjdk - Git at Google

 /*
  * Copyright (c) 2002, 2013, Oracle and/or its affiliates. All rights reserved.
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
  *
  * This code is free software; you can redistribute it and/or modify it
  * under the terms of the GNU General Public License version 2 only, as
  * published by the Free Software Foundation.  Oracle designates this
  * particular file as subject to the "Classpath" exception as provided
  * by Oracle in the LICENSE file that accompanied this code.
  *
  * This code 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 General Public License
  * version 2 for more details (a copy is included in the LICENSE file that
  * accompanied this code).
  *
  * You should have received a copy of the GNU General Public License version
  * 2 along with this work; if not, write to the Free Software Foundation,
  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
  *
  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
  * or visit www.oracle.com if you need additional information or have any
  * questions.
  */


 package com.sun.corba.se.impl.orb ;

 import java.net.URL ;

 import org.omg.CORBA.CompletionStatus ;
 import org.omg.PortableInterceptor.ORBInitializer ;

 import com.sun.corba.se.pept.transport.Acceptor;

 import com.sun.corba.se.spi.ior.iiop.GIOPVersion ;
 import com.sun.corba.se.spi.logging.CORBALogDomains ;
 import com.sun.corba.se.spi.orb.DataCollector ;
 import com.sun.corba.se.spi.orb.ORB ;
 import com.sun.corba.se.spi.orb.ORBData ;
 import com.sun.corba.se.spi.orb.ParserImplTableBase ;
 import com.sun.corba.se.spi.orb.StringPair ;
 import com.sun.corba.se.spi.transport.CorbaContactInfoListFactory;
 import com.sun.corba.se.spi.transport.CorbaTransportManager;
 import com.sun.corba.se.spi.transport.IORToSocketInfo;
 import com.sun.corba.se.spi.transport.IIOPPrimaryToContactInfo;
 import com.sun.corba.se.spi.transport.ReadTimeouts;

 import com.sun.corba.se.impl.encoding.CodeSetComponentInfo ;
 import com.sun.corba.se.impl.legacy.connection.USLPort;
 import com.sun.corba.se.impl.orbutil.ORBConstants ;
 import com.sun.corba.se.impl.logging.ORBUtilSystemException ;


 public class ORBDataParserImpl extends ParserImplTableBase implements ORBData
 {
     private ORB orb ;
     private ORBUtilSystemException wrapper ;
     private String ORBInitialHost ;
     private int ORBInitialPort ;
     private String ORBServerHost ;
     private int ORBServerPort ;
     private String listenOnAllInterfaces;
     private com.sun.corba.se.spi.legacy.connection.ORBSocketFactory legacySocketFactory ;
     private com.sun.corba.se.spi.transport.ORBSocketFactory socketFactory;
     private USLPort[] userSpecifiedListenPorts ;
     private IORToSocketInfo iorToSocketInfo;
     private IIOPPrimaryToContactInfo iiopPrimaryToContactInfo;
     private String orbId ;
     private boolean orbServerIdPropertySpecified ;
     private URL servicesURL ;
     private String propertyInitRef ;
     private boolean allowLocalOptimization ;
     private GIOPVersion giopVersion ;
     private int highWaterMark ;
     private int lowWaterMark ;
     private int numberToReclaim ;
     private int giopFragmentSize ;
     private int giopBufferSize ;
     private int giop11BuffMgr ;
     private int giop12BuffMgr ;
     private short giopTargetAddressPreference ;
     private short giopAddressDisposition ;
     private boolean useByteOrderMarkers ;
     private boolean useByteOrderMarkersInEncaps ;
     private boolean alwaysSendCodeSetCtx ;
     private boolean persistentPortInitialized ;
     private int persistentServerPort ;
     private boolean persistentServerIdInitialized ;
     private int persistentServerId ;
     private boolean serverIsORBActivated ;
     private Class badServerIdHandlerClass ;
     private CodeSetComponentInfo.CodeSetComponent charData ;
     private CodeSetComponentInfo.CodeSetComponent wcharData ;
     private ORBInitializer[] orbInitializers ;
     private StringPair[] orbInitialReferences ;
     private String defaultInitRef ;
     private String[] debugFlags ;
     private Acceptor[] acceptors;
     private CorbaContactInfoListFactory corbaContactInfoListFactory;
     private String acceptorSocketType;
     private boolean acceptorSocketUseSelectThreadToWait;
     private boolean acceptorSocketUseWorkerThreadForEvent;
     private String connectionSocketType;
     private boolean connectionSocketUseSelectThreadToWait;
     private boolean connectionSocketUseWorkerThreadForEvent;
     private ReadTimeouts readTimeouts;
     private boolean disableDirectByteBufferUse;
     private boolean enableJavaSerialization;
     private boolean useRepId;

     // This is not initialized from ParserTable.
     private CodeSetComponentInfo codesets ;

 // Public accessor methods ========================================================================

     public String getORBInitialHost()
     {
         return ORBInitialHost;
     }

     public int getORBInitialPort()
     {
         return ORBInitialPort;
     }

     public String getORBServerHost()
     {
         return ORBServerHost;
     }

     public String getListenOnAllInterfaces()
     {
         return listenOnAllInterfaces;
     }

     public int getORBServerPort()
     {
         return ORBServerPort;
     }

     public com.sun.corba.se.spi.legacy.connection.ORBSocketFactory getLegacySocketFactory()
     {
         return legacySocketFactory;
     }

     public com.sun.corba.se.spi.transport.ORBSocketFactory getSocketFactory()
     {
         return socketFactory;
     }

     public USLPort[] getUserSpecifiedListenPorts ()
     {
         return userSpecifiedListenPorts;
     }

     public IORToSocketInfo getIORToSocketInfo()
     {
         return iorToSocketInfo;
     }

     public IIOPPrimaryToContactInfo getIIOPPrimaryToContactInfo()
     {
         return iiopPrimaryToContactInfo;
     }

     public String getORBId()
     {
         return orbId;
     }

     public boolean getORBServerIdPropertySpecified()
     {
         return orbServerIdPropertySpecified;
     }

     public boolean isLocalOptimizationAllowed()
     {
         return allowLocalOptimization ;
     }

     public GIOPVersion getGIOPVersion()
     {
         return giopVersion;
     }

     public int getHighWaterMark()
     {
         return highWaterMark;
     }

     public int getLowWaterMark()
     {
         return lowWaterMark;
     }

     public int getNumberToReclaim()
     {
         return numberToReclaim;
     }

     public int getGIOPFragmentSize()
     {
         return giopFragmentSize;
     }

     public int getGIOPBufferSize()
     {
         return giopBufferSize;
     }

     public int getGIOPBuffMgrStrategy(GIOPVersion gv)
     {
         if(gv!=null){
             if (gv.equals(GIOPVersion.V1_0)) return 0; //Always grow for 1.0
             if (gv.equals(GIOPVersion.V1_1)) return giop11BuffMgr;
             if (gv.equals(GIOPVersion.V1_2)) return giop12BuffMgr;
         }
         //If a "faulty" GIOPVersion is passed, it's going to return 0;
         return 0;
     }

     /**
      * @return the GIOP Target Addressing preference of the ORB.
      * This ORB by default supports all addressing dispositions unless specified
      * otherwise via a java system property ORBConstants.GIOP_TARGET_ADDRESSING
      */
     public short getGIOPTargetAddressPreference()
     {
         return giopTargetAddressPreference;
     }

     public short getGIOPAddressDisposition()
     {
         return giopAddressDisposition;
     }

     public boolean useByteOrderMarkers()
     {
         return useByteOrderMarkers;
     }

     public boolean useByteOrderMarkersInEncapsulations()
     {
         return useByteOrderMarkersInEncaps;
     }

     public boolean alwaysSendCodeSetServiceContext()
     {
         return alwaysSendCodeSetCtx;
     }

     public boolean getPersistentPortInitialized()
     {
         return persistentPortInitialized ;
     }

     //public void setPersistentServerPort(int sp)
     //{
         //persistentServerPort = sp;
         //persistentPortInitialized = true;
     //}

     public int getPersistentServerPort()
     {
         if ( persistentPortInitialized ) // this is a user-activated server
             return persistentServerPort;
         else {
             throw wrapper.persistentServerportNotSet(
                 CompletionStatus.COMPLETED_MAYBE );
         }
     }

     public boolean getPersistentServerIdInitialized()
     {
         return persistentServerIdInitialized;
     }

     /** Set the persistent-server-id of this server. This id is the same
      *  across multiple activations of this server. The id can be set to any
      *  integer value other than 0. This id must be set before any persistent
      *  objects can be created.
      */
     //public void setPersistentServerId(int id)
     //{
         //persistentServerId = id;
         //persistentServerIdInitialized = true;
     //}

     /** Return the persistent-server-id of this server. This id is the same
      *  across multiple activations of this server. This is in contrast to
      *  com.sun.corba.se.impl.iiop.ORB.getTransientServerId() which
      *  returns a transient id that is guaranteed to be different
      *  across multiple activations of
      *  this server. The user/environment is required to supply the
      *  persistent-server-id every time this server is started, in
      *  the ORBServerId parameter, System properties, or other means.
      *  The user is also required to ensure that no two persistent servers
      *  on the same host have the same server-id.
      */
     public int getPersistentServerId()
     {
         if ( persistentServerIdInitialized ) {
             return persistentServerId;
         } else {
             throw wrapper.persistentServeridNotSet(
                 CompletionStatus.COMPLETED_MAYBE);
         }
     }

     public boolean getServerIsORBActivated()
     {
         return serverIsORBActivated ;
     }

     public Class getBadServerIdHandler()
     {
         return badServerIdHandlerClass ;
     }

      /**
      * Get the prefered code sets for connections. Should the client send the code set service context on every
      * request?
      */
     public CodeSetComponentInfo getCodeSetComponentInfo()
     {
         return codesets;
     }

     public ORBInitializer[] getORBInitializers()
     {
         return orbInitializers ;
     }

     public StringPair[] getORBInitialReferences()
     {
         return orbInitialReferences ;
     }

     public String getORBDefaultInitialReference()
     {
         return defaultInitRef ;
     }

     public String[] getORBDebugFlags()
     {
         return debugFlags ;
     }

     public Acceptor[] getAcceptors()
     {
         return acceptors;
     }

     public CorbaContactInfoListFactory getCorbaContactInfoListFactory()
     {
         return corbaContactInfoListFactory;
     }

     public String acceptorSocketType()
     {
         return acceptorSocketType;
     }
     public boolean acceptorSocketUseSelectThreadToWait()
     {
         return acceptorSocketUseSelectThreadToWait;
     }
     public boolean acceptorSocketUseWorkerThreadForEvent()
     {
         return acceptorSocketUseWorkerThreadForEvent;
     }
     public String connectionSocketType()
     {
         return connectionSocketType;
     }
     public boolean connectionSocketUseSelectThreadToWait()
     {
         return connectionSocketUseSelectThreadToWait;
     }
     public boolean connectionSocketUseWorkerThreadForEvent()
     {
         return connectionSocketUseWorkerThreadForEvent;
     }
     public boolean isJavaSerializationEnabled()
     {
         return enableJavaSerialization;
     }
     public ReadTimeouts getTransportTCPReadTimeouts()
     {
         return readTimeouts;
     }
     public boolean disableDirectByteBufferUse()
     {
         return disableDirectByteBufferUse ;
     }
     public boolean useRepId()
     {
         return useRepId;
     }

 // Methods for constructing and initializing this object ===========================================

     public ORBDataParserImpl( ORB orb, DataCollector coll )
     {
         super( ParserTable.get().getParserData() ) ;
         this.orb = orb ;
         wrapper = ORBUtilSystemException.get( orb, CORBALogDomains.ORB_LIFECYCLE ) ;
         init( coll ) ;
         complete() ;
     }

     public void complete()
     {
         codesets = new CodeSetComponentInfo(charData, wcharData);
     }
 }

 // End of file.
	/*
	* Copyright (c) 2002, 2013, Oracle and/or its affiliates. All rights reserved.
	* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
	*
	* This code is free software; you can redistribute it and/or modify it
	* under the terms of the GNU General Public License version 2 only, as
	* published by the Free Software Foundation. Oracle designates this
	* particular file as subject to the "Classpath" exception as provided
	* by Oracle in the LICENSE file that accompanied this code.
	*
	* This code 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 General Public License
	* version 2 for more details (a copy is included in the LICENSE file that
	* accompanied this code).
	*
	* You should have received a copy of the GNU General Public License version
	* 2 along with this work; if not, write to the Free Software Foundation,
	* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
	*
	* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
	* or visit www.oracle.com if you need additional information or have any
	* questions.
	*/


	package com.sun.corba.se.impl.orb ;

	import java.net.URL ;

	import org.omg.CORBA.CompletionStatus ;
	import org.omg.PortableInterceptor.ORBInitializer ;

	import com.sun.corba.se.pept.transport.Acceptor;

	import com.sun.corba.se.spi.ior.iiop.GIOPVersion ;
	import com.sun.corba.se.spi.logging.CORBALogDomains ;
	import com.sun.corba.se.spi.orb.DataCollector ;
	import com.sun.corba.se.spi.orb.ORB ;
	import com.sun.corba.se.spi.orb.ORBData ;
	import com.sun.corba.se.spi.orb.ParserImplTableBase ;
	import com.sun.corba.se.spi.orb.StringPair ;
	import com.sun.corba.se.spi.transport.CorbaContactInfoListFactory;
	import com.sun.corba.se.spi.transport.CorbaTransportManager;
	import com.sun.corba.se.spi.transport.IORToSocketInfo;
	import com.sun.corba.se.spi.transport.IIOPPrimaryToContactInfo;
	import com.sun.corba.se.spi.transport.ReadTimeouts;

	import com.sun.corba.se.impl.encoding.CodeSetComponentInfo ;
	import com.sun.corba.se.impl.legacy.connection.USLPort;
	import com.sun.corba.se.impl.orbutil.ORBConstants ;
	import com.sun.corba.se.impl.logging.ORBUtilSystemException ;


	public class ORBDataParserImpl extends ParserImplTableBase implements ORBData
	{
	private ORB orb ;
	private ORBUtilSystemException wrapper ;
	private String ORBInitialHost ;
	private int ORBInitialPort ;
	private String ORBServerHost ;
	private int ORBServerPort ;
	private String listenOnAllInterfaces;
	private com.sun.corba.se.spi.legacy.connection.ORBSocketFactory legacySocketFactory ;
	private com.sun.corba.se.spi.transport.ORBSocketFactory socketFactory;
	private USLPort[] userSpecifiedListenPorts ;
	private IORToSocketInfo iorToSocketInfo;
	private IIOPPrimaryToContactInfo iiopPrimaryToContactInfo;
	private String orbId ;
	private boolean orbServerIdPropertySpecified ;
	private URL servicesURL ;
	private String propertyInitRef ;
	private boolean allowLocalOptimization ;
	private GIOPVersion giopVersion ;
	private int highWaterMark ;
	private int lowWaterMark ;
	private int numberToReclaim ;
	private int giopFragmentSize ;
	private int giopBufferSize ;
	private int giop11BuffMgr ;
	private int giop12BuffMgr ;
	private short giopTargetAddressPreference ;
	private short giopAddressDisposition ;
	private boolean useByteOrderMarkers ;
	private boolean useByteOrderMarkersInEncaps ;
	private boolean alwaysSendCodeSetCtx ;
	private boolean persistentPortInitialized ;
	private int persistentServerPort ;
	private boolean persistentServerIdInitialized ;
	private int persistentServerId ;
	private boolean serverIsORBActivated ;
	private Class badServerIdHandlerClass ;
	private CodeSetComponentInfo.CodeSetComponent charData ;
	private CodeSetComponentInfo.CodeSetComponent wcharData ;
	private ORBInitializer[] orbInitializers ;
	private StringPair[] orbInitialReferences ;
	private String defaultInitRef ;
	private String[] debugFlags ;
	private Acceptor[] acceptors;
	private CorbaContactInfoListFactory corbaContactInfoListFactory;
	private String acceptorSocketType;
	private boolean acceptorSocketUseSelectThreadToWait;
	private boolean acceptorSocketUseWorkerThreadForEvent;
	private String connectionSocketType;
	private boolean connectionSocketUseSelectThreadToWait;
	private boolean connectionSocketUseWorkerThreadForEvent;
	private ReadTimeouts readTimeouts;
	private boolean disableDirectByteBufferUse;
	private boolean enableJavaSerialization;
	private boolean useRepId;

	// This is not initialized from ParserTable.
	private CodeSetComponentInfo codesets ;

	// Public accessor methods ========================================================================

	public String getORBInitialHost()
	{
	return ORBInitialHost;
	}

	public int getORBInitialPort()
	{
	return ORBInitialPort;
	}

	public String getORBServerHost()
	{
	return ORBServerHost;
	}

	public String getListenOnAllInterfaces()
	{
	return listenOnAllInterfaces;
	}

	public int getORBServerPort()
	{
	return ORBServerPort;
	}

	public com.sun.corba.se.spi.legacy.connection.ORBSocketFactory getLegacySocketFactory()
	{
	return legacySocketFactory;
	}

	public com.sun.corba.se.spi.transport.ORBSocketFactory getSocketFactory()
	{
	return socketFactory;
	}

	public USLPort[] getUserSpecifiedListenPorts ()
	{
	return userSpecifiedListenPorts;
	}

	public IORToSocketInfo getIORToSocketInfo()
	{
	return iorToSocketInfo;
	}

	public IIOPPrimaryToContactInfo getIIOPPrimaryToContactInfo()
	{
	return iiopPrimaryToContactInfo;
	}

	public String getORBId()
	{
	return orbId;
	}

	public boolean getORBServerIdPropertySpecified()
	{
	return orbServerIdPropertySpecified;
	}

	public boolean isLocalOptimizationAllowed()
	{
	return allowLocalOptimization ;
	}

	public GIOPVersion getGIOPVersion()
	{
	return giopVersion;
	}

	public int getHighWaterMark()
	{
	return highWaterMark;
	}

	public int getLowWaterMark()
	{
	return lowWaterMark;
	}

	public int getNumberToReclaim()
	{
	return numberToReclaim;
	}

	public int getGIOPFragmentSize()
	{
	return giopFragmentSize;
	}

	public int getGIOPBufferSize()
	{
	return giopBufferSize;
	}

	public int getGIOPBuffMgrStrategy(GIOPVersion gv)
	{
	if(gv!=null){
	if (gv.equals(GIOPVersion.V1_0)) return 0; //Always grow for 1.0
	if (gv.equals(GIOPVersion.V1_1)) return giop11BuffMgr;
	if (gv.equals(GIOPVersion.V1_2)) return giop12BuffMgr;
	}
	//If a "faulty" GIOPVersion is passed, it's going to return 0;
	return 0;
	}

	/**
	* @return the GIOP Target Addressing preference of the ORB.
	* This ORB by default supports all addressing dispositions unless specified
	* otherwise via a java system property ORBConstants.GIOP_TARGET_ADDRESSING
	*/
	public short getGIOPTargetAddressPreference()
	{
	return giopTargetAddressPreference;
	}

	public short getGIOPAddressDisposition()
	{
	return giopAddressDisposition;
	}

	public boolean useByteOrderMarkers()
	{
	return useByteOrderMarkers;
	}

	public boolean useByteOrderMarkersInEncapsulations()
	{
	return useByteOrderMarkersInEncaps;
	}

	public boolean alwaysSendCodeSetServiceContext()
	{
	return alwaysSendCodeSetCtx;
	}

	public boolean getPersistentPortInitialized()
	{
	return persistentPortInitialized ;
	}

	//public void setPersistentServerPort(int sp)
	//{
	//persistentServerPort = sp;
	//persistentPortInitialized = true;
	//}

	public int getPersistentServerPort()
	{
	if ( persistentPortInitialized ) // this is a user-activated server
	return persistentServerPort;
	else {
	throw wrapper.persistentServerportNotSet(
	CompletionStatus.COMPLETED_MAYBE );
	}
	}

	public boolean getPersistentServerIdInitialized()
	{
	return persistentServerIdInitialized;
	}

	/** Set the persistent-server-id of this server. This id is the same
	* across multiple activations of this server. The id can be set to any
	* integer value other than 0. This id must be set before any persistent
	* objects can be created.
	*/
	//public void setPersistentServerId(int id)
	//{
	//persistentServerId = id;
	//persistentServerIdInitialized = true;
	//}

	/** Return the persistent-server-id of this server. This id is the same
	* across multiple activations of this server. This is in contrast to
	* com.sun.corba.se.impl.iiop.ORB.getTransientServerId() which
	* returns a transient id that is guaranteed to be different
	* across multiple activations of
	* this server. The user/environment is required to supply the
	* persistent-server-id every time this server is started, in
	* the ORBServerId parameter, System properties, or other means.
	* The user is also required to ensure that no two persistent servers
	* on the same host have the same server-id.
	*/
	public int getPersistentServerId()
	{
	if ( persistentServerIdInitialized ) {
	return persistentServerId;
	} else {
	throw wrapper.persistentServeridNotSet(
	CompletionStatus.COMPLETED_MAYBE);
	}
	}

	public boolean getServerIsORBActivated()
	{
	return serverIsORBActivated ;
	}

	public Class getBadServerIdHandler()
	{
	return badServerIdHandlerClass ;
	}

	/**
	* Get the prefered code sets for connections. Should the client send the code set service context on every
	* request?
	*/
	public CodeSetComponentInfo getCodeSetComponentInfo()
	{
	return codesets;
	}

	public ORBInitializer[] getORBInitializers()
	{
	return orbInitializers ;
	}

	public StringPair[] getORBInitialReferences()
	{
	return orbInitialReferences ;
	}

	public String getORBDefaultInitialReference()
	{
	return defaultInitRef ;
	}

	public String[] getORBDebugFlags()
	{
	return debugFlags ;
	}

	public Acceptor[] getAcceptors()
	{
	return acceptors;
	}

	public CorbaContactInfoListFactory getCorbaContactInfoListFactory()
	{
	return corbaContactInfoListFactory;
	}

	public String acceptorSocketType()
	{
	return acceptorSocketType;
	}
	public boolean acceptorSocketUseSelectThreadToWait()
	{
	return acceptorSocketUseSelectThreadToWait;
	}
	public boolean acceptorSocketUseWorkerThreadForEvent()
	{
	return acceptorSocketUseWorkerThreadForEvent;
	}
	public String connectionSocketType()
	{
	return connectionSocketType;
	}
	public boolean connectionSocketUseSelectThreadToWait()
	{
	return connectionSocketUseSelectThreadToWait;
	}
	public boolean connectionSocketUseWorkerThreadForEvent()
	{
	return connectionSocketUseWorkerThreadForEvent;
	}
	public boolean isJavaSerializationEnabled()
	{
	return enableJavaSerialization;
	}
	public ReadTimeouts getTransportTCPReadTimeouts()
	{
	return readTimeouts;
	}
	public boolean disableDirectByteBufferUse()
	{
	return disableDirectByteBufferUse ;
	}
	public boolean useRepId()
	{
	return useRepId;
	}

	// Methods for constructing and initializing this object ===========================================

	public ORBDataParserImpl( ORB orb, DataCollector coll )
	{
	super( ParserTable.get().getParserData() ) ;
	this.orb = orb ;
	wrapper = ORBUtilSystemException.get( orb, CORBALogDomains.ORB_LIFECYCLE ) ;
	init( coll ) ;
	complete() ;
	}

	public void complete()
	{
	codesets = new CodeSetComponentInfo(charData, wcharData);
	}
	}

	// End of file.