jdk8-mips64-public/corba: src/share/classes/com/sun/corba/se/impl/orb/ORBDataParserImpl.java@bfd167e38830 (annotated)

src/share/classes/com/sun/corba/se/impl/orb/ORBDataParserImpl.java@bfd167e38830 (annotated)

src/share/classes/com/sun/corba/se/impl/orb/ORBDataParserImpl.java

Mon, 28 May 2018 10:29:43 +0800

author: aoqi
date: Mon, 28 May 2018 10:29:43 +0800
changeset 1655: bfd167e38830
parent 748: 6845b95cba6b
permissions: -rw-r--r--

Merge

 /*
  * 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.

Mercurial > jdk8-mips64-public > corba / annotate

src/share/classes/com/sun/corba/se/impl/orb/ORBDataParserImpl.java@bfd167e38830 (annotated)

src/share/classes/com/sun/corba/se/impl/orb/ORBDataParserImpl.java