-
-
Notifications
You must be signed in to change notification settings - Fork 15.8k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[#4284] Forward decoded messages more frequently #4322
Conversation
@Scottmitch PTAL. @ninja- this should help you... |
@normanmaurer looks good to me |
very creative way to keep the full API :P |
for (int i = 0; i < size; i++) { | ||
ctx.fireChannelRead(out.get(i)); | ||
} | ||
fireChannelRead(ctx, out, size); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
move into conditional below?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
yep
@normanmaurer - Few questions. Lookin good. |
c41d044
to
350128e
Compare
@Scottmitch comments addressed |
Motivation: At the moment we only forward decoded messages that were added the out List once the full decode loop was completed. This has the affect that resources may not be released as fast as possible and as an application may incounter higher latency if the user triggeres a writeAndFlush(...) as a result of the decoded messages. Modifications: - forward decoded messages after each decode call Result: Forwarding decoded messages through the pipeline in a more eager fashion.
350128e
to
0f7943c
Compare
Motivation:
At the moment we only forward decoded messages that were added the out List once the full decode loop was completed. This has the affect that resources may not be released as fast as possible and as an application may incounter higher latency if the user triggeres a writeAndFlush(...) as a result of the decoded messages.
Modifications:
Result:
Forwarding decoded messages through the pipeline in a more eager fashion.