-
Notifications
You must be signed in to change notification settings - Fork 408
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
RATIS-2096. Add a conf to enable/disable zero copy. #1099
Conversation
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.
@duongkame , thanks for working on this! Please see the comments inlined.
Sorry that I asked to remove the conf earlier!
@@ -170,6 +172,10 @@ RaftPeerId getId() { | |||
|
|||
ServerServiceDefinition bindServiceWithZeroCopy() { | |||
ServerServiceDefinition orig = super.bindService(); | |||
if (!zeroCopyEnabled) { | |||
LOG.info("Zero copy is disabled."); |
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.
Print also the id:
LOG.info("{}: Zero copy is disabled.", getId());
@@ -241,6 +244,10 @@ RaftPeerId getId() { | |||
|
|||
ServerServiceDefinition bindServiceWithZeroCopy() { | |||
ServerServiceDefinition orig = super.bindService(); | |||
if (!zeroCopyEnabled) { | |||
LOG.info("Zero copy is disabled."); |
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.
Print also the id:
LOG.info("{}: Zero copy is disabled.", getId());
Thanks for the review @szetszwo . |
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.
+1 the change looks good.
What changes were proposed in this pull request?
Add a conf to enable/disable zero copy.
What is the link to the Apache JIRA
https://issues.apache.org/jira/browse/RATIS-2096
How was this patch tested?
CI.