Skip to content

Commit b7a85da

Browse files
committed
fix: fix access
1 parent d9f674e commit b7a85da

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
@@ -169,8 +169,8 @@ impl<T> Producer<T> {
169169
all(target_arch = "x86_64", target_feature = "sse")
170170
))]
171171
unsafe {
172-
let next_index = next_head & self.queue.mask.0;
173-
let next_slot = self.queue.buffer.0.add(next_index);
172+
let next_index = next_head & self.queue.0.mask.0;
173+
let next_slot = self.queue.0.buffer.0.add(next_index);
174174
prefetch_write(next_slot as *const u8);
175175
}
176176

@@ -282,8 +282,8 @@ impl<T> Consumer<T> {
282282
))]
283283
unsafe {
284284
let next_tail = tail.wrapping_add(1);
285-
let next_index = next_tail & self.queue.mask.0;
286-
let next_slot = self.queue.buffer.0.add(next_index);
285+
let next_index = next_tail & self.queue.0.mask.0;
286+
let next_slot = self.queue.0.buffer.0.add(next_index);
287287
prefetch_read(next_slot as *const u8);
288288
}
289289

0 commit comments

Comments
 (0)