Hyunsik Kang 6e5cf0ce45 Do not release body buffers already handed to the sink ...

BodyState.flush() emits every queued buffer and only clears the queue
afterwards, so a cancellation arriving while it emits makes dispose()
release buffers whose ownership has already been transferred to the sink.
Such a buffer is then released twice: once by the parser, and once by the
downstream consumer or the discard hook. With Netty, body buffers are
slices of the inbound buffer, so the second release frees the inbound
buffer prematurely, which surfaces as

  IllegalReferenceCountException: refCnt: 0, decrement: 1
    io.netty.handler.codec.http.DefaultHttpContent.release
    reactor.netty.channel.FluxReceive.drainReceiver

when reactor-netty releases its own share right after onNext.

Remove each buffer from the queue before emitting it, mirroring what
enqueue() already does, so that dispose() only ever releases buffers the
parser still owns.

Signed-off-by: Hyunsik Kang <cj848@hanmail.net>

2026-08-28 16:26:54 +02:00

..

src

Do not release body buffers already handed to the sink

2026-08-28 16:26:54 +02:00

spring-web.gradle

Exclude DataAccessException and MessagingException in DisconnectedClientHelper

2026-01-14 11:44:43 +00:00