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();
847
while (!Http3Frame.TryReadIntegerPair(
_recvBuffer
.ActiveSpan, out frameType, out payloadLength, out bytesRead))
849
_recvBuffer
.EnsureAvailableSpace(VariableLengthIntegerHelper.MaximumEncodedLength * 2);
850
bytesRead = await _stream.ReadAsync(
_recvBuffer
.AvailableMemory, cancellationToken).ConfigureAwait(false);
854
_recvBuffer
.Commit(bytesRead);
856
else if (
_recvBuffer
.ActiveLength == 0)
868
_recvBuffer
.Discard(bytesRead);
915
if (
_recvBuffer
.ActiveLength == 0)
917
_recvBuffer
.EnsureAvailableSpace(1);
919
int bytesRead = await _stream.ReadAsync(
_recvBuffer
.AvailableMemory, cancellationToken).ConfigureAwait(false);
922
_recvBuffer
.Commit(bytesRead);
931
int processLength = (int)Math.Min(headersLength,
_recvBuffer
.ActiveLength);
934
_headerDecoder.Decode(
_recvBuffer
.ActiveSpan.Slice(0, processLength), endHeaders, this);
935
_recvBuffer
.Discard(processLength);
1115
if (
_recvBuffer
.ActiveLength == 0)
1117
_recvBuffer
.EnsureAvailableSpace(1);
1118
int bytesRead = await _stream.ReadAsync(
_recvBuffer
.AvailableMemory, cancellationToken).ConfigureAwait(false);
1122
_recvBuffer
.Commit(bytesRead);
1131
long readLength = Math.Min(payloadLength,
_recvBuffer
.ActiveLength);
1132
_recvBuffer
.Discard((int)readLength);
1158
if (
_recvBuffer
.ActiveLength != 0)
1162
int copyLen = (int)Math.Min(buffer.Length, Math.Min(_responseDataPayloadRemaining,
_recvBuffer
.ActiveLength));
1163
_recvBuffer
.ActiveSpan.Slice(0, copyLen).CopyTo(buffer);
1167
_recvBuffer
.Discard(copyLen);
1173
if (_responseDataPayloadRemaining == 0 &&
_recvBuffer
.ActiveLength == 0)
1230
if (
_recvBuffer
.ActiveLength != 0)
1234
int copyLen = (int)Math.Min(buffer.Length, Math.Min(_responseDataPayloadRemaining,
_recvBuffer
.ActiveLength));
1235
_recvBuffer
.ActiveSpan.Slice(0, copyLen).CopyTo(buffer.Span);
1239
_recvBuffer
.Discard(copyLen);
1245
if (_responseDataPayloadRemaining == 0 &&
_recvBuffer
.ActiveLength == 0)