Serve Unix and TCP 9P through cloud9.serve's std.Io runner

The hand-written poll loop for Unix/TCP listeners is replaced by
cloud9.serve.Runner; requests are queued to the editor thread, which answers
them under the connection lock on each frame and retries parked reads as
before. QUIC keeps the poll path (its adapter is fd based). The detached
server no longer loses a wake that lands between frames. The firmware path
keeps driving the engine with push/step. cloud9 re-pinned.

Co-Authored-By: Claude Fable 5.1 <[email protected]>

1 files changed, 3 insertions, 3 deletions

diff --git a/src/gui/gui.zig b/src/gui/gui.zig
index dbad10d4..27f3346c 100644
--- a/src/gui/gui.zig
+++ b/src/gui/gui.zig
@@ -2382,7 +2382,7 @@ fn localSession(
         inotify_fd = -1;
     };
     var watches: file_watch.Table = @splat(null);
-    var fs = ninep_io.start(gpa, core);
+    var fs = ninep_io.start(io, gpa, core);
     defer if (fs) |f| f.deinit(gpa);
 
     var shell: Shell = .{
@@ -2412,7 +2412,7 @@ fn localSession(
         watch_stop = try stopPipe();
         watch_reader = try std.Thread.spawn(.{}, watchThread, .{ inotify_fd, watch_stop[0], &queue });
     }
-    if (fs) |f| try f.wakeThread(&queue, wakeFs);
+    if (fs) |f| try f.watch(&queue, wakeFs);
 
     _ = c.SDL_StartTextInput(g.window);
 
@@ -2680,7 +2680,7 @@ fn runGrid(init: std.process.Init, opts_in: pardes.Options) !void {
     var pipe_tasks: PipeTasks = .{};
     defer pipe_tasks.cancelAll(io);
     var watches: file_watch.Table = @splat(null);
-    const fs = ninep_io.start(gpa, core);
+    const fs = ninep_io.start(io, gpa, core);
     defer if (fs) |f| f.deinit(gpa);
     var shell: Shell = .{
         .core = core,