Fixed another bug

darkcoderrises · darkcoderrises · commit 8aff3c898315 · 2023-09-15T19:15:26.000+05:30
diff --git a/posting/lists.go b/posting/lists.go
@@ -254,12 +254,18 @@ func (lc *LocalCache) getInternal(key []byte, readFromDisk bool) (*List, error)
 func (lc *LocalCache) GetSinglePosting(key []byte) (*pb.PostingList, error) {
 	pl := &pb.PostingList{}
 	validatePl := func() {
+		i := 0
 		for _, postings := range pl.Postings {
 			if hasDeleteAll(postings) {
 				pl = nil
 				return
 			}
+			if postings.Op != Del {
+				pl.Postings[i] = postings
+				i++
+			}
 		}
+		pl.Postings = pl.Postings[:i]
 	}
 	lc.RLock()
 	if delta, ok := lc.deltas[string(key)]; ok && len(delta) > 0 {

Original file line number	Diff line number	Diff line change
`@@ -254,12 +254,18 @@ func (lc LocalCache) getInternal(key []byte, readFromDisk bool) (List, error)`
`254`	`254`	`func (lc LocalCache) GetSinglePosting(key []byte) (pb.PostingList, error) {`
`255`	`255`	`pl := &pb.PostingList{}`
`256`	`256`	`validatePl := func() {`
	`257`	`+ i := 0`
`257`	`258`	`for _, postings := range pl.Postings {`
`258`	`259`	`if hasDeleteAll(postings) {`
`259`	`260`	`pl = nil`
`260`	`261`	`return`
`261`	`262`	`}`
	`263`	`+ if postings.Op != Del {`
	`264`	`+ pl.Postings[i] = postings`
	`265`	`+ i++`
	`266`	`+ }`
`262`	`267`	`}`
	`268`	`+ pl.Postings = pl.Postings[:i]`
`263`	`269`	`}`
`264`	`270`	`lc.RLock()`
`265`	`271`	`if delta, ok := lc.deltas[string(key)]; ok && len(delta) > 0 {`