summaryrefslogtreecommitdiff
path: root/gnu/CORBA/gnuRequest.java
diff options
context:
space:
mode:
authorAudrius Meskauskas <audriusa@Bioinformatics.org>2006-04-08 19:43:55 +0000
committerAudrius Meskauskas <audriusa@Bioinformatics.org>2006-04-08 19:43:55 +0000
commit010e5bfc114df0cbefdbeb303e32f83585e65a78 (patch)
treebf6cb70461433d5d54dad569c6effe9084d44b9f /gnu/CORBA/gnuRequest.java
parent60f072d07a051c3f6f71650ce59274fc670c5ffb (diff)
downloadclasspath-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.java8
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();