summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/Outgoing.java
diff options
context:
space:
mode:
authorMarc Laukien <marc@zeroc.com>2004-02-23 14:39:39 +0000
committerMarc Laukien <marc@zeroc.com>2004-02-23 14:39:39 +0000
commit12a3bcc93abb7fc436ccd80599fd731d2a477474 (patch)
tree5c80ec39793bae084e7b29bad08d2f0c40eed666 /java/src/IceInternal/Outgoing.java
parentAdded some AMI tests. (diff)
downloadice-12a3bcc93abb7fc436ccd80599fd731d2a477474.tar.bz2
ice-12a3bcc93abb7fc436ccd80599fd731d2a477474.tar.xz
ice-12a3bcc93abb7fc436ccd80599fd731d2a477474.zip
mutex for OutgoingAsync
Diffstat (limited to 'java/src/IceInternal/Outgoing.java')
-rw-r--r--java/src/IceInternal/Outgoing.java11
1 files changed, 10 insertions, 1 deletions
diff --git a/java/src/IceInternal/Outgoing.java b/java/src/IceInternal/Outgoing.java
index fcbf6b1b6a3..303d49a4957 100644
--- a/java/src/IceInternal/Outgoing.java
+++ b/java/src/IceInternal/Outgoing.java
@@ -36,8 +36,14 @@ public final class Outgoing
public void
destroy()
{
- _os.destroy();
+ assert(_is != null);
_is.destroy();
+ _is = null;
+
+ assert(_os != null);
+ _os.destroy();
+ _os = null;
+
}
//
@@ -50,7 +56,10 @@ public final class Outgoing
_state = StateUnsent;
_exception = null;
+ assert(_is != null);
_is.reset();
+
+ assert(_os != null);
_os.reset();
writeHeader(operation, mode, context);