1.1 --- a/src/share/classes/com/sun/corba/se/impl/encoding/BufferManagerWriteStream.java Thu Oct 07 01:03:51 2010 -0700
1.2 +++ b/src/share/classes/com/sun/corba/se/impl/encoding/BufferManagerWriteStream.java Mon Nov 29 22:10:46 2010 -0800
1.3 @@ -30,12 +30,14 @@
1.4 import com.sun.corba.se.impl.protocol.giopmsgheaders.Message;
1.5 import com.sun.corba.se.impl.protocol.giopmsgheaders.MessageBase;
1.6 import com.sun.corba.se.impl.protocol.giopmsgheaders.FragmentMessage;
1.7 +import com.sun.corba.se.impl.protocol.giopmsgheaders.ReplyMessage;
1.8 import com.sun.corba.se.impl.encoding.BufferManagerWrite;
1.9 import com.sun.corba.se.impl.encoding.ByteBufferWithInfo;
1.10 import com.sun.corba.se.impl.encoding.CDROutputObject;
1.11 import com.sun.corba.se.spi.orb.ORB;
1.12 import com.sun.corba.se.pept.transport.Connection;
1.13 import com.sun.corba.se.pept.encoding.OutputObject;
1.14 +import org.omg.CORBA.SystemException;
1.15
1.16 /**
1.17 * Streaming buffer manager.
1.18 @@ -66,7 +68,13 @@
1.19 // Set the fragment's moreFragments field to true
1.20 MessageBase.setFlag(bbwi.byteBuffer, Message.MORE_FRAGMENTS_BIT);
1.21
1.22 - sendFragment(false);
1.23 + try {
1.24 + sendFragment(false);
1.25 + } catch(SystemException se){
1.26 + orb.getPIHandler().invokeClientPIEndingPoint(
1.27 + ReplyMessage.SYSTEM_EXCEPTION, se);
1.28 + throw se;
1.29 + }
1.30
1.31 // Reuse the old buffer
1.32
