Skip to content

Commit 1f0cc5f

Browse files
added filter for vector lengths
1 parent 6309e2c commit 1f0cc5f

2 files changed

Lines changed: 8 additions & 3 deletions

File tree

posting/list.go

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -404,13 +404,18 @@ func (mm *MutableLayer) print() string {
404404
if mm == nil {
405405
return ""
406406
}
407-
return fmt.Sprintf("Committed List: %+v Proposed list: %+v Delete all marker: %d \n",
407+
return fmt.Sprintf("Committed List: %+v Proposed list: %+v Delete all marker: %d. Count: %d \n",
408408
mm.committedEntries,
409409
mm.currentEntries,
410-
mm.deleteAllMarker)
410+
mm.deleteAllMarker,
411+
mm.length)
411412
}
412413

413414
func (l *List) Print() string {
415+
if l.plist.Pack != nil {
416+
uids := codec.Decode(l.plist.Pack, 0)
417+
return fmt.Sprintf("minTs: %d, committed uids: %+v, mutationMap: %s", l.minTs, uids, l.mutationMap.print())
418+
}
414419
return fmt.Sprintf("minTs: %d, plist: %+v, mutationMap: %s", l.minTs, l.plist, l.mutationMap.print())
415420
}
416421

posting/mvcc.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ func (ir *incrRollupi) rollUpKey(writer *TxnWriter, key []byte) error {
131131
}
132132
newLength := codec.ExactLen(pl.Pack)
133133
if newLength != length {
134-
fmt.Println(l.Print(), pl.Pack)
134+
fmt.Println(l.Print())
135135
panic(errors.Errorf("New length %d does not match old length %d", newLength, length))
136136
}
137137

0 commit comments

Comments
 (0)