Joseph Doherty
ba0d65317a
Improve source XML docs and refresh profiling artifacts
...
This captures the iterative CommentChecker cleanup plus updated snapshot/report outputs used to validate and benchmark the latest JetStream and transport work.
2026-03-14 03:13:17 -04:00
Joseph Doherty
1d4b87e5f9
docs: refresh benchmark comparison with increased message counts
...
Increase message counts across all 14 benchmark test files to reduce
run-to-run variance (e.g. PubSub 16B: 10K→50K, FanOut: 10K→15K,
SinglePub: 100K→500K, JS tests: 5K→25K). Rewrite benchmarks_comparison.md
with fresh numbers from two-batch runs. Key changes: multi 4x4 reached
parity (1.01x), fan-out improved to 0.84x, TLS pub/sub shows 4.70x .NET
advantage, previous small-count anomalies corrected.
2026-03-13 17:52:03 -04:00
Joseph Doherty
a62a25dcdf
perf: optimize fan-out hot path and switch benchmarks to Release build
...
Round 9 optimizations targeting per-delivery overhead:
- Switch benchmark harness from Debug to Release build (biggest impact:
durable fetch 0.42x→0.92x, request-reply to parity)
- Batch server-wide stats after fan-out loop (2 Interlocked per delivery → 2 per publish)
- Guard auto-unsub tracking with MaxMessages > 0 (skip Interlocked in common case)
- Cache SID as ASCII bytes on Subscription (avoid per-delivery encoding)
- Pre-encode subject bytes once before fan-out loop (avoid N encodings)
- Add 1-element subject string cache in ProcessPub (avoid repeated alloc)
- Remove Interlocked from SubList.Match stats counters (approximate is fine)
- Extract WriteMessageToBuffer helper for both string and span overloads
2026-03-13 15:30:02 -04:00
Joseph Doherty
11e01b9026
perf: optimize MQTT cross-protocol path (0.30x → 0.78x Go)
...
Replace per-message async fire-and-forget with direct-buffer write loop
mirroring NatsClient pattern: SpinLock-guarded buffer append, double-
buffer swap, single WriteAsync per batch.
- MqttConnection: add _directBuf/_writeBuf + RunMqttWriteLoopAsync
- MqttConnection: add EnqueuePublishNoFlush (zero-alloc PUBLISH format)
- MqttPacketWriter: add WritePublishTo(Span<byte>) + MeasurePublish
- MqttTopicMapper: add NatsToMqttBytes with bounded ConcurrentDictionary
- MqttNatsClientAdapter: synchronous SendMessageNoFlush + SignalFlush
- Skip FlushAsync on plain TCP sockets (TCP auto-flushes)
2026-03-13 14:25:13 -04:00
Joseph Doherty
20f45b2aaf
Merge branch 'codex/filestore-payload-index-optimization'
2026-03-13 11:36:15 -04:00
Joseph Doherty
ca2d8019a1
docs: add FileStore benchmarks and storage notes
2026-03-13 11:34:19 -04:00
Joseph Doherty
900a4b0923
Merge branch 'codex/sublist-allocation-reduction'
2026-03-13 10:15:46 -04:00
Joseph Doherty
d1f22255d7
docs: record SubList allocation strategy
2026-03-13 10:08:50 -04:00
Joseph Doherty
a3b34fb16d
docs: record parser hot-path allocation strategy
2026-03-13 10:08:20 -04:00
Joseph Doherty
37575dc41c
feat: add benchmark test project for Go vs .NET server comparison
...
Side-by-side performance benchmarks using NATS.Client.Core against both
servers on ephemeral ports. Includes core pub/sub, request/reply latency,
and JetStream throughput tests with comparison output and
benchmarks_comparison.md results. Also fixes timestamp flakiness in
StoreInterfaceTests by using explicit timestamps.
2026-03-13 01:23:31 -04:00
