Skip to content

Commit 17dd2e4

Browse files
committed
fix: fix for x86_64
1 parent fe8e063 commit 17dd2e4

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/lib.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -151,8 +151,8 @@ impl<T> Producer<T> {
151151
all(target_arch = "x86_64", target_feature = "sse")
152152
))]
153153
{
154-
let next_index = next_head & self.queue.mask;
155-
let next_slot = self.queue.buffer.add(next_index);
154+
let next_index = next_head & self.queue.mask.0;
155+
let next_slot = self.queue.buffer.0.add(next_index);
156156
prefetch_write(next_slot as *const u8);
157157
}
158158

@@ -223,8 +223,8 @@ impl<T> Consumer<T> {
223223
all(target_arch = "x86_64", target_feature = "sse")
224224
))]
225225
{
226-
let next_index = (tail + 1) & self.queue.mask;
227-
let next_slot = self.queue.buffer.add(next_index);
226+
let next_index = (tail + 1) & self.queue.mask.0;
227+
let next_slot = self.queue.buffer.0.add(next_index);
228228
prefetch_read(next_slot as *const u8);
229229
}
230230

0 commit comments

Comments
 (0)