Fix warning message

torcolvin · torcolvin · commit e22a3ca210e3 · 2026-05-27T11:22:34.000-04:00
diff --git a/base/dcp_common.go b/base/dcp_common.go
@@ -231,10 +231,8 @@ func (c *DCPCommon) updateSeq(vbucketId uint16, seq uint64, warnOnLowerSeqNo boo
 	if c.endSeqNos != nil {
 		endSeq, ok := c.endSeqNos[vbucketId]
 		if !ok {
-			AssertfCtx(c.loggingCtx, "Received DCP event for vbno %d which is greater than endSeqNos we have for that vbno", vbucketId)
-		}
-		// Checkpoints
-		if seq > endSeq {
+			AssertfCtx(c.loggingCtx, "Received DCP event for vbno %d which is not tracked by the expected endSeqNos %#+v. This means that endSeqNos was specified with the incorrect number of vBuckets", vbucketId, c.endSeqNos)
+		} else if seq > endSeq {
 			return
 		}
 	}

Original file line number	Diff line number	Diff line change
`@@ -231,10 +231,8 @@ func (c *DCPCommon) updateSeq(vbucketId uint16, seq uint64, warnOnLowerSeqNo boo`
`231`	`231`	`if c.endSeqNos != nil {`
`232`	`232`	`endSeq, ok := c.endSeqNos[vbucketId]`
`233`	`233`	`if !ok {`
`234`		`- AssertfCtx(c.loggingCtx, "Received DCP event for vbno %d which is greater than endSeqNos we have for that vbno", vbucketId)`
`235`		`- }`
`236`		`- // Checkpoints`
`237`		`- if seq > endSeq {`
	`234`	`+ AssertfCtx(c.loggingCtx, "Received DCP event for vbno %d which is not tracked by the expected endSeqNos %#+v. This means that endSeqNos was specified with the incorrect number of vBuckets", vbucketId, c.endSeqNos)`
	`235`	`+ } else if seq > endSeq {`
`238`	`236`	`return`
`239`	`237`	`}`
`240`	`238`	`}`