Skip to content
Permalink
Browse files
Merge branch 'phaser-deregister' into 'ibm-trunk'
Correct phaser usage to deregister parties as they arrive

Without this, the phaser overflows after 64k connections.  As there is only one party per executor, I don't deregister it, nor the server thread.

See merge request !72
  • Loading branch information
David Jencks committed Aug 11, 2016
2 parents e9379fd + 549b090 commit 4a9d9e522627f8c5f1e9e51bf51b9b4b47dcbe21
Showing 1 changed file with 2 additions and 2 deletions.
@@ -244,9 +244,9 @@ synchronized protected void gracefulShutdown() {

private void arrive() {
if ((properties_ & Property.CreatedByClient) != 0)
orbInstance_.getClientPhaser().arrive();
orbInstance_.getClientPhaser().arriveAndDeregister();
else
orbInstance_.getServerPhaser().arrive();
orbInstance_.getServerPhaser().arriveAndDeregister();
}

// ----------------------------------------------------------------

0 comments on commit 4a9d9e5

Please sign in to comment.