synchronize NettyChannelTracker.channelCreate() (neo4j#734)

gjmwoods · web-flow · commit 9f075eb611c9 · 2020-06-10T13:14:22.000+01:00
diff --git a/driver/src/main/java/org/neo4j/driver/internal/async/pool/NettyChannelTracker.java b/driver/src/main/java/org/neo4j/driver/internal/async/pool/NettyChannelTracker.java
@@ -86,7 +86,7 @@ public void channelCreated( Channel channel )
         throw new IllegalStateException( "Untraceable channel created." );
     }
 
-    public void channelCreated( Channel channel, ListenerEvent creatingEvent )
+    public synchronized void channelCreated( Channel channel, ListenerEvent creatingEvent )
     {
         log.debug( "Channel [0x%s] created. Local address: %s, remote address: %s",
                 channel.id(), channel.localAddress(), channel.remoteAddress() );

Original file line number	Diff line number	Diff line change
`@@ -86,7 +86,7 @@ public void channelCreated( Channel channel )`
`86`	`86`	`throw new IllegalStateException( "Untraceable channel created." );`
`87`	`87`	`}`
`88`	`88`
`89`		`- public void channelCreated( Channel channel, ListenerEvent creatingEvent )`
	`89`	`+ public synchronized void channelCreated( Channel channel, ListenerEvent creatingEvent )`
`90`	`90`	`{`
`91`	`91`	`log.debug( "Channel [0x%s] created. Local address: %s, remote address: %s",`
`92`	`92`	`channel.id(), channel.localAddress(), channel.remoteAddress() );`