fix a bug in FEC non-time continuous parityshard

xtaci · xtaci · commit 05aede1bf1eb · 2024-08-28T13:47:30.000+08:00
diff --git a/fec.go b/fec.go
@@ -401,6 +401,10 @@ func (enc *fecEncoder) encode(b []byte, rto uint32) (ps [][]byte) {
 					ps[k] = ps[k][:enc.maxSize]
 				}
 			}
+		} else {
+			// through we do not send non-continuous parity shard, we still increase the next value
+			// to keep the seqid aligned with 0 start
+			enc.next = (enc.next + uint32(enc.parityShards)) % enc.paws
 		}
 
 		// counters resetting

Original file line number	Diff line number	Diff line change
`@@ -401,6 +401,10 @@ func (enc *fecEncoder) encode(b []byte, rto uint32) (ps [][]byte) {`
`401`	`401`	`ps[k] = ps[k][:enc.maxSize]`
`402`	`402`	`}`
`403`	`403`	`}`
	`404`	`+ } else {`
	`405`	`+ // through we do not send non-continuous parity shard, we still increase the next value`
	`406`	`+ // to keep the seqid aligned with 0 start`
	`407`	`+ enc.next = (enc.next + uint32(enc.parityShards)) % enc.paws`
`404`	`408`	`}`
`405`	`409`
`406`	`410`	`// counters resetting`