Index: impl/memory/datastore_index.go |
diff --git a/impl/memory/datastore_index.go b/impl/memory/datastore_index.go |
index db79a3b5ecb03c68d90d71c5ce497d9cc67cac3d..0126034d2bd2d610633528d16782e0f5742783a6 100644 |
--- a/impl/memory/datastore_index.go |
+++ b/impl/memory/datastore_index.go |
@@ -224,7 +224,7 @@ func mergeIndexes(ns string, store, oldIdx, newIdx *memStore) { |
}) |
} |
-func addIndexes(store *memStore, ns string, compIdx []*ds.IndexDefinition) { |
+func addIndexes(store *memStore, aid, ns string, compIdx []*ds.IndexDefinition) { |
normalized := make([]*ds.IndexDefinition, len(compIdx)) |
idxColl := store.SetCollection("idx", nil) |
for i, idx := range compIdx { |
@@ -234,10 +234,10 @@ func addIndexes(store *memStore, ns string, compIdx []*ds.IndexDefinition) { |
if allEnts := store.GetCollection("ents:" + ns); allEnts != nil { |
allEnts.VisitItemsAscend(nil, true, func(i *gkvlite.Item) bool { |
- pm, err := rpmWoCtx(i.Val, ns) |
+ pm, err := rpm(i.Val) |
memoryCorruption(err) |
- prop, err := serialize.ReadProperty(bytes.NewBuffer(i.Key), serialize.WithoutContext, globalAppID, ns) |
+ prop, err := serialize.ReadProperty(bytes.NewBuffer(i.Key), serialize.WithoutContext, aid, ns) |
memoryCorruption(err) |
k := prop.Value().(*ds.Key) |