updates: don't try to fetch one more difference when context has been cancelled
This commit is contained in:
@@ -169,9 +169,6 @@ func (s *internalState) Run(ctx context.Context) error {
|
||||
for {
|
||||
select {
|
||||
case <-ctx.Done():
|
||||
if len(s.pts.pending) > 0 || len(s.qts.pending) > 0 || len(s.seq.pending) > 0 {
|
||||
s.getDifferenceLogger(ctx)
|
||||
}
|
||||
return ctx.Err()
|
||||
case u := <-s.externalQueue:
|
||||
ctx := trace.ContextWithSpanContext(ctx, u.span)
|
||||
|
||||
@@ -112,10 +112,6 @@ func (s *channelState) Run(ctx context.Context) error {
|
||||
s.log.Debug("Gap timeout")
|
||||
s.getDifferenceLogger(ctx)
|
||||
case <-ctx.Done():
|
||||
if len(s.pts.pending) > 0 {
|
||||
// This will probably fail.
|
||||
s.getDifferenceLogger(ctx)
|
||||
}
|
||||
return ctx.Err()
|
||||
case <-s.idleTimeout.C:
|
||||
s.log.Debug("Idle timeout")
|
||||
|
||||
Reference in New Issue
Block a user