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)
120
_recvBuffer
.Dispose();
817
while (!Http3Frame.TryReadIntegerPair(
_recvBuffer
.ActiveSpan, out frameType, out payloadLength, out bytesRead))
819
_recvBuffer
.EnsureAvailableSpace(VariableLengthIntegerHelper.MaximumEncodedLength * 2);
820
bytesRead = await _stream.ReadAsync(
_recvBuffer
.AvailableMemory, cancellationToken).ConfigureAwait(false);
824
_recvBuffer
.Commit(bytesRead);
826
else if (
_recvBuffer
.ActiveLength == 0)
838
_recvBuffer
.Discard(bytesRead);
885
if (
_recvBuffer
.ActiveLength == 0)
887
_recvBuffer
.EnsureAvailableSpace(1);
889
int bytesRead = await _stream.ReadAsync(
_recvBuffer
.AvailableMemory, cancellationToken).ConfigureAwait(false);
892
_recvBuffer
.Commit(bytesRead);
901
int processLength = (int)Math.Min(headersLength,
_recvBuffer
.ActiveLength);
904
_headerDecoder.Decode(
_recvBuffer
.ActiveSpan.Slice(0, processLength), endHeaders, this);
905
_recvBuffer
.Discard(processLength);
1085
if (
_recvBuffer
.ActiveLength == 0)
1087
_recvBuffer
.EnsureAvailableSpace(1);
1088
int bytesRead = await _stream.ReadAsync(
_recvBuffer
.AvailableMemory, cancellationToken).ConfigureAwait(false);
1092
_recvBuffer
.Commit(bytesRead);
1101
long readLength = Math.Min(payloadLength,
_recvBuffer
.ActiveLength);
1102
_recvBuffer
.Discard((int)readLength);
1128
if (
_recvBuffer
.ActiveLength != 0)
1132
int copyLen = (int)Math.Min(buffer.Length, Math.Min(_responseDataPayloadRemaining,
_recvBuffer
.ActiveLength));
1133
_recvBuffer
.ActiveSpan.Slice(0, copyLen).CopyTo(buffer);
1137
_recvBuffer
.Discard(copyLen);
1143
if (_responseDataPayloadRemaining == 0 &&
_recvBuffer
.ActiveLength == 0)
1200
if (
_recvBuffer
.ActiveLength != 0)
1204
int copyLen = (int)Math.Min(buffer.Length, Math.Min(_responseDataPayloadRemaining,
_recvBuffer
.ActiveLength));
1205
_recvBuffer
.ActiveSpan.Slice(0, copyLen).CopyTo(buffer.Span);
1209
_recvBuffer
.Discard(copyLen);
1215
if (_responseDataPayloadRemaining == 0 &&
_recvBuffer
.ActiveLength == 0)