mirror of
https://git.robbyzambito.me/zits
synced 2026-02-04 19:54:48 +00:00
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
This commit is contained in:
@@ -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;
|
||||
|
||||
|
||||
Reference in New Issue
Block a user