149 mediator);
150 this.connection = connection ;
151 }
152
153 // XREVISIT
154 // Header should only be in message mediator.
155 // Another possibility: merge header and message mediator.
156 // REVISIT - make protected once all encoding together
157 public Message getMessageHeader() {
158 return header;
159 }
160
161 public final void finishSendingMessage() {
162 getBufferManager().sendMessage();
163 }
164
165 /**
166 * Write the contents of the CDROutputStream to the specified
167 * output stream. Has the side-effect of pushing any current
168 * Message onto the Message list.
169 * @param s The output stream to write to.
170 */
171 public void writeTo(CorbaConnection connection)
172 throws java.io.IOException
173 {
174
175 //
176 // Update the GIOP MessageHeader size field.
177 //
178
179 ByteBufferWithInfo bbwi = getByteBufferWithInfo();
180
181 getMessageHeader().setSize(bbwi.byteBuffer, bbwi.getSize());
182
183 if (orb() != null) {
184 if (((ORB)orb()).transportDebugFlag) {
185 dprint(".writeTo: " + connection);
186 }
187 if (((ORB)orb()).giopDebugFlag) {
188 CDROutputStream_1_0.printBuffer(bbwi);
189 }
|
149 mediator);
150 this.connection = connection ;
151 }
152
153 // XREVISIT
154 // Header should only be in message mediator.
155 // Another possibility: merge header and message mediator.
156 // REVISIT - make protected once all encoding together
157 public Message getMessageHeader() {
158 return header;
159 }
160
161 public final void finishSendingMessage() {
162 getBufferManager().sendMessage();
163 }
164
165 /**
166 * Write the contents of the CDROutputStream to the specified
167 * output stream. Has the side-effect of pushing any current
168 * Message onto the Message list.
169 * @param connection The output stream to write to.
170 */
171 public void writeTo(CorbaConnection connection)
172 throws java.io.IOException
173 {
174
175 //
176 // Update the GIOP MessageHeader size field.
177 //
178
179 ByteBufferWithInfo bbwi = getByteBufferWithInfo();
180
181 getMessageHeader().setSize(bbwi.byteBuffer, bbwi.getSize());
182
183 if (orb() != null) {
184 if (((ORB)orb()).transportDebugFlag) {
185 dprint(".writeTo: " + connection);
186 }
187 if (((ORB)orb()).giopDebugFlag) {
188 CDROutputStream_1_0.printBuffer(bbwi);
189 }
|