174 |
public InputStream invoke(org.omg.CORBA.Object target, OutputStream output) |
public InputStream invoke(org.omg.CORBA.Object target, OutputStream output) |
175 |
throws ApplicationException, RemarshalException |
throws ApplicationException, RemarshalException |
176 |
{ |
{ |
177 |
streamRequest request = (streamRequest) output; |
StreamBasedRequest request = (StreamBasedRequest) output; |
178 |
Forwardings: while (true) |
Forwardings: while (true) |
179 |
{ |
{ |
180 |
try |
try |
181 |
{ |
{ |
182 |
if (request.response_expected) |
if (request.response_expected) |
183 |
{ |
{ |
184 |
binaryReply response = request.request.submit(); |
RawReply response = request.request.submit(); |
185 |
|
|
186 |
// Read reply header. |
// Read reply header. |
187 |
ReplyHeader rh = response.header.create_reply_header(); |
ReplyHeader rh = response.header.create_reply_header(); |
338 |
/** |
/** |
339 |
* Show exception to interceptor. |
* Show exception to interceptor. |
340 |
*/ |
*/ |
341 |
void showException(streamRequest request, cdrBufInput input) |
void showException(StreamBasedRequest request, cdrBufInput input) |
342 |
throws ForwardRequest |
throws ForwardRequest |
343 |
{ |
{ |
344 |
input.mark(2048); |
input.mark(2048); |
390 |
request.set_target(target); |
request.set_target(target); |
391 |
request.setOperation(operation); |
request.setOperation(operation); |
392 |
|
|
393 |
streamRequest out = request.getParameterStream(); |
StreamBasedRequest out = request.getParameterStream(); |
394 |
out.response_expected = response_expected; |
out.response_expected = response_expected; |
395 |
request.setORB(orb); |
request.setORB(orb); |
396 |
out.setOrb(orb); |
out.setOrb(orb); |