You are viewing a plain text version of this content. The canonical link for it is here.
Posted to scm@geronimo.apache.org by dj...@apache.org on 2017/02/19 01:50:04 UTC

[47/51] [abbrv] geronimo-yoko git commit: Correct phaser usage to deregister parties as they arrive

Correct phaser usage to deregister parties as they arrive


Project: http://git-wip-us.apache.org/repos/asf/geronimo-yoko/repo
Commit: http://git-wip-us.apache.org/repos/asf/geronimo-yoko/commit/549b0904
Tree: http://git-wip-us.apache.org/repos/asf/geronimo-yoko/tree/549b0904
Diff: http://git-wip-us.apache.org/repos/asf/geronimo-yoko/diff/549b0904

Branch: refs/heads/master
Commit: 549b090454c6cab5737b2ce2ad1c4cc4c6bc91f1
Parents: e9379fd
Author: David Jencks <dj...@apache.org>
Authored: Thu Aug 4 11:45:57 2016 -0700
Committer: David Jencks <dj...@apache.org>
Committed: Thu Aug 4 11:45:57 2016 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/yoko/orb/OB/GIOPConnectionThreaded.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/geronimo-yoko/blob/549b0904/yoko-core/src/main/java/org/apache/yoko/orb/OB/GIOPConnectionThreaded.java
----------------------------------------------------------------------
diff --git a/yoko-core/src/main/java/org/apache/yoko/orb/OB/GIOPConnectionThreaded.java b/yoko-core/src/main/java/org/apache/yoko/orb/OB/GIOPConnectionThreaded.java
index c6d6c2e..92aef1e 100644
--- a/yoko-core/src/main/java/org/apache/yoko/orb/OB/GIOPConnectionThreaded.java
+++ b/yoko-core/src/main/java/org/apache/yoko/orb/OB/GIOPConnectionThreaded.java
@@ -244,9 +244,9 @@ public final class GIOPConnectionThreaded extends GIOPConnection {
 
     private void arrive() {
         if ((properties_ & Property.CreatedByClient) != 0)
-            orbInstance_.getClientPhaser().arrive();
+            orbInstance_.getClientPhaser().arriveAndDeregister();
         else
-            orbInstance_.getServerPhaser().arrive();
+            orbInstance_.getServerPhaser().arriveAndDeregister();
     }
 
     // ----------------------------------------------------------------