From 934360646fd063a84c6527eea059dc40ae0050bb Mon Sep 17 00:00:00 2001 From: Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> Date: Tue, 15 Nov 2022 17:52:04 -0800 Subject: Wip --- src/bun.js/webcore/streams.zig | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) (limited to 'src/bun.js/webcore/streams.zig') diff --git a/src/bun.js/webcore/streams.zig b/src/bun.js/webcore/streams.zig index 6d4fcb6bf..49e214bb7 100644 --- a/src/bun.js/webcore/streams.zig +++ b/src/bun.js/webcore/streams.zig @@ -3162,6 +3162,7 @@ pub const FileBlobLoader = struct { resume this.concurrent.read_frame; } + const ScheduleReadFrame = @Frame(scheduleRead); pub fn scheduleRead(this: *FileBlobLoader) void { if (comptime Environment.isMac) { var remaining = this.buf[this.concurrent.read..]; @@ -3209,14 +3210,15 @@ pub const FileBlobLoader = struct { null, ); - suspend { - var _frame = @frame(); - var this_frame = bun.default_allocator.create(std.meta.Child(@TypeOf(_frame))) catch unreachable; - this_frame.* = _frame.*; - this.concurrent.read_frame = this_frame; - } + // suspend { + // var _frame = @frame(); + // var this_frame = bun.allocateFrame(ScheduleReadFrame) catch unreachable; + // this_frame.* = _frame.*; + // this.concurrent.read_frame = this_frame; + // } + unreachable; - scheduleMainThreadTask(this); + // scheduleMainThreadTask(this); } pub fn onJSThread(task_ctx: *anyopaque) void { -- cgit v1.2.3