const std = @import("std"); const os = std.os; const mem = std.mem; const meta = std.meta; const atomic = std.atomic; const builtin = std.builtin; const testing = std.testing; const assert = std.debug.assert; const mpsc = @This(); pub const cache_line_length = switch (@import("builtin").target.cpu.arch) { .x86_64, .aarch64, .powerpc64 => 128, .arm, .mips, .mips64, .riscv64 => 32, .s390x => 256, else => 64, }; pub fn UnboundedQueue(comptime T: type, comptime next_field: meta.FieldEnum(T)) type { const next_name = meta.fieldInfo(T, next_field).name; return struct { const Self = @This(); pub const Batch = struct { pub const Iterator = struct { batch: Self.Batch, pub fn next(self: *Self.Batch.Iterator) ?*T { if (self.batch.count == 0) return null; const front = self.batch.front orelse unreachable; self.batch.front = @field(front, next_name); self.batch.count -= 1; return front; } }; front: ?*T = null, last: ?*T = null, count: usize = 0, pub fn iterator(self: Self.Batch) Self.Batch.Iterator { return .{ .batch = self }; } }; const next = next_name; pub const queue_padding_length = cache_line_length / 2; back: ?*T align(queue_padding_length) = null, count: usize = 0, front: T align(queue_padding_length) = init: { var stub: T = undefined; @field(stub, next) = null; break :init stub; }, pub fn push(self: *Self, src: *T) void { assert(@atomicRmw(usize, &self.count, .Add, 1, .Release) >= 0); @field(src, next) = null; const old_back = @atomicRmw(?*T, &self.back, .Xchg, src, .AcqRel) orelse &self.front; @field(old_back, next) = src; } pub fn pushBatch(self: *Self, first: *T, last: *T, count: usize) void { assert(@atomicRmw(usize, &self.count, .Add, count, .Release) >= 0); @field(last, next) = null; const old_back = @atomicRmw(?*T, &self.back, .Xchg, last, .AcqRel) orelse &self.front; @field(old_back, next) = first; } pub fn pop(self: *Self) ?*T { const first = @atomicLoad(?*T, &@field(self.front, next), .Acquire) orelse return null; if (@atomicLoad(?*T, &@field(first, next), .Acquire)) |next_item| { @atomicStore(?*T, &@field(self.front, next), next_item, .Monotonic); assert(@atomicRmw(usize, &self.count, .Sub, 1, .Monotonic) >= 1); return first; } const last = @atomicLoad(?*T, &self.back, .Acquire) orelse &self.front; if (first != last) return null; @atomicStore(?*T, &@field(self.front, next), null, .Monotonic); if (@cmpxchgStrong(?*T, &self.back, last, &self.front, .AcqRel, .Acquire) == null) { assert(@atomicRmw(usize, &self.count, .Sub, 1, .Monotonic) >= 1); return first; } var next_item = @atomicLoad(?*T, &@field(first, next), .Acquire); while (next_item == null) : (atomic.spinLoopHint()) { next_item = @atomicLoad(?*T, &@field(first, next), .Acquire); } @atomicStore(?*T, &@field(self.front, next), next_item, .Monotonic); assert(@atomicRmw(usize, &self.count, .Sub, 1, .Monotonic) >= 1); return first; } pub fn popBatch(self: *Self) Self.Batch { var batch: Self.Batch = .{}; var front = @atomicLoad(?*T, &@field(self.front, next), .Acquire) orelse return batch; batch.front = front; var next_item = @atomicLoad(?*T, &@field(front, next), .Acquire); while (next_item) |next_node| : (next_item = @atomicLoad(?*T, &@field(next_node, next), .Acquire)) { batch.count += 1; batch.last = front; front = next_node; } const last = @atomicLoad(?*T, &self.back, .Acquire) orelse &self.front; if (front != last) { @atomicStore(?*T, &@field(self.front, next), front, .Release); assert(@atomicRmw(usize, &self.count, .Sub, batch.count, .Monotonic) >= batch.count); return batch; } @atomicStore(?*T, &@field(self.front, next), null, .Monotonic); if (@cmpxchgStrong(?*T, &self.back, last, &self.front, .AcqRel, .Acquire) == null) { batch.count += 1; batch.last = front; assert(@atomicRmw(usize, &self.count, .Sub, batch.count, .Monotonic) >= batch.count); return batch; } next_item = @atomicLoad(?*T, &@field(front, next), .Acquire); while (next_item == null) : (atomic.spinLoopHint()) { next_item = @atomicLoad(?*T, &@field(front, next), .Acquire); } batch.count += 1; @atomicStore(?*T, &@field(self.front, next), next_item, .Monotonic); batch.last = front; assert(@atomicRmw(usize, &self.count, .Sub, batch.count, .Monotonic) >= batch.count); return batch; } pub fn peek(self: *Self) usize { const count = @atomicLoad(usize, &self.count, .Acquire); assert(count >= 0); return count; } pub fn isEmpty(self: *Self) bool { return self.peek() == 0; } }; } s Unnamed repository; edit this file 'description' to name the repository.
aboutsummaryrefslogtreecommitdiff
path: root/test/snapshots/array-args-with-default-values.hmr.debug.js (unfollow)
AgeCommit message (Expand)AuthorFilesLines
2023-09-06stuffGravatar dave caruso 2-164/+164
2023-09-06remove native events from streamsGravatar dave caruso 12-979/+425
2023-09-06allocate task for `ThreadSafeFunction` (#4513)Gravatar Dylan Conway 3-4/+18
2023-09-05Update development.md (#4480)Gravatar Derrick Farris 1-1/+1
2023-09-05update root certs (#4499)Gravatar Ciro Spaciari 2-912/+1993
2023-09-05fix text decode trim (#4495)Gravatar Dylan Conway 3-5/+143
2023-09-05Align `process.nextTick` execution order with Node (#4409)Gravatar Jarred Sumner 17-87/+1481
2023-09-05feat(runtime): Implement `fs.watchFile` (#4467)Gravatar dave caruso 17-12/+1309
2023-09-05fix(node:net): emit close event on connection error (#4336)Gravatar dave caruso 3-11/+24
2023-09-05fix(fetch) always use readable stream if it is available (#4503)Gravatar Ciro Spaciari 2-27/+82
2023-09-05fix SSL proxy tunneling on fetch (#4510)Gravatar Ciro Spaciari 2-17/+76
2023-09-05fix(install): ensure all lockfile structs do not have undefined padding (#4401)Gravatar dave caruso 5-2/+113
2023-09-05fix checkout/build failure due to `src/deps/uws` (#4505)Gravatar Alex Lam S.L 5-15/+10
2023-09-05fix ipv6 localhost fetch (#4498)Gravatar Dylan Conway 2-2/+31
2023-09-05minor rebuild diffs (#4486)Gravatar Alex Lam S.L 4-4999/+4999
2023-09-05fix dup syscall on Windows (#4496)Gravatar Jason 2-3/+3
2023-09-04no need to chmod (#4490)Gravatar Dylan Conway 1-2/+0
2023-09-04fix zlib deflate on fetch (#4483)Gravatar Ciro Spaciari 3-8/+47
2023-09-04chore: fix typo (#4476)Gravatar Ai Hoshino 1-1/+1
2023-09-04fix(HTMLRewriter) buffer response before transform (#4418)Gravatar Ciro Spaciari 18-5941/+6655
2023-09-03initialize JSC for macros from cliGravatar Dylan Conway 1-0/+4
2023-09-03fix(syscall): fix handling syscall errno (#4461)Gravatar Ai Hoshino 2-1/+22
2023-09-02workaround a zig bug (#4440)Gravatar dave caruso 1-3/+4
2023-09-01docs: fix http simple example log statement (#4320)Gravatar Karl Böhlmark 1-1/+1
2023-09-01Fix typo (#4445)Gravatar Jorge Jiménez 1-1/+1
2023-09-01keep export star as (#4451)Gravatar Dylan Conway 1-14/+0
2023-09-01bun-vscode 0.0.8Gravatar Colin McDonnell 3-41/+39
2023-09-01Update commandsGravatar Colin McDonnell 3-4/+6
2023-09-01fix `Bun.serve` with tls and `Bun.file` (#4450)Gravatar Dylan Conway 3-14/+40
2023-09-01exclusive maxGravatar Dylan Conway 1-1/+1
2023-09-01Fix debug console from appears on startGravatar Ashcon Partovi 2-2/+5
2023-09-01Add configuration options to extensionGravatar Ashcon Partovi 5-5/+137
2023-09-01Fix run button starting cwd at /Gravatar Ashcon Partovi 1-0/+2
2023-09-01fix(runtime): fix dns_resolver crash (#4435)Gravatar dave caruso 3-17/+19
2023-09-01Fix background colorGravatar Ashcon Partovi 1-2/+3
2023-09-01Allow older versions of VSCodeGravatar Ashcon Partovi 2-6/+5
2023-09-01Fix README for extensionGravatar Ashcon Partovi 2-7/+12
2023-09-01Update VSCode extensionGravatar Ashcon Partovi 1-3/+4
2023-09-01Fix breakpoint on entry for extensionGravatar Ashcon Partovi 5-18/+15
2023-09-01Add Bun.canReload event to inspectorGravatar Ashcon Partovi 2-0/+17
2023-08-31JavaScript Debug Terminal == Bun TerminalGravatar Ashcon Partovi 1-0/+32
2023-08-31fix(runtime): `fs.cp` edge cases (#4439)Gravatar dave caruso 2-8/+44
2023-08-31only set initial debugger breakpoint once (#4441)Gravatar Dylan Conway 1-2/+11
2023-08-31Make breakpoints faster in VSCode extensionGravatar Ashcon Partovi 1-241/+327
2023-08-31`bun install` correctly join dependency URLs (#4421)Gravatar Julian 6-64/+243
2023-08-31get name if not provided in `FormData.append` (#4434)Gravatar Dylan Conway 4-5/+45
2023-08-31Fix vscode debug terminalGravatar Ashcon Partovi 1-21/+0