diff options
author | 2022-11-29 02:42:56 -0800 | |
---|---|---|
committer | 2022-11-29 02:42:56 -0800 | |
commit | b631ea7d725a42954c577ea686ae711ef04f63e1 (patch) | |
tree | 37852a650a0ec02fd6042919dc476c7dab550529 /src/network_thread.zig | |
parent | 7b59d9d97c4d4543d8fe2a2222781d7b89539fc2 (diff) | |
download | bun-b631ea7d725a42954c577ea686ae711ef04f63e1.tar.gz bun-b631ea7d725a42954c577ea686ae711ef04f63e1.tar.zst bun-b631ea7d725a42954c577ea686ae711ef04f63e1.zip |
import everything from "bun" where possible
Diffstat (limited to 'src/network_thread.zig')
-rw-r--r-- | src/network_thread.zig | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/network_thread.zig b/src/network_thread.zig index f48e94e5a..5590dafa8 100644 --- a/src/network_thread.zig +++ b/src/network_thread.zig @@ -1,15 +1,15 @@ -const ThreadPool = @import("thread_pool"); +const ThreadPool = @import("bun").ThreadPool; pub const Batch = ThreadPool.Batch; pub const Task = ThreadPool.Task; const Node = ThreadPool.Node; pub const Completion = AsyncIO.Completion; const std = @import("std"); -pub const AsyncIO = @import("io"); -const Output = @import("./global.zig").Output; +pub const AsyncIO = @import("bun").AsyncIO; +const Output = @import("bun").Output; const IdentityContext = @import("./identity_context.zig").IdentityContext; const HTTP = @import("./http_client_async.zig"); const NetworkThread = @This(); -const Environment = @import("./global.zig").Environment; +const Environment = @import("bun").Environment; const Lock = @import("./lock.zig").Lock; const FIFO = @import("./io/fifo.zig").FIFO; @@ -26,9 +26,9 @@ pub var global: NetworkThread = undefined; pub var global_loaded: std.atomic.Atomic(u32) = std.atomic.Atomic(u32).init(0); const log = Output.scoped(.NetworkThread, true); -const Global = @import("./global.zig").Global; +const Global = @import("bun").Global; pub fn onStartIOThread(waker: AsyncIO.Waker) void { - NetworkThread.address_list_cached = NetworkThread.AddressListCache.init(@import("./global.zig").default_allocator); + NetworkThread.address_list_cached = NetworkThread.AddressListCache.init(@import("bun").default_allocator); AsyncIO.global = AsyncIO.init(1024, 0, waker) catch |err| { log: { if (comptime Environment.isLinux) { @@ -234,7 +234,7 @@ pub fn init() !void { const fd = try std.os.eventfd(0, std.os.linux.EFD.CLOEXEC | 0); global.waker = .{ .fd = fd }; } else if (comptime Environment.isMac) { - global.waker = try AsyncIO.Waker.init(@import("./global.zig").default_allocator); + global.waker = try AsyncIO.Waker.init(@import("bun").default_allocator); } else { @compileLog("TODO: Waker"); } |