diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2014-07-10 14:39:04 +0200 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2014-07-10 14:39:04 +0200 |
| commit | 1fccdf858f416bf029d86d4784ac81206db1eaf3 (patch) | |
| tree | 7aadc83da8be2130139b5c1abbe9747736758158 /java/src/Ice/ConnectionI.java | |
| parent | ICE-4612: first cut of the IceGrid discovery plugin and APIs (diff) | |
| download | ice-1fccdf858f416bf029d86d4784ac81206db1eaf3.tar.bz2 ice-1fccdf858f416bf029d86d4784ac81206db1eaf3.tar.xz ice-1fccdf858f416bf029d86d4784ac81206db1eaf3.zip | |
Fixed bogus synchronization in ConnectionI.asyncRequestTimedOut
Diffstat (limited to 'java/src/Ice/ConnectionI.java')
| -rw-r--r-- | java/src/Ice/ConnectionI.java | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/java/src/Ice/ConnectionI.java b/java/src/Ice/ConnectionI.java index a2c9e9d1060..15290246234 100644 --- a/java/src/Ice/ConnectionI.java +++ b/java/src/Ice/ConnectionI.java @@ -1007,22 +1007,22 @@ public final class ConnectionI extends IceInternal.EventHandler implements Conne break; // We're done. } } - } - if(!finished) - { - if(outAsync instanceof IceInternal.OutgoingAsync) + if(!finished) { - IceInternal.OutgoingAsync o = (IceInternal.OutgoingAsync)outAsync; - java.util.Iterator<IceInternal.OutgoingAsync> it2 = _asyncRequests.values().iterator(); - while(it2.hasNext()) + if(outAsync instanceof IceInternal.OutgoingAsync) { - if(it2.next() == o) + IceInternal.OutgoingAsync o = (IceInternal.OutgoingAsync)outAsync; + java.util.Iterator<IceInternal.OutgoingAsync> it2 = _asyncRequests.values().iterator(); + while(it2.hasNext()) { - it2.remove(); - finished = true; - isSent = true; - break; // We're done. + if(it2.next() == o) + { + it2.remove(); + finished = true; + isSent = true; + break; // We're done. + } } } } |