diff options
| author | Robby Zambito <contact@robbyzambito.me> | 2026-01-02 14:34:29 +0000 |
|---|---|---|
| committer | Robby Zambito <contact@robbyzambito.me> | 2026-01-02 14:34:32 +0000 |
| commit | 539255adb1f0a681ff49ebfb9e1e3c7198ad5310 (patch) | |
| tree | cb56e62bacee3721e5c2480a0d5dee76f62d5f58 /src/server | |
| parent | faa552969ddeb1f083022cfd17a9f4f5764c201b (diff) | |
broke 100 mbps!!
coder@08714a4174bb:~$ nats bench sub foo -s localhost:4223
14:33:02 Starting Core NATS subscriber benchmark [clients=1, msg-size=128 B, msgs=100,000, multi-subject=false, subject=foo]
14:33:02 [1] Starting Core NATS subscriber, expecting 100,000 messages
Finished 0s [===============================================================================================================================] 100%
NATS Core NATS subscriber stats: 934,205 msgs/sec ~ 114 MiB/sec ~ 1.07us
Diffstat (limited to 'src/server')
| -rw-r--r-- | src/server/main.zig | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/server/main.zig b/src/server/main.zig index d8cf1d7..59dfa94 100644 --- a/src/server/main.zig +++ b/src/server/main.zig @@ -147,12 +147,12 @@ fn handleConnection( //const allocator = if (builtin.mode == .Debug or builtin.mode == .ReleaseSafe) client_allocator.allocator() else server_allocator; // Set up client writer - var w_buffer: [1024]u8 = undefined; + var w_buffer: [1024*16]u8 = undefined; var writer = stream.writer(io, &w_buffer); const out = &writer.interface; // Set up client reader - var r_buffer: [1024]u8 = undefined; + var r_buffer: [1024*16]u8 = undefined; var reader = stream.reader(io, &r_buffer); const in = &reader.interface; |