import com.sun.corba.se.impl.encoding.BufferManagerReadStream; //导入依赖的package包/类
public static BufferManagerRead newBufferManagerRead(
        GIOPVersion version, byte encodingVersion, ORB orb) {

    // REVISIT - On the reading side, shouldn't we monitor the incoming
    // fragments on a given connection to determine what fragment size
    // they're using, then use that ourselves?

    if (encodingVersion != Message.CDR_ENC_VERSION) {
        return new BufferManagerReadGrow(orb);
    }

    switch (version.intValue())
    {
        case GIOPVersion.VERSION_1_0:
            return new BufferManagerReadGrow(orb);
        case GIOPVersion.VERSION_1_1:
        case GIOPVersion.VERSION_1_2:
            // The stream reader can handle fragmented and
            // non fragmented messages
            return new BufferManagerReadStream(orb);
        default:
            // REVISIT - what is appropriate?
            throw new INTERNAL("Unknown GIOP version: "
                               + version);
    }
}
 

import com.sun.corba.se.impl.encoding.BufferManagerReadStream; //导入依赖的package包/类
public void signalExceptionToAllWaiters(SystemException systemException)
{

    if (orb.transportDebugFlag) {
        dprint(".signalExceptionToAllWaiters: " + systemException);
    }

    OutCallDesc call;
    java.util.Enumeration e = out_calls.elements();
    while(e.hasMoreElements()) {
        call = (OutCallDesc) e.nextElement();

        synchronized(call.done){
            // anything waiting for BufferManagerRead's fragment queue
            // needs to be cancelled
            CorbaMessageMediator corbaMsgMediator =
                         (CorbaMessageMediator)call.messageMediator;
            CDRInputObject inputObject =
                       (CDRInputObject)corbaMsgMediator.getInputObject();
            // IMPORTANT: If inputObject is null, then no need to tell
            //            BufferManagerRead to cancel request processing.
            if (inputObject != null) {
                BufferManagerReadStream bufferManager =
                    (BufferManagerReadStream)inputObject.getBufferManager();
                int requestId = corbaMsgMediator.getRequestId();
                bufferManager.cancelProcessing(requestId);
            }
            call.inputObject = null;
            call.exception = systemException;
            call.done.notify();
        }
    }
}
 

import com.sun.corba.se.impl.encoding.BufferManagerReadStream; //导入依赖的package包/类
public void signalExceptionToAllWaiters(SystemException systemException)
{

    if (orb.transportDebugFlag) {
        dprint(".signalExceptionToAllWaiters: " + systemException);
    }

    synchronized (out_calls) {
        if (orb.transportDebugFlag) {
            dprint(".signalExceptionToAllWaiters: out_calls size :" +
                   out_calls.size());
        }

        for (OutCallDesc call : out_calls.values()) {
            if (orb.transportDebugFlag) {
                dprint(".signalExceptionToAllWaiters: signaling " +
                        call);
            }
            synchronized(call.done) {
                try {
                    // anything waiting for BufferManagerRead's fragment queue
                    // needs to be cancelled
                    CorbaMessageMediator corbaMsgMediator =
                                 (CorbaMessageMediator)call.messageMediator;
                    CDRInputObject inputObject =
                               (CDRInputObject)corbaMsgMediator.getInputObject();
                    // IMPORTANT: If inputObject is null, then no need to tell
                    //            BufferManagerRead to cancel request processing.
                    if (inputObject != null) {
                        BufferManagerReadStream bufferManager =
                            (BufferManagerReadStream)inputObject.getBufferManager();
                        int requestId = corbaMsgMediator.getRequestId();
                        bufferManager.cancelProcessing(requestId);
                    }
                } catch (Exception e) {
                } finally {
                    // attempt to wake up waiting threads in all cases
                    call.inputObject = null;
                    call.exception = systemException;
                    call.done.notifyAll();
                }
            }
        }
    }
}