-
Notifications
You must be signed in to change notification settings - Fork 3
Open
Labels
enhancementNew feature or requestNew feature or requestgood first issueGood for newcomersGood for newcomers
Description
Equip SMF-Client with back pressure mechanism, basically, this method have to check if channel is writable,
public void executeAsync(long methodMeta, byte[] body, final Consumer<ByteBuffer> callback) {
int sessionId = sessionIdGenerator.next();
LOG.info("Constructing RPC call for sessionId {}", sessionId);
final RpcRequest rpcRequest = new RpcRequest(sessionId, methodMeta, body, callback);
dispatcher.assignCallback(sessionId, rpcRequest.getCallback());
//channel.isWritable() has to be checked before.
channel.writeAndFlush(rpcRequest);
}otherwise, we can just kill GC, because it will not be able to keep up.
Metadata
Metadata
Assignees
Labels
enhancementNew feature or requestNew feature or requestgood first issueGood for newcomersGood for newcomers