import com.sun.corba.se.impl.protocol.giopmsgheaders.RequestMessage; //导入依赖的package包/类
public void handleInput(RequestMessage_1_0 header) throws IOException
{
    try {
        if (transportDebug()) dprint(".REQUEST 1.0->: " + header);
        try {
            messageHeader = requestHeader = (RequestMessage) header;
            setInputObject();
        } finally {
            setWorkThenPoolOrResumeSelect(header);
        }
        getProtocolHandler().handleRequest(header, this);
    } catch (Throwable t) {
        if (transportDebug())
            dprint(".REQUEST 1.0: !!ERROR!!: " + header, t);
        // Mask the exception from thread.;
    } finally {
        if (transportDebug()) dprint(".REQUEST 1.0<-: " + header);
    }
}
 

import com.sun.corba.se.impl.protocol.giopmsgheaders.RequestMessage; //导入依赖的package包/类
public CorbaMessageMediatorImpl(ORB orb,
                                ContactInfo contactInfo,
                                Connection connection,
                                GIOPVersion giopVersion,
                                IOR ior,
                                int requestId,
                                short addrDisposition,
                                String operationName,
                                boolean isOneWay)
{
    this( orb, connection ) ;

    this.contactInfo = (CorbaContactInfo) contactInfo;
    this.addrDisposition = addrDisposition;

    streamFormatVersion =
        getStreamFormatVersionForThisRequest(
            ((CorbaContactInfo)this.contactInfo).getEffectiveTargetIOR(),
            giopVersion);
    streamFormatVersionSet = true;

    requestHeader = (RequestMessage) MessageBase.createRequest(
        this.orb,
        giopVersion,
        ORBUtility.getEncodingVersion(orb, ior),
        requestId,
        !isOneWay,
        ((CorbaContactInfo)this.contactInfo).getEffectiveTargetIOR(),
        this.addrDisposition,
        operationName,
        new ServiceContexts(orb),
        null);
}
 

import com.sun.corba.se.impl.protocol.giopmsgheaders.RequestMessage; //导入依赖的package包/类
public void handleRequest(RequestMessage header,
CorbaMessageMediator messageMediator);
 

import com.sun.corba.se.impl.protocol.giopmsgheaders.RequestMessage; //导入依赖的package包/类
public RequestMessage getRequestHeader()
{
    return requestHeader;
}
 

import com.sun.corba.se.impl.protocol.giopmsgheaders.RequestMessage; //导入依赖的package包/类
private void resumeSelect(Message header)
{
    // NOTE: VERY IMPORTANT:
    // Only participate in select after getting to the point
    // that proper serialization of fragments is ensured.

    if (transportDebug()) {
        dprint(".resumeSelect:->");
        // REVISIT: not-OO:
        String requestId = "?";
        if (header instanceof RequestMessage) {
            requestId =
                new Integer(((RequestMessage)header)
                            .getRequestId()).toString();
        } else if (header instanceof ReplyMessage) {
            requestId =
                new Integer(((ReplyMessage)header)
                            .getRequestId()).toString();
        } else if (header instanceof FragmentMessage_1_2) {
            requestId =
                new Integer(((FragmentMessage_1_2)header)
                            .getRequestId()).toString();
        }
        dprint(".resumeSelect: id/"
               + requestId
               + " " + getConnection()
               );

    }

    // IMPORTANT: To avoid bug (4953599), we force the Thread that does the NIO select
    // to also do the enable/disable of Ops using SelectionKey.interestOps(Ops of Interest).
    // Otherwise, the SelectionKey.interestOps(Ops of Interest) may block indefinitely in
    // this thread.
    EventHandler eventHandler = getConnection().getEventHandler();
    orb.getTransportManager().getSelector(0).registerInterestOps(eventHandler);

    if (transportDebug()) {
        dprint(".resumeSelect:<-");
    }
}