Skip to content

Commit d3a021f

Browse files
committed
cleanup ctx checks in handleUidPostings and filterGeoFunction
1 parent c3cb714 commit d3a021f

1 file changed

Lines changed: 11 additions & 13 deletions

File tree

worker/task.go

Lines changed: 11 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -804,15 +804,10 @@ func (qs *queryState) handleUidPostings(
804804
outputs[start/width] = out
805805

806806
for i := start; i < end; i++ {
807-
select {
808-
case <-egCtx.Done():
809-
return egCtx.Err()
810-
default:
811-
}
812807
if i%100 == 0 {
813808
select {
814-
case <-ctx.Done():
815-
return ctx.Err()
809+
case <-egCtx.Done():
810+
return egCtx.Err()
816811
default:
817812
}
818813
}
@@ -1605,12 +1600,15 @@ func (qs *queryState) filterGeoFunction(ctx context.Context, arg funcArgs) error
16051600
filter := func(idx, start, end int) error {
16061601
filtered[idx] = &pb.List{}
16071602
out := filtered[idx]
1608-
for _, uid := range uids.Uids[start:end] {
1609-
select {
1610-
case <-egCtx.Done():
1611-
return egCtx.Err()
1612-
default:
1613-
}
1603+
for i := start; i < end; i++ {
1604+
uid := uids.Uids[i]
1605+
if i%100 == 0 {
1606+
select {
1607+
case <-egCtx.Done():
1608+
return egCtx.Err()
1609+
default:
1610+
}
1611+
}
16141612
pl, err := qs.cache.Get(x.DataKey(attr, uid))
16151613
if err != nil {
16161614
return err

0 commit comments

Comments
 (0)