Aliaksandr Valialkin d107dee9c7 lib/writeconcurrencylimiter: remove Reader.DecConcurrency() method ...

Call decConcurrency() inside Reader.Read() before calling the Read() at the underlying reader.
This reduces chances of improper use of the writeconcurrencylimiter.Reader by callers.

While at it, move the creation of writeconcurrencylimiter.GetReader() to the top of stream parser functions
at lib/protoparser/* packages, and call incConcurrency() inside GetReader() call.
This reduces the frequency of decConcurrency() / incConcurrency() calls
for typical buffered reads when parsing the incoming data. This, in turn,
reduces the contention on the concurrencyLimitCh.

2026-01-14 22:55:17 +01:00

..

stream

lib/writeconcurrencylimiter: remove Reader.DecConcurrency() method

2026-01-14 22:55:17 +01:00