Index: impl/memory/datastore_data.go |
diff --git a/impl/memory/datastore_data.go b/impl/memory/datastore_data.go |
index e221c55eee161eb9fda8fece355a4a71da1da546..f0dcc416b9f14ed55711304ee82a1a4dcf6cd6a3 100644 |
--- a/impl/memory/datastore_data.go |
+++ b/impl/memory/datastore_data.go |
@@ -126,7 +126,8 @@ func (d *dataStoreData) getQuerySnaps(consistent bool) (idx, head *memStore) { |
defer d.rwlock.RUnlock() |
if d.snap == nil { |
// we're 'always consistent' |
- return d.head, d.head |
+ snap := d.head.Snapshot() |
+ return snap, snap |
} |
head = d.head.Snapshot() |