diff options
| author | Audrius Meskauskas <audriusa@Bioinformatics.org> | 2006-04-08 19:43:55 +0000 |
|---|---|---|
| committer | Audrius Meskauskas <audriusa@Bioinformatics.org> | 2006-04-08 19:43:55 +0000 |
| commit | 010e5bfc114df0cbefdbeb303e32f83585e65a78 (patch) | |
| tree | bf6cb70461433d5d54dad569c6effe9084d44b9f /gnu/CORBA/gnuRequest.java | |
| parent | 60f072d07a051c3f6f71650ce59274fc670c5ffb (diff) | |
| download | classpath-010e5bfc114df0cbefdbeb303e32f83585e65a78.tar.gz | |
2006-04-08 Audrius Meskauskas <AudriusA@Bioinformatics.org>
* gnu/CORBA/gnuRequest.java (p_invoke, submit): Do not try to read
response for the one way messages.
Diffstat (limited to 'gnu/CORBA/gnuRequest.java')
| -rw-r--r-- | gnu/CORBA/gnuRequest.java | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/gnu/CORBA/gnuRequest.java b/gnu/CORBA/gnuRequest.java index 5adf74129..6425101df 100644 --- a/gnu/CORBA/gnuRequest.java +++ b/gnu/CORBA/gnuRequest.java @@ -833,7 +833,9 @@ public class gnuRequest extends Request implements Cloneable request_part.buffer.writeTo(socketOutput); socketOutput.flush(); - if (!socket.isClosed()) + // If the message is sent one way, we do not care about the response + // that may never come. + if (!socket.isClosed() && !oneWay) { MessageHeader response_header = new MessageHeader(); InputStream socketInput = socket.getInputStream(); @@ -937,6 +939,10 @@ public class gnuRequest extends Request implements Cloneable throws SystemException, ForwardRequest { RawReply response = submit(); + + // If this is a one way message, do not care about the response. + if (oneWay && response == EMPTY) + return; if (m_rph == null) m_rph = response.header.create_reply_header(); |
