BurningCN opened a new issue, #4194:
URL: https://github.com/apache/rocketmq/issues/4194

   The `responseFuture` has a `timeoutMillis` attribute, and 
`NettyRemotingClient/Server#timer` will call 
`scheduleAtFixedRate->scanResponseTable`.
   
   If the client initiates an asynchronous request, the response comes, and the 
callback(`ResponseFuture#invokeCallback`) of the asynchronous request is also 
triggered (everything is normal, no timeout). The current code lacks a proper 
place to perform the `responseTable.remove(responseFuture.getOpaque());` 
operation instead of waiting for the `timer` to remove it as a timeout request 
(because it doesn't have a timeout itself).
   
   Just like `invokeSyncImpl`, there are xx operations in the finally block.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to