Aaron Son b77f2bad8c go/libraries/doltcore/sqle/async_indexed_lookups.go: Fix leaking of results from one index lookup to another. ...

When a query with an index lookup as a LIMIT, it's possible for the result
iterator to be closed before all the index results have been streamed. When
that happens, we can end up with queueRows goroutine which is enqueuing rows
into a ring buffer that is going to be used by a different query later.

This PR adds two mechanisms, one to stop the wrong results from being seen and
to cancel the unnecessary work.

1. RingBuffer gets an epoch, which is incremented on each Reset(). If a given
   Push does not match the current epoch, then nothing is added to the ring
   buffer.

2. queueRows is run with a cancelable (sub-)Context, and that Context is
   canceled when the corresponding iterator is Closed().

2021-03-24 14:11:09 -07:00

..

action_executor_test.go

go/**/*.go: Update copyright headers for company name change.

2020-11-02 10:17:02 -08:00

action_executor.go

go/**/*.go: Update copyright headers for company name change.

2020-11-02 10:17:02 -08:00

async_read_test.go

go/**/*.go: Update copyright headers for company name change.

2020-11-02 10:17:02 -08:00

async_reader.go

go/**/*.go: Update copyright headers for company name change.

2020-11-02 10:17:02 -08:00

errgroup_test.go

go/libraries/util/async/errgroup{,_test}.go: Update copyright headers for Dolthub.

2020-11-02 11:09:44 -08:00

errgroup.go

go/libraries/util/async/errgroup{,_test}.go: Update copyright headers for Dolthub.

2020-11-02 11:09:44 -08:00

ring_buffer_test.go

go/libraries/doltcore/sqle/async_indexed_lookups.go: Fix leaking of results from one index lookup to another.

2021-03-24 14:11:09 -07:00

ring_buffer.go

go/libraries/doltcore/sqle/async_indexed_lookups.go: Fix leaking of results from one index lookup to another.

2021-03-24 14:11:09 -07:00