diff options
author | 2021-11-20 19:27:18 -0800 | |
---|---|---|
committer | 2021-12-16 19:18:51 -0800 | |
commit | b1660fa46873a9579180f9f02c1f287a97dd8228 (patch) | |
tree | fffd40c5cf6df8544856bd9093c5d2a5b60b1148 /src/http/network_thread.zig | |
parent | 4af743766d9e32789b90e39c761d5e896426d2f3 (diff) | |
download | bun-b1660fa46873a9579180f9f02c1f287a97dd8228.tar.gz bun-b1660fa46873a9579180f9f02c1f287a97dd8228.tar.zst bun-b1660fa46873a9579180f9f02c1f287a97dd8228.zip |
[bun install] async http request works I think?
Diffstat (limited to 'src/http/network_thread.zig')
-rw-r--r-- | src/http/network_thread.zig | 25 |
1 files changed, 25 insertions, 0 deletions
diff --git a/src/http/network_thread.zig b/src/http/network_thread.zig new file mode 100644 index 000000000..d7f9c4409 --- /dev/null +++ b/src/http/network_thread.zig @@ -0,0 +1,25 @@ +const ThreadPool = @import("../thread_pool.zig"); +const Batch = ThreadPool.Batch; +const std = @import("std"); +const AsyncIO = @import("io"); + +const NetworkThread = @This(); + +/// Single-thread in this pool +pool: ThreadPool, + +pub var global: NetworkThread = undefined; +pub var global_loaded: bool = false; + +pub fn init() !void { + AsyncIO.global = try AsyncIO.init(0, 0); + AsyncIO.global_loaded = true; + + global = NetworkThread{ + .pool = ThreadPool.init(.{ .max_threads = 1, .stack_size = 64 * 1024 * 1024 }), + }; + + global.pool.io = &AsyncIO.global; + + global_loaded = true; +} |