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

/**
 * Adds an new request to the queue.
 * 
 * @param request The request to be added.
 */
synchronized public void add(QueuedRequest request) {
    if ( m_deactivation  || 
         m_values.size() >= m_poa_manager.m_conf.getMaxQueuedRequests()) {
        TRANSIENT e = new TRANSIENT(null, 1, CompletionStatus.COMPLETED_NO);
        if ( m_poa_manager.m_orb.m_trace != null ) {
            String[] msg = { toString(),
                             " Submitting TRANSIENT in request because",
                             " MaxQueuedRequests ",
                             Integer.toString(m_poa_manager.m_conf.getMaxQueuedRequests()),
                             " has been reached" };
            m_poa_manager.m_orb.printTrace(Trace.DEEP_DEBUG, msg);
        }
        request.submitResponse( e );
    } else {
        m_values.add(request);
        if (!m_queue_read_manager.createNewReader()) {
            notify();
        }
    }
}

/**
 * Checks in a new connection for manage it.
 * 
 * @param conn
 *            the bidirectional connection.
 */
protected void newConnection(IIOPConnection conn)
{
    try {

        m_connections.append(conn);

    } catch (es.tid.TIDorbj.core.util.FullUseTableException f) {
        conn.closeByManager();
        if (conn.isClientConnection()) {
            throw new TRANSIENT(
                "Maximun of Connections reached, and all are in use, try later!!",
                0, 
    CompletionStatus.COMPLETED_NO
);
        }
    }

    Object[] removed = m_connections.getRemovedObjects();

    if (removed != null) {
        for (int i = 0; i < removed.length; i++) {
            closeConnection((IIOPConnection) removed[i]);
        }
    }
}

/**
 * Checks in a new connection for manage it.
 * 
 * @param conn
 *            the bidirectional connection.
 */
protected void newConnection(SSLConnection conn)
{
    try {

        m_connections.append(conn);

    } catch (es.tid.TIDorbj.core.util.FullUseTableException f) {
        conn.closeByManager();
        if (conn.isClientConnection()) {
            throw new TRANSIENT(
                "Maximun of Connections reached, and all are in use, try later!!",
                0, 
    CompletionStatus.COMPLETED_NO
);
        }
    }

    Object[] removed = m_connections.getRemovedObjects();

    if (removed != null) {
        for (int i = 0; i < removed.length; i++) {
            closeConnection((IIOPConnection) removed[i]);
        }
    }
}

public TRANSIENT requestCanceled( CompletionStatus cs, Throwable t ) {
    TRANSIENT exc = new TRANSIENT( REQUEST_CANCELED, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

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

    return exc ;
}

public TRANSIENT poaDiscarding( CompletionStatus cs, Throwable t ) {
    TRANSIENT exc = new TRANSIENT( POA_DISCARDING, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

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

    return exc ;
}

public TRANSIENT poaRequestDiscard( CompletionStatus cs, Throwable t ) {
    TRANSIENT exc = new TRANSIENT( POA_REQUEST_DISCARD, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

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

    return exc ;
}

public TRANSIENT noUsableProfile3( CompletionStatus cs, Throwable t ) {
    TRANSIENT exc = new TRANSIENT( NO_USABLE_PROFILE_3, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

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

    return exc ;
}

public TRANSIENT requestCancelled( CompletionStatus cs, Throwable t ) {
    TRANSIENT exc = new TRANSIENT( REQUEST_CANCELLED, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

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

    return exc ;
}

public TRANSIENT poaDestroyed( CompletionStatus cs, Throwable t ) {
    TRANSIENT exc = new TRANSIENT( POA_DESTROYED, cs ) ;
    if (t != null)
        exc.initCause( t ) ;

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

    return exc ;
}

/**
 * Check if the POA is not in a discarding mode. The activation
 * operations are forbidded in discarding mode.
 *
 * @throws TRANSIENT if the POA is in discarding mode.
 */
void checkDiscarding()
                      throws TRANSIENT
{
  if (m_manager.get_state() == State.DISCARDING)
    throw new TRANSIENT("Discarding mode", 1, CompletionStatus.COMPLETED_MAYBE);
}

/**
 * Check if the POA is not in a discarding mode. The activation
 * operations are forbidded in discarding mode.
 *
 * @throws TRANSIENT if the POA is in discarding mode.
 */
void checkDiscarding()
                      throws TRANSIENT
{
  if (m_manager.get_state() == State.DISCARDING)
    throw new TRANSIENT("Discarding mode", 1, CompletionStatus.COMPLETED_MAYBE);
}

/**
 * Check if the POA is not in a discarding mode. The activation
 * operations are forbidded in discarding mode.
 *
 * @throws TRANSIENT if the POA is in discarding mode.
 */
void checkDiscarding()
                      throws TRANSIENT
{
  if (m_manager.get_state() == State.DISCARDING)
    throw new TRANSIENT("Discarding mode", 1, CompletionStatus.COMPLETED_MAYBE);
}

/**
 * Check if the POA is not in a discarding mode. The activation
 * operations are forbidded in discarding mode.
 *
 * @throws TRANSIENT if the POA is in discarding mode.
 */
void checkDiscarding()
                      throws TRANSIENT
{
  if (m_manager.get_state() == State.DISCARDING)
    throw new TRANSIENT("Discarding mode", 1, CompletionStatus.COMPLETED_MAYBE);
}

/**
 * Creates a new connection in CLIENT_MODE.
 */

public static IIOPConnection clientConnection(IIOPConnectionManager mngr,
                                          ListenPoint listen_point)
{
    try {

        // create the socket
        Socket socket =
            new Socket(listen_point.m_host, listen_point.m_port);
        IIOPConnection conn = new IIOPConnection(mngr, socket);

        conn.m_mode = CLIENT_MODE;

        conn.m_initial_point = listen_point;

        conn.addListenPoint(listen_point);

        conn.init();

        return conn;

    }
    catch (java.io.IOException ioe) {
        throw new TRANSIENT(ioe.toString(), 0,
                               CompletionStatus.COMPLETED_NO);
    }
    catch (java.lang.SecurityException sce) {
        throw new NO_PERMISSION(sce.toString(), 0,
                                CompletionStatus.COMPLETED_NO);
    }
}

public TRANSIENT requestCanceled( CompletionStatus cs ) {
    return requestCanceled( cs, null  ) ;
}

public TRANSIENT requestCanceled( Throwable t ) {
    return requestCanceled( CompletionStatus.COMPLETED_NO, t  ) ;
}

public TRANSIENT requestCanceled(  ) {
    return requestCanceled( CompletionStatus.COMPLETED_NO, null  ) ;
}

public TRANSIENT poaDiscarding( CompletionStatus cs ) {
    return poaDiscarding( cs, null  ) ;
}

public TRANSIENT poaDiscarding( Throwable t ) {
    return poaDiscarding( CompletionStatus.COMPLETED_NO, t  ) ;
}

public TRANSIENT poaDiscarding(  ) {
    return poaDiscarding( CompletionStatus.COMPLETED_NO, null  ) ;
}

public TRANSIENT poaRequestDiscard( CompletionStatus cs ) {
    return poaRequestDiscard( cs, null  ) ;
}

public TRANSIENT poaRequestDiscard( Throwable t ) {
    return poaRequestDiscard( CompletionStatus.COMPLETED_NO, t  ) ;
}

public TRANSIENT poaRequestDiscard(  ) {
    return poaRequestDiscard( CompletionStatus.COMPLETED_NO, null  ) ;
}

public TRANSIENT noUsableProfile3( CompletionStatus cs ) {
    return noUsableProfile3( cs, null  ) ;
}

public TRANSIENT noUsableProfile3( Throwable t ) {
    return noUsableProfile3( CompletionStatus.COMPLETED_NO, t  ) ;
}

public TRANSIENT noUsableProfile3(  ) {
    return noUsableProfile3( CompletionStatus.COMPLETED_NO, null  ) ;
}

public TRANSIENT requestCancelled( CompletionStatus cs ) {
    return requestCancelled( cs, null  ) ;
}

public TRANSIENT requestCancelled( Throwable t ) {
    return requestCancelled( CompletionStatus.COMPLETED_NO, t  ) ;
}

public TRANSIENT requestCancelled(  ) {
    return requestCancelled( CompletionStatus.COMPLETED_NO, null  ) ;
}

public TRANSIENT poaDestroyed( CompletionStatus cs ) {
    return poaDestroyed( cs, null  ) ;
}

public TRANSIENT poaDestroyed( Throwable t ) {
    return poaDestroyed( CompletionStatus.COMPLETED_NO, t  ) ;
}

public TRANSIENT poaDestroyed(  ) {
    return poaDestroyed( CompletionStatus.COMPLETED_NO, null  ) ;
}