summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/ConnectRequestHandler.java
diff options
context:
space:
mode:
authorMark Spruiell <mes@zeroc.com>2008-01-19 08:04:43 -0800
committerMark Spruiell <mes@zeroc.com>2008-01-19 08:04:43 -0800
commit36c55aaab360d317521de7488d7a286788e8bd2e (patch)
tree63d169432555c3569b3faaf4f93ff7d2ba9c0f23 /java/src/IceInternal/ConnectRequestHandler.java
parentAdded mcpp patch (diff)
downloadice-36c55aaab360d317521de7488d7a286788e8bd2e.tar.bz2
ice-36c55aaab360d317521de7488d7a286788e8bd2e.tar.xz
ice-36c55aaab360d317521de7488d7a286788e8bd2e.zip
async I/O in C#
Diffstat (limited to 'java/src/IceInternal/ConnectRequestHandler.java')
-rw-r--r--java/src/IceInternal/ConnectRequestHandler.java20
1 files changed, 10 insertions, 10 deletions
diff --git a/java/src/IceInternal/ConnectRequestHandler.java b/java/src/IceInternal/ConnectRequestHandler.java
index e269dce1ee8..3f0c5bb6104 100644
--- a/java/src/IceInternal/ConnectRequestHandler.java
+++ b/java/src/IceInternal/ConnectRequestHandler.java
@@ -467,14 +467,6 @@ public class ConnectRequestHandler
}
}
- synchronized(this)
- {
- assert(!_initialized);
- _initialized = true;
- _flushing = false;
- notifyAll();
- }
-
//
// We've finished sending the queued requests and the request handler now send
// the requests over the connection directly. It's time to substitute the
@@ -486,8 +478,16 @@ public class ConnectRequestHandler
{
_proxy.__setRequestHandler(_delegate, new ConnectionRequestHandler(_reference, _connection, _compress));
}
- _proxy = null; // Break cyclic reference count.
- _delegate = null; // Break cyclic reference count.
+
+ synchronized(this)
+ {
+ assert(!_initialized);
+ _initialized = true;
+ _flushing = false;
+ _proxy = null; // Break cyclic reference count.
+ _delegate = null; // Break cyclic reference count.
+ notifyAll();
+ }
}
void