public/browser
1
0
Fork 0
mirror of https://github.com/lightpanda-io/browser.git synced 2026-03-22 04:34:44 +00:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

mcp: modernize I/O processing and reuse message buffer

Browse Source
This commit is contained in:
Adrià Arrufat
2026-03-01 22:35:28 +09:00
parent e9c36fd6f8
commit 42b5e32473
1 changed files with 15 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/mcp/router.zig
View File

@@ -18,13 +18,22 @@ pub fn processRequests(server: *Server) !void {
var arena: std.heap.ArenaAllocator = .init(server.allocator); var arena: std.heap.ArenaAllocator = .init(server.allocator);
defer arena.deinit(); defer arena.deinit();
while (server.is_running.load(.acquire)) { var msg_buf = std.Io.Writer.Allocating.init(server.allocator);
const msg = stdin.interface.adaptToOldInterface().readUntilDelimiterAlloc(server.allocator, '\n', 1024 * 1024 * 10) catch |err| { defer msg_buf.deinit();
if (err == error.EndOfStream) break;
return err;
};
defer server.allocator.free(msg);
while (server.is_running.load(.acquire)) {
msg_buf.clearRetainingCapacity();
const n = try stdin.interface.streamDelimiterLimit(&msg_buf.writer, '\n', .limited(1024 * 1024 * 10));
var found_newline = true;
_ = stdin.interface.discardDelimiterInclusive('\n') catch |err| switch (err) {
error.EndOfStream => found_newline = false,
else => return err,
};
if (n == 0 and !found_newline) break;
const msg = msg_buf.written();
if (msg.len == 0) continue; if (msg.len == 0) continue;
handleMessage(server, arena.allocator(), msg) catch |err| { handleMessage(server, arena.allocator(), msg) catch |err| {