We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 236221d commit 731e6e9Copy full SHA for 731e6e9
1 file changed
posting/mvcc.go
@@ -642,6 +642,16 @@ func (txn *Txn) UpdateCachedKeys(commitTs uint64) {
642
MemLayerInstance.updateItemInCache(key, delta, txn.StartTs, commitTs)
643
return nil
644
})
645
+ for _, globalMap := range txn.cache.globalMap {
646
+ globalMap.Iterate(func(key string, data *pb.PostingList) error {
647
+ dataBytes, err := proto.Marshal(data)
648
+ if err != nil {
649
+ return err
650
+ }
651
+ MemLayerInstance.updateItemInCache(key, dataBytes, txn.StartTs, commitTs)
652
+ return nil
653
+ })
654
655
}
656
657
func unmarshalOrCopy(plist *pb.PostingList, item *badger.Item) error {
0 commit comments