aboutsummaryrefslogtreecommitdiff
path: root/std/atomic/queue.zig
diff options
context:
space:
mode:
Diffstat (limited to 'std/atomic/queue.zig')
-rw-r--r--std/atomic/queue.zig20
1 files changed, 10 insertions, 10 deletions
diff --git a/std/atomic/queue.zig b/std/atomic/queue.zig
index e1cadf5d1c..c0c050f0ba 100644
--- a/std/atomic/queue.zig
+++ b/std/atomic/queue.zig
@@ -7,7 +7,7 @@ const assert = std.debug.assert;
/// Many producer, many consumer, non-allocating, thread-safe.
/// Uses a mutex to protect access.
pub fn Queue(comptime T: type) type {
- return struct {
+ return struct.{
head: ?*Node,
tail: ?*Node,
mutex: std.Mutex,
@@ -16,7 +16,7 @@ pub fn Queue(comptime T: type) type {
pub const Node = std.LinkedList(T).Node;
pub fn init() Self {
- return Self{
+ return Self.{
.head = null,
.tail = null,
.mutex = std.Mutex.init(),
@@ -126,7 +126,7 @@ pub fn Queue(comptime T: type) type {
};
}
-const Context = struct {
+const Context = struct.{
allocator: *std.mem.Allocator,
queue: *Queue(i32),
put_sum: isize,
@@ -154,7 +154,7 @@ test "std.atomic.Queue" {
var a = &fixed_buffer_allocator.allocator;
var queue = Queue(i32).init();
- var context = Context{
+ var context = Context.{
.allocator = a,
.queue = &queue,
.put_sum = 0,
@@ -198,7 +198,7 @@ fn startPuts(ctx: *Context) u8 {
while (put_count != 0) : (put_count -= 1) {
std.os.time.sleep(1); // let the os scheduler be our fuzz
const x = @bitCast(i32, r.random.scalar(u32));
- const node = ctx.allocator.create(Queue(i32).Node{
+ const node = ctx.allocator.create(Queue(i32).Node.{
.prev = undefined,
.next = undefined,
.data = x,
@@ -226,14 +226,14 @@ fn startGets(ctx: *Context) u8 {
test "std.atomic.Queue single-threaded" {
var queue = Queue(i32).init();
- var node_0 = Queue(i32).Node{
+ var node_0 = Queue(i32).Node.{
.data = 0,
.next = undefined,
.prev = undefined,
};
queue.put(&node_0);
- var node_1 = Queue(i32).Node{
+ var node_1 = Queue(i32).Node.{
.data = 1,
.next = undefined,
.prev = undefined,
@@ -242,14 +242,14 @@ test "std.atomic.Queue single-threaded" {
assert(queue.get().?.data == 0);
- var node_2 = Queue(i32).Node{
+ var node_2 = Queue(i32).Node.{
.data = 2,
.next = undefined,
.prev = undefined,
};
queue.put(&node_2);
- var node_3 = Queue(i32).Node{
+ var node_3 = Queue(i32).Node.{
.data = 3,
.next = undefined,
.prev = undefined,
@@ -260,7 +260,7 @@ test "std.atomic.Queue single-threaded" {
assert(queue.get().?.data == 2);
- var node_4 = Queue(i32).Node{
+ var node_4 = Queue(i32).Node.{
.data = 4,
.next = undefined,
.prev = undefined,