afdb78dd5c
There is a potential deadlock scenario if 2 threads try sendReplicatePacket. Thread 1 registers Netty callback which will invoke readyForWrites() method, which locks the callback list and waits on the replicationLock. Thread 2 enters sendReplicatePacket and gets the replicationLock and is blocked on the callback list lock. This fix ensures the sendReplicatePacket blocks on the ReplicationManager meaning no interleaving of the Netty callback thread and the wait on lock can happen. |
||
---|---|---|
.. | ||
src | ||
pom.xml |