Commit e30888a
authored
This update fixes an issue when `SimpleChannelPool` may invoke the `channelAcquired` method before the `channelCreated` method is called. Since it violates `NettyChannelTracker` contract, it may result in runtime failures.
See the following for details:
```
@startuml
T1 -> SimpleChannelPool: acquireHealthyFromPoolOrNew
activate SimpleChannelPool
SimpleChannelPool -> NettyChannelPool: connectChannel
activate NettyChannelPool
NettyChannelPool -> ChannelFuture: addListener
activate ChannelFuture
ChannelFuture --> NettyChannelPool:
deactivate ChannelFuture
NettyChannelPool --> SimpleChannelPool:
deactivate NettyChannelPool
T2 -> ChannelFuture: setSuccess
activate ChannelFuture
ChannelFuture -> ChannelFuture: done
activate ChannelFuture
ChannelFuture --> ChannelFuture:
deactivate ChannelFuture
SimpleChannelPool -> ChannelFuture: isDone
activate ChannelFuture
ChannelFuture --> SimpleChannelPool:
deactivate ChannelFuture
alt isDone case
SimpleChannelPool -> NettyChannelTracker: channelAcquired
activate NettyChannelTracker
NettyChannelTracker --> SimpleChannelPool:
deactivate NettyChannelTracker
end
SimpleChannelPool --> T1:
deactivate SimpleChannelPool
ChannelFuture -> NettyChannelTracker: channelCreated
activate NettyChannelTracker
NettyChannelTracker -> ChannelFuture:
deactivate NettyChannelTracker
ChannelFuture -> T2:
deactivate ChannelFuture
@enduml
```
1 parent ed2e4fe commit e30888a
File tree
1 file changed
+22
-15
lines changed- driver/src/main/java/org/neo4j/driver/internal/async/pool
1 file changed
+22
-15
lines changedLines changed: 22 additions & 15 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
21 | 21 | | |
22 | 22 | | |
23 | 23 | | |
| 24 | + | |
24 | 25 | | |
25 | 26 | | |
26 | 27 | | |
| |||
66 | 67 | | |
67 | 68 | | |
68 | 69 | | |
69 | | - | |
70 | | - | |
71 | | - | |
72 | | - | |
73 | | - | |
74 | | - | |
75 | | - | |
76 | | - | |
77 | | - | |
78 | | - | |
79 | | - | |
80 | | - | |
81 | | - | |
82 | | - | |
83 | | - | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
| 90 | + | |
84 | 91 | | |
85 | 92 | | |
86 | 93 | | |
| |||
0 commit comments