aboutsummaryrefslogtreecommitdiff
path: root/src/analytics/analytics_thread.zig
diff options
context:
space:
mode:
Diffstat (limited to 'src/analytics/analytics_thread.zig')
-rw-r--r--src/analytics/analytics_thread.zig5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/analytics/analytics_thread.zig b/src/analytics/analytics_thread.zig
index 62486b779..e45359ddb 100644
--- a/src/analytics/analytics_thread.zig
+++ b/src/analytics/analytics_thread.zig
@@ -8,6 +8,7 @@ const Fs = @import("../fs.zig");
const Analytics = @import("./analytics_schema.zig").analytics;
const Writer = @import("./analytics_schema.zig").Writer;
const Headers = @import("../javascript/jsc/webcore/response.zig").Headers;
+const Futex = @import("../futex.zig");
fn NewUint64(val: u64) Analytics.Uint64 {
const bytes = std.mem.asBytes(&val);
@@ -302,7 +303,7 @@ pub fn enqueue(comptime name: EventName) void {
var items = [_]Event{Event.init(name)};
_ = event_queue.write(&items) catch false;
- std.Thread.Futex.wake(&counter, 1);
+ Futex.wake(&counter, 1);
}
pub var thread: std.Thread = undefined;
@@ -364,7 +365,7 @@ fn readloop() anyerror!void {
event_list.flush();
}
- std.Thread.Futex.wait(&counter, counter.load(.Acquire), null) catch unreachable;
+ Futex.wait(&counter, counter.load(.Acquire), null) catch unreachable;
}
}