import com.sun.corba.se.impl.protocol.giopmsgheaders.FragmentMessage; //导入依赖的package包/类
public void processFragment(ByteBuffer byteBuffer, FragmentMessage msg)
{
    ByteBufferWithInfo bbwi =
        new ByteBufferWithInfo(orb, byteBuffer, msg.getHeaderLength());

    synchronized (fragmentQueue) {
        if (debug)
        {
            // print address of ByteBuffer being queued
            int bbAddress = System.identityHashCode(byteBuffer);
            StringBuffer sb = new StringBuffer(80);
            sb.append("processFragment() - queueing ByteBuffer id (");
            sb.append(bbAddress).append(") to fragment queue.");
            String strMsg = sb.toString();
            dprint(strMsg);
        }
        fragmentQueue.enqueue(bbwi);
        endOfStream = !msg.moreFragmentsToFollow();
        fragmentQueue.notify();
    }
}
 

import com.sun.corba.se.impl.protocol.giopmsgheaders.FragmentMessage; //导入依赖的package包/类
public void overflow (ByteBufferWithInfo bbwi)
{
    // Set the fragment's moreFragments field to true
    MessageBase.setFlag(bbwi.byteBuffer, Message.MORE_FRAGMENTS_BIT);

    try {
       sendFragment(false);
    } catch(SystemException se){
            orb.getPIHandler().invokeClientPIEndingPoint(
                    ReplyMessage.SYSTEM_EXCEPTION, se);
            throw se;
    }

    // Reuse the old buffer

    // REVISIT - need to account for case when needed > available
    // even after fragmenting.  This is the large array case, so
    // the caller should retry when it runs out of space.
    bbwi.position(0);
    bbwi.buflen = bbwi.byteBuffer.limit();
    bbwi.fragmented = true;

    // Now we must marshal in the fragment header/GIOP header

    // REVISIT - we can optimize this by not creating the fragment message
    // each time.

    FragmentMessage header = ((CDROutputObject)outputObject).getMessageHeader().createFragmentMessage();

    header.write(((CDROutputObject)outputObject));
}
 

import com.sun.corba.se.impl.protocol.giopmsgheaders.FragmentMessage; //导入依赖的package包/类
public void overflow (ByteBufferWithInfo bbwi)
{
    // Set the fragment's moreFragments field to true
    MessageBase.setFlag(bbwi.byteBuffer, Message.MORE_FRAGMENTS_BIT);

    // Enqueue the previous fragment
    queue.enqueue(bbwi);

    // Create a new bbwi
    ByteBufferWithInfo newBbwi = new ByteBufferWithInfo(orb, this);
    newBbwi.fragmented = true;

    // XREVISIT - Downcast
    ((CDROutputObject)outputObject).setByteBufferWithInfo(newBbwi);

    // Now we must marshal in the fragment header/GIOP header

    // REVISIT - we can optimize this by not creating the fragment message
    // each time.

    // XREVISIT - Downcast
    FragmentMessage header =
          ((CDROutputObject)outputObject).getMessageHeader()
                                         .createFragmentMessage();

    header.write((CDROutputObject)outputObject);
}
 

import com.sun.corba.se.impl.protocol.giopmsgheaders.FragmentMessage; //导入依赖的package包/类
public void processFragment (ByteBuffer byteBuffer, FragmentMessage header)
{
    // REVISIT - should we consider throwing an exception similar to what's
    //           done for underflow()???
}