Java 类org.omg.CORBA.INITIALIZE 实例源码

public es.tid.TIDorbj.core.poa.POAImpl initPOA() {
    synchronized (this) {
        if (m_root_POA == null) {
            m_root_POA = 
                es.tid.TIDorbj.core.poa.POAImpl.createRootPOA(this);


            // init the orb listening points (usually one for each layer)
            try {
                this.communicationManager.setServerModeEnabled( true );
            } catch ( CommunicationException ce ) {
                throw new INITIALIZE( "Unable to activate server mode: " + ce.getMessage() );
            }

            m_state.running();
        }
    }

    return m_root_POA;
}

protected es.tid.TIDorbj.dynAny.DynAnyFactoryImpl initDynAnyFactory()
{
    synchronized (this) {
        if (m_dyn_factory == null) {
            try {
                m_dyn_factory = 
                    new es.tid.TIDorbj.dynAny.DynAnyFactoryImpl();
                m_dyn_factory.set_orb(this);
            }
            catch (Throwable th) {
                throw new INITIALIZE("Cannot Initialize DynAnyFactory", 0,
                                     CompletionStatus.COMPLETED_NO);
            }
        }
    }
    return m_dyn_factory;
}

/**
 * Parse the ORB nominal Bidirectional Policy.
 * 
 * @param str
 *            the policy value.
 * @pre Values must be "NORMAL", "BOTH".
 * @exception org.omg.CORBA.INITIALIZE
 *                if the string does not contains a valid value.
 */
//TODO: remove iiop, this is por ORB's policy manager...
public void parse_bidirectional(String str)
{
    if (str == null)
        return;

    short value = 0;

    if (str.equals("NORMAL")) {
        return;
    } else if (str.equals("BOTH")) {
        try {
            policy_context.setPolicy(
               new BidirectionalPolicyImpl(org.omg.BiDirPolicy.BOTH.value));
        }
        catch (PolicyError pe) {}
    } else {
        throw new org.omg.CORBA.INITIALIZE("Invalid value"
                                           + bidirectional_name 
                                           + "=" + str);
    }
}

/**
 * Parse the max_blocked_time value.
 * 
 * @param str
 *            the value digits.
 * @pre Values must be >= 0.
 * @exception org.omg.CORBA.INITIALIZE
 *                if the string does not contains a valid value.
 */
public void parse_max_blocked_time(String str)
{
    if (str == null)
        return;

    long value = parse_long(max_blocked_time_name, str);

    if (value < 0)
        throw new INITIALIZE(max_blocked_time_name + ":invalid value "
                             + value + " (minimum blocked 0)");

    if (value != DEFAULT_MAX_BLOCKED_TIME) {
        // converts to TimeT (from ms to units of 100 ns)
        value = UTC.toTimeT(value);
        try {
            policy_context.setPolicy(
                new RelativeRoundtripTimeoutPolicyImpl(value));
        }
        catch (PolicyError pe) {}
        max_blocked_time = value;
    }

}

/**
 * Constructs a new TransientNameService, and creates an initial
 * NamingContext, whose object
 * reference can be obtained by the initialNamingContext method.
 * @param orb The ORB object
 * @exception org.omg.CORBA.INITIALIZE Thrown if
 * the TransientNameService cannot initialize.
 */
public TransientNameService(com.sun.corba.se.spi.orb.ORB orb )
    throws org.omg.CORBA.INITIALIZE
{
    // Default constructor uses "NameService" as the key for the Root Naming
    // Context. If default constructor is used then INS's object key for
    // Transient Name Service is "NameService"
    initialize( orb, "NameService" );
}

public INITIALIZE cannotCreateOrbidDb( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( CANNOT_CREATE_ORBID_DB, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "ORBUTIL.cannotCreateOrbidDb",
            parameters, ORBUtilSystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE cannotReadOrbidDb( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( CANNOT_READ_ORBID_DB, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "ORBUTIL.cannotReadOrbidDb",
            parameters, ORBUtilSystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE cannotWriteOrbidDb( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( CANNOT_WRITE_ORBID_DB, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "ORBUTIL.cannotWriteOrbidDb",
            parameters, ORBUtilSystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE getServerPortCalledBeforeEndpointsInitialized( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( GET_SERVER_PORT_CALLED_BEFORE_ENDPOINTS_INITIALIZED, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "ORBUTIL.getServerPortCalledBeforeEndpointsInitialized",
            parameters, ORBUtilSystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE persistentServerportNotSet( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( PERSISTENT_SERVERPORT_NOT_SET, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "ORBUTIL.persistentServerportNotSet",
            parameters, ORBUtilSystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE persistentServeridNotSet( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( PERSISTENT_SERVERID_NOT_SET, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "ORBUTIL.persistentServeridNotSet",
            parameters, ORBUtilSystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE transNsCannotCreateInitialNcSys( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( TRANS_NS_CANNOT_CREATE_INITIAL_NC_SYS, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "NAMING.transNsCannotCreateInitialNcSys",
            parameters, NamingSystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE transNsCannotCreateInitialNc( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( TRANS_NS_CANNOT_CREATE_INITIAL_NC, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "NAMING.transNsCannotCreateInitialNc",
            parameters, NamingSystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE jtsInitError( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( JTS_INIT_ERROR, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "POA.jtsInitError",
            parameters, POASystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE persistentServeridNotSet( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( PERSISTENT_SERVERID_NOT_SET, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "POA.persistentServeridNotSet",
            parameters, POASystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE persistentServerportNotSet( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( PERSISTENT_SERVERPORT_NOT_SET, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "POA.persistentServerportNotSet",
            parameters, POASystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE orbdError( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( ORBD_ERROR, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "POA.orbdError",
            parameters, POASystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE bootstrapError( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( BOOTSTRAP_ERROR, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "POA.bootstrapError",
            parameters, POASystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE cannotReadRepositoryDb( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( CANNOT_READ_REPOSITORY_DB, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "ACTIVATION.cannotReadRepositoryDb",
            parameters, ActivationSystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE cannotAddInitialNaming( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( CANNOT_ADD_INITIAL_NAMING, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "ACTIVATION.cannotAddInitialNaming",
            parameters, ActivationSystemException.class, exc ) ;
    }

    return exc ;
}

public INITIALIZE priorityRangeRestrict( CompletionStatus cs, Throwable t ) {
    INITIALIZE exc = new INITIALIZE( PRIORITY_RANGE_RESTRICT, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

    if (logger.isLoggable( Level.WARNING )) {
        Object[] parameters = null ;
        doLog( Level.WARNING, "OMG.priorityRangeRestrict",
            parameters, OMGSystemException.class, exc ) ;
    }

    return exc ;
}

/**
 * Constructs a new TransientNameService, and creates an initial
 * NamingContext, whose object
 * reference can be obtained by the initialNamingContext method.
 * @param orb The ORB object
 * @exception org.omg.CORBA.INITIALIZE Thrown if
 * the TransientNameService cannot initialize.
 */
public TransientNameService(com.sun.corba.se.spi.orb.ORB orb )
    throws org.omg.CORBA.INITIALIZE
{
    // Default constructor uses "NameService" as the key for the Root Naming
    // Context. If default constructor is used then INS's object key for
    // Transient Name Service is "NameService"
    initialize( orb, "NameService" );
}

/**
 * Constructs a new TransientNameService, and creates an initial
 * NamingContext, whose object
 * reference can be obtained by the initialNamingContext method.
 * @param orb The ORB object
 * @exception org.omg.CORBA.INITIALIZE Thrown if
 * the TransientNameService cannot initialize.
 */
public TransientNameService(com.sun.corba.se.spi.orb.ORB orb )
    throws org.omg.CORBA.INITIALIZE
{
    // Default constructor uses "NameService" as the key for the Root Naming
    // Context. If default constructor is used then INS's object key for
    // Transient Name Service is "NameService"
    initialize( orb, "NameService" );
}

/**
 * Constructs a new TransientNameService, and creates an initial
 * NamingContext, whose object
 * reference can be obtained by the initialNamingContext method.
 * @param orb The ORB object
 * @exception org.omg.CORBA.INITIALIZE Thrown if
 * the TransientNameService cannot initialize.
 */
public TransientNameService(com.sun.corba.se.spi.orb.ORB orb )
    throws org.omg.CORBA.INITIALIZE
{
    // Default constructor uses "NameService" as the key for the Root Naming
    // Context. If default constructor is used then INS's object key for
    // Transient Name Service is "NameService"
    initialize( orb, "NameService" );
}

/**
 * Constructs a new TransientNameService, and creates an initial
 * NamingContext, whose object
 * reference can be obtained by the initialNamingContext method.
 * @param orb The ORB object
 * @exception org.omg.CORBA.INITIALIZE Thrown if
 * the TransientNameService cannot initialize.
 */
public TransientNameService(com.sun.corba.se.spi.orb.ORB orb )
    throws org.omg.CORBA.INITIALIZE
{
    // Default constructor uses "NameService" as the key for the Root Naming
    // Context. If default constructor is used then INS's object key for
    // Transient Name Service is "NameService"
    initialize( orb, "NameService" );
}

/**
 * Constructs a new TransientNameService, and creates an initial
 * NamingContext, whose object
 * reference can be obtained by the initialNamingContext method.
 * @param orb The ORB object
 * @exception org.omg.CORBA.INITIALIZE Thrown if
 * the TransientNameService cannot initialize.
 */
public TransientNameService(com.sun.corba.se.spi.orb.ORB orb )
    throws org.omg.CORBA.INITIALIZE
{
    // Default constructor uses "NameService" as the key for the Root Naming
    // Context. If default constructor is used then INS's object key for
    // Transient Name Service is "NameService"
    initialize( orb, "NameService" );
}

/**
 * Constructs a new TransientNameService, and creates an initial
 * NamingContext, whose object
 * reference can be obtained by the initialNamingContext method.
 * @param orb The ORB object
 * @exception org.omg.CORBA.INITIALIZE Thrown if
 * the TransientNameService cannot initialize.
 */
public TransientNameService(com.sun.corba.se.spi.orb.ORB orb )
    throws org.omg.CORBA.INITIALIZE
{
    // Default constructor uses "NameService" as the key for the Root Naming
    // Context. If default constructor is used then INS's object key for
    // Transient Name Service is "NameService"
    initialize( orb, "NameService" );
}

/**
 * Constructs a new TransientNameService, and creates an initial
 * NamingContext, whose object
 * reference can be obtained by the initialNamingContext method.
 * @param orb The ORB object
 * @exception org.omg.CORBA.INITIALIZE Thrown if
 * the TransientNameService cannot initialize.
 */
public TransientNameService(com.sun.corba.se.spi.orb.ORB orb )
    throws org.omg.CORBA.INITIALIZE
{
    // Default constructor uses "NameService" as the key for the Root Naming
    // Context. If default constructor is used then INS's object key for
    // Transient Name Service is "NameService"
    initialize( orb, "NameService" );
}

/**
 * Constructs a new TransientNameService, and creates an initial
 * NamingContext, whose object
 * reference can be obtained by the initialNamingContext method.
 * @param orb The ORB object
 * @exception org.omg.CORBA.INITIALIZE Thrown if
 * the TransientNameService cannot initialize.
 */
public TransientNameService(com.sun.corba.se.spi.orb.ORB orb )
    throws org.omg.CORBA.INITIALIZE
{
    // Default constructor uses "NameService" as the key for the Root Naming
    // Context. If default constructor is used then INS's object key for
    // Transient Name Service is "NameService"
    initialize( orb, "NameService" );
}

/**
 * Constructs a new TransientNameService, and creates an initial
 * NamingContext, whose object
 * reference can be obtained by the initialNamingContext method.
 * @param orb The ORB object
 * @exception org.omg.CORBA.INITIALIZE Thrown if
 * the TransientNameService cannot initialize.
 */
public TransientNameService(com.sun.corba.se.spi.orb.ORB orb )
    throws org.omg.CORBA.INITIALIZE
{
    // Default constructor uses "NameService" as the key for the Root Naming
    // Context. If default constructor is used then INS's object key for
    // Transient Name Service is "NameService"
    initialize( orb, "NameService" );
}

/**
 * Parse the block_size value.
 * 
 * @param str
 *            the value digits.
 * @pre Values must be > 256 and multiple of 8.
 * @exception org.omg.CORBA.INITIALIZE
 *                if the string does not contains a valid value.
 */
public void parse_block_size(String str)
{
    if (str == null)
        return;

    int value = parse_int(block_size_name, str);

    if ((value < 256) || (value % CDR.LONG_SIZE != 0))
        throw new INITIALIZE(block_size_name + ":invalid value " + value
                             + " (minimum fragment size: 256)");

    block_size = value;
}

/**
 * Parse the typecode_cache_size value.
 * 
 * @param str
 *            the value digits.
 * @pre Value must be > 1024 and multiple of 8.
 * @exception org.omg.CORBA.INITIALIZE
 *                if the string does not contains a valid value.
 */
public void parse_typecode_cache_size(String str)
{
    if (str == null)
        return;

    int value = parse_int(typecode_cache_size_name, str);

    if (value < 0)
        throw new INITIALIZE(typecode_cache_size_name + ": invalid value "
                             + value + " (fragment size must be > 0)");

    typecode_cache_size = value;

}

/**
 * Parse the poa_max_threads value.
 * 
 * @param str
 *            the value digits.
 * @pre Values must be > 0.
 * @exception org.omg.CORBA.INITIALIZE
 *                if the string does not contains a valid value.
 */
public void parse_poa_max_threads(String str)
{
    if (str == null)
        return;

    int value = parse_int(poa_max_threads_name, str);

    if (value < 1)
        throw new INITIALIZE(poa_max_threads_name + ":invalid value "
                             + value + " (minimum 1)");

    poa_max_threads = value;

}

/**
 * Parse the poa_min_threads value.
 * 
 * @param str
 *            the value digits.
 * @pre Values must be >= 0.
 * @exception org.omg.CORBA.INITIALIZE
 *                if the string does not contains a valid value.
 */
public void parse_poa_min_threads(String str)
{
    if (str == null)
        return;

    int value = parse_int(poa_min_threads_name, str);

    if (value < 1)
        throw new INITIALIZE(poa_min_threads_name + ":invalid value "
                             + value + " (minimum 1)");

    poa_min_threads = value;

}

/**
 * Parse the poa_max_queued_requests value.
 * 
 * @param str
 *            the value digits.
 * @pre Values must be > 0.
 * @exception org.omg.CORBA.INITIALIZE
 *                if the string does not contains a valid value.
 */
public void parse_poa_max_queued_requests(String str)
{
    if (str == null)
        return;

    int value = parse_int(poa_max_queued_requests_name, str);

    if (value < 1)
        throw new INITIALIZE(poa_max_queued_requests_name
                             + ":invalid value " + value + " (minimum 1)");

    poa_max_queued_requests = value;

}

/**
 * Parse the poa_starving_time value.
 * 
 * @param str
 *            the value digits.
 * @pre Values must be >= 0.
 * @exception org.omg.CORBA.INITIALIZE
 *                if the string does not contains a valid value.
 */
public void parse_poa_starving_time(String str)
{
    if (str == null)
        return;

    int value = parse_int(poa_starving_time_name, str);

    if (value < 0)
        throw new INITIALIZE(poa_starving_time_name + ":invalid value "
                             + value + " (minimum 0)");

    poa_starving_time = value;

}

/**
 * Parse the ami_max_threads value.
 * 
 * @param str
 *            the value digits.
 * @pre Values must be > 0.
 * @exception org.omg.CORBA.INITIALIZE
 *                if the string does not contains a valid value.
 */
public void parse_ami_max_threads(String str)
{
    if (str == null)
        return;

    int value = parse_int(ami_max_threads_name, str);

    if (value < 1)
        throw new INITIALIZE(ami_max_threads_name + ":invalid value "
                             + value + " (minimum 1)");

    ami_max_threads = value;

}

/**
 * Parse the ami_min_threads value.
 * 
 * @param str
 *            the value digits.
 * @pre Values must be >= 0.
 * @exception org.omg.CORBA.INITIALIZE
 *                if the string does not contains a valid value.
 */
public void parse_ami_min_threads(String str)
{
    if (str == null)
        return;

    int value = parse_int(ami_min_threads_name, str);

    if (value < 1)
        throw new INITIALIZE(ami_min_threads_name + ":invalid value "
                             + value + " (minimum 1)");

    ami_min_threads = value;

}

/**
 * Parse the ami_max_queued_requests value.
 * 
 * @param str
 *            the value digits.
 * @pre Values must be > 0.
 * @exception org.omg.CORBA.INITIALIZE
 *                if the string does not contains a valid value.
 */
public void parse_ami_max_queued_handled_requests(String str)
{
    if (str == null)
        return;

    int value = parse_int(ami_max_queued_handled_requests_name, str);

    if (value < 1)
        throw new INITIALIZE(ami_max_queued_handled_requests_name
                             + ":invalid value " + value + " (minimum 1)");

    ami_max_queued_handled_requests = value;

}

/**
 * Parse the ami_starving_time value.
 * 
 * @param str
 *            the value digits.
 * @pre Values must be >= 0.
 * @exception org.omg.CORBA.INITIALIZE
 *                if the string does not contains a valid value.
 */
public void parse_ami_starving_time(String str)
{
    if (str == null)
        return;

    int value = parse_int(ami_starving_time_name, str);

    if (value < 0)
        throw new INITIALIZE(ami_starving_time_name + ":invalid value "
                             + value + " (minimum 0)");

    ami_starving_time = value;

}