move to wrapping_add on untrusted join

OliverNChalk · OliverNChalk · commit 2095aa48217c · 2026-03-09T11:58:27.000-05:00
diff --git a/src/spsc.rs b/src/spsc.rs
@@ -463,7 +463,7 @@ impl SharedQueueHeader {
                     actual: header.version,
                 });
             }
-            if header.buffer_mask as usize + 1
+            if (header.buffer_mask as usize).wrapping_add(1)
                 != Self::calculate_buffer_size_in_items::<T>(file_size)?
             {
                 return Err(Error::InvalidBufferSize);

Original file line number	Diff line number	Diff line change
`@@ -463,7 +463,7 @@ impl SharedQueueHeader {`
`463`	`463`	`actual: header.version,`
`464`	`464`	`});`
`465`	`465`	`}`
`466`		`- if header.buffer_mask as usize + 1`
	`466`	`+ if (header.buffer_mask as usize).wrapping_add(1)`
`467`	`467`	`!= Self::calculate_buffer_size_in_items::<T>(file_size)?`
`468`	`468`	`{`
`469`	`469`	`return Err(Error::InvalidBufferSize);`