File tree Expand file tree Collapse file tree 1 file changed +5
-2
lines changed
pkg/kv/kvclient/kvstreamer Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -244,8 +244,7 @@ func (b *requestsProviderBase) close() {
244244}
245245
246246// outOfOrderRequestsProvider is a requestProvider that returns requests in an
247- // arbitrary order (namely in the same order as the requests are enqueued and
248- // added).
247+ // arbitrary order (namely in the LIFO order of requests being enqueued).
249248type outOfOrderRequestsProvider struct {
250249 * requestsProviderBase
251250}
@@ -283,6 +282,8 @@ func (p *outOfOrderRequestsProvider) nextLocked() singleRangeBatch {
283282 if len (p .requests ) == 0 {
284283 panic (errors .AssertionFailedf ("nextLocked called when requestsProvider is empty" ))
285284 }
285+ // Use the last request so that we could reuse its slot if resume request is
286+ // added.
286287 return p .requests [len (p .requests )- 1 ]
287288}
288289
@@ -291,6 +292,8 @@ func (p *outOfOrderRequestsProvider) removeNextLocked() {
291292 if len (p .requests ) == 0 {
292293 panic (errors .AssertionFailedf ("removeNextLocked called when requestsProvider is empty" ))
293294 }
295+ // Use the last request so that we could reuse its slot if resume request is
296+ // added.
294297 p .requests = p .requests [:len (p .requests )- 1 ]
295298}
296299
You can’t perform that action at this time.
0 commit comments