| Index: impl/memory/datastore.go
|
| diff --git a/impl/memory/datastore.go b/impl/memory/datastore.go
|
| index c01b4d4120a9f547e5de0d9675524ddc3f9198ee..677264634738ffc7b1141a66f11f01480442deab 100644
|
| --- a/impl/memory/datastore.go
|
| +++ b/impl/memory/datastore.go
|
| @@ -92,10 +92,10 @@ func (d *dsImpl) DecodeCursor(s string) (ds.Cursor, error) {
|
|
|
| func (d *dsImpl) Run(fq *ds.FinalizedQuery, cb ds.RawRunCB) error {
|
| idx, head := d.data.getQuerySnaps(!fq.EventuallyConsistent())
|
| - err := executeQuery(fq, d.kc, false, idx, head, cb)
|
| + err := executeQuery(fq, d.kc, false, false, idx, head, cb)
|
| if d.data.maybeAutoIndex(err) {
|
| idx, head = d.data.getQuerySnaps(!fq.EventuallyConsistent())
|
| - err = executeQuery(fq, d.kc, false, idx, head, cb)
|
| + err = executeQuery(fq, d.kc, false, false, idx, head, cb)
|
| }
|
| return err
|
| }
|
| @@ -207,7 +207,7 @@ func (d *txnDsImpl) Run(q *ds.FinalizedQuery, cb ds.RawRunCB) error {
|
| // It's possible that if you have full-consistency and also auto index enabled
|
| // that this would make sense... but at that point you should probably just
|
| // add the index up front.
|
| - return executeQuery(q, d.kc, true, d.data.snap, d.data.snap, cb)
|
| + return executeQuery(q, d.kc, true, false, d.data.snap, d.data.snap, cb)
|
| }
|
|
|
| func (d *txnDsImpl) Count(fq *ds.FinalizedQuery) (ret int64, err error) {
|
| @@ -219,7 +219,7 @@ func (*txnDsImpl) RunInTransaction(func(c context.Context) error, *ds.Transactio
|
| }
|
|
|
| func (d *txnDsImpl) WithoutTransaction() context.Context {
|
| - return context.WithValue(d, currentTxnKey, nil)
|
| + return context.WithValue(d, ¤tTxnKey, nil)
|
| }
|
|
|
| func (d *txnDsImpl) CurrentTransaction() ds.Transaction {
|
|
|