| Index: impl/memory/datastore.go
|
| diff --git a/impl/memory/datastore.go b/impl/memory/datastore.go
|
| index 84f5adddb53b2fbbb571bed4ff50c868532da881..5b8581a71c8d9e6c3623086b949c3b7b613784dd 100644
|
| --- a/impl/memory/datastore.go
|
| +++ b/impl/memory/datastore.go
|
| @@ -64,20 +64,20 @@ 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.ns, false, idx, head, cb)
|
| + err := executeQuery(fq, d.data.aid, d.ns, false, idx, head, cb)
|
| if d.data.maybeAutoIndex(err) {
|
| idx, head = d.data.getQuerySnaps(!fq.EventuallyConsistent())
|
| - err = executeQuery(fq, d.ns, false, idx, head, cb)
|
| + err = executeQuery(fq, d.data.aid, d.ns, false, idx, head, cb)
|
| }
|
| return err
|
| }
|
|
|
| func (d *dsImpl) Count(fq *ds.FinalizedQuery) (ret int64, err error) {
|
| idx, head := d.data.getQuerySnaps(!fq.EventuallyConsistent())
|
| - ret, err = countQuery(fq, d.ns, false, idx, head)
|
| + ret, err = countQuery(fq, d.data.aid, d.ns, false, idx, head)
|
| if d.data.maybeAutoIndex(err) {
|
| idx, head := d.data.getQuerySnaps(!fq.EventuallyConsistent())
|
| - ret, err = countQuery(fq, d.ns, false, idx, head)
|
| + ret, err = countQuery(fq, d.data.aid, d.ns, false, idx, head)
|
| }
|
| return
|
| }
|
| @@ -174,11 +174,11 @@ 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.ns, true, d.data.snap, d.data.snap, cb)
|
| + return executeQuery(q, d.data.parent.aid, d.ns, true, d.data.snap, d.data.snap, cb)
|
| }
|
|
|
| func (d *txnDsImpl) Count(fq *ds.FinalizedQuery) (ret int64, err error) {
|
| - return countQuery(fq, d.ns, true, d.data.snap, d.data.snap)
|
| + return countQuery(fq, d.data.parent.aid, d.ns, true, d.data.snap, d.data.snap)
|
| }
|
|
|
| func (*txnDsImpl) RunInTransaction(func(c context.Context) error, *ds.TransactionOptions) error {
|
|
|