1 write to _recvBuffer
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (1)
74
_recvBuffer
= new ArrayBuffer(initialSize: 64, usePool: true);
30 references to _recvBuffer
System.Net.Http (30)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (30)
134
_recvBuffer
.Dispose();
855
while (!Http3Frame.TryReadIntegerPair(
_recvBuffer
.ActiveSpan, out frameType, out payloadLength, out bytesRead))
857
_recvBuffer
.EnsureAvailableSpace(VariableLengthIntegerHelper.MaximumEncodedLength * 2);
858
bytesRead = await _stream.ReadAsync(
_recvBuffer
.AvailableMemory, cancellationToken).ConfigureAwait(false);
862
_recvBuffer
.Commit(bytesRead);
864
else if (
_recvBuffer
.ActiveLength == 0)
876
_recvBuffer
.Discard(bytesRead);
923
if (
_recvBuffer
.ActiveLength == 0)
925
_recvBuffer
.EnsureAvailableSpace(1);
927
int bytesRead = await _stream.ReadAsync(
_recvBuffer
.AvailableMemory, cancellationToken).ConfigureAwait(false);
930
_recvBuffer
.Commit(bytesRead);
939
int processLength = (int)Math.Min(headersLength,
_recvBuffer
.ActiveLength);
942
_headerDecoder.Decode(
_recvBuffer
.ActiveSpan.Slice(0, processLength), endHeaders, this);
943
_recvBuffer
.Discard(processLength);
1123
if (
_recvBuffer
.ActiveLength == 0)
1125
_recvBuffer
.EnsureAvailableSpace(1);
1126
int bytesRead = await _stream.ReadAsync(
_recvBuffer
.AvailableMemory, cancellationToken).ConfigureAwait(false);
1130
_recvBuffer
.Commit(bytesRead);
1139
long readLength = Math.Min(payloadLength,
_recvBuffer
.ActiveLength);
1140
_recvBuffer
.Discard((int)readLength);
1166
if (
_recvBuffer
.ActiveLength != 0)
1170
int copyLen = (int)Math.Min(buffer.Length, Math.Min(_responseDataPayloadRemaining,
_recvBuffer
.ActiveLength));
1171
_recvBuffer
.ActiveSpan.Slice(0, copyLen).CopyTo(buffer);
1175
_recvBuffer
.Discard(copyLen);
1181
if (_responseDataPayloadRemaining == 0 &&
_recvBuffer
.ActiveLength == 0)
1238
if (
_recvBuffer
.ActiveLength != 0)
1242
int copyLen = (int)Math.Min(buffer.Length, Math.Min(_responseDataPayloadRemaining,
_recvBuffer
.ActiveLength));
1243
_recvBuffer
.ActiveSpan.Slice(0, copyLen).CopyTo(buffer.Span);
1247
_recvBuffer
.Discard(copyLen);
1253
if (_responseDataPayloadRemaining == 0 &&
_recvBuffer
.ActiveLength == 0)