fix a bug in FEC non-time continuous parityshard

xtaci · Aug 28, 2024 · 05aede1 · 05aede1
1 parent 7296a7b
commit 05aede1
Showing 1 changed file with 4 additions and 0 deletions.
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