Add transaction buffer filter.

impl/memory/datastore_query_execution.go

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package memory
 
 import (
         "bytes"
         "fmt"
 
@@ skipping 125 matching lines @@
         return newNormalStrategy(rq.ns, cb, head)
 }
 
 func parseSuffix(ns string, suffixFormat []ds.IndexColumn, suffix []byte, count int) (raw [][]byte, decoded []ds.Property) {
         buf := serialize.Invertible(bytes.NewBuffer(suffix))
         decoded = make([]ds.Property, len(suffixFormat))
         raw = make([][]byte, len(suffixFormat))
 
         err := error(nil)
         for i := range decoded {
-                if count > 0 && i > count {
+                if count >= 0 && i >= count {
                         break
                 }
                 needInvert := suffixFormat[i].Descending
 
                 buf.SetInvert(needInvert)
                 decoded[i], err = serialize.ReadProperty(buf, serialize.WithoutContext, globalAppID, ns)
                 memoryCorruption(err)
 
                 offset := len(suffix) - buf.Len()
                 raw[i] = suffix[:offset]
@@ skipping 86 matching lines @@
                         impossible(fmt.Errorf("decoded index row doesn't end with a Key: %#v", keyProp))
                 }
 
                 return strategy.handle(
                         rawData, decodedProps, keyProp.Value().(*ds.Key),
                         getCursorFn(suffix))
         })
 
         return nil
 }