We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9dbaf80 commit 8d90676Copy full SHA for 8d90676
tracker/progress.go
@@ -165,12 +165,7 @@ func (pr *Progress) SentEntries(entries int, bytes uint64) {
165
// consider this message being a probe, so that the flow is paused.
166
pr.MsgAppFlowPaused = pr.Inflights.Full()
167
case StateProbe:
168
- // TODO(pavelkalinnikov): this condition captures the previous behaviour,
169
- // but we should set MsgAppFlowPaused unconditionally for simplicity, because any
170
- // MsgApp in StateProbe is a probe, not only non-empty ones.
171
- if entries > 0 {
172
- pr.MsgAppFlowPaused = true
173
- }
+ pr.MsgAppFlowPaused = true
174
default:
175
panic(fmt.Sprintf("sending append in unhandled state %s", pr.State))
176
}
0 commit comments