-
Notifications
You must be signed in to change notification settings - Fork 9.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
raft: fast fail while dropping index reading #9567
Conversation
99eff43
to
412c4d2
Compare
@nolouch Have you tested it from etcd point of view? And can you add an integration test for this into etcdserver side? |
ok, I will add the test. |
@@ -449,23 +454,17 @@ func (n *node) stepWait(ctx context.Context, m pb.Message) error { | |||
// Step advances the state machine using msgs. The ctx.Err() will be returned, | |||
// if any. | |||
func (n *node) stepWithWaitOption(ctx context.Context, m pb.Message, wait bool) error { | |||
if m.Type != pb.MsgProp { |
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.
why removing them?
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.
This logic is no longer suitable because the recvc
channel also need to handle the error.
235e0f1
to
06928fc
Compare
Sorry for the delay in this PR. |
closing in favor of #10094 |
The read request will block the following read request until the context timeout when the read message dropped in the raft, try to fast fail in some case.
This pull request is used to fix #9566