3 writes to _readBuffer
System.Net.Http (3)
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (3)
88
_readBuffer
= new ArrayBuffer(InitialReadBufferSize, usePool: false);
2002
_readBuffer
= new ArrayBuffer(pooledBuffer);
2020
_readBuffer
= new ArrayBuffer(origReadBuffer);
66 references to _readBuffer
System.Net.Http (66)
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (66)
170
_readAheadTask = _stream.ReadAsync(
_readBuffer
.AvailableMemory);
248
Debug.Assert(
_readBuffer
.ActiveLength == 0);
259
int read = await _stream.ReadAsync(
_readBuffer
.AvailableMemory).ConfigureAwait(false);
300
private int ReadBufferSize =>
_readBuffer
.Capacity;
302
private ReadOnlyMemory<byte> RemainingBuffer =>
_readBuffer
.ActiveMemory;
306
Debug.Assert(bytesToConsume <=
_readBuffer
.ActiveLength);
307
_readBuffer
.Discard(bytesToConsume);
538
Debug.Assert(
_readBuffer
.ActiveLength == 0, "Unexpected data in read buffer");
606
Debug.Assert(
_readBuffer
.ActiveLength == 0);
641
_readBuffer
.Commit(bytesRead);
653
if (
_readBuffer
.ActiveLength == 0)
1034
Span<byte> buffer =
_readBuffer
.ActiveSpan;
1040
_readBuffer
.Discard(bytesConsumed);
1136
Span<byte> buffer =
_readBuffer
.ActiveSpan;
1146
_readBuffer
.Discard(bytesConsumed);
1594
ReadOnlySpan<byte> buffer =
_readBuffer
.ActiveReadOnlySpan;
1629
_readBuffer
.Discard(bytesConsumed);
1652
Debug.Assert(
_readBuffer
.AvailableLength ==
_readBuffer
.Capacity);
1653
Debug.Assert(
_readBuffer
.AvailableLength >= InitialReadBufferSize);
1656
await _stream.ReadAsync(
_readBuffer
.AvailableMemory).ConfigureAwait(false) :
1657
_stream.Read(
_readBuffer
.AvailableSpan);
1659
_readBuffer
.Commit(bytesRead);
1669
_readBuffer
.EnsureAvailableSpace(1);
1672
await _stream.ReadAsync(
_readBuffer
.AvailableMemory).ConfigureAwait(false) :
1673
_stream.Read(
_readBuffer
.AvailableSpan);
1675
_readBuffer
.Commit(bytesRead);
1688
return
_readBuffer
.ActiveStartOffset == 0
1696
int searchOffset =
_readBuffer
.ActiveLength;
1707
Debug.Assert(
_readBuffer
.ActiveStartOffset == 0);
1708
Debug.Assert(
_readBuffer
.ActiveLength > searchOffset);
1711
if (TryFindEndOfLine(
_readBuffer
.ActiveReadOnlySpan.Slice(searchOffset), out int offset))
1718
int readLength =
_readBuffer
.ActiveLength;
1721
Debug.Assert(searchOffset == readLength - 1 &&
_readBuffer
.ActiveReadOnlySpan[searchOffset] == '\n');
1773
ReadOnlySpan<byte> available =
_readBuffer
.ActiveSpan;
1777
_readBuffer
.Discard(toCopy);
1786
if (
_readBuffer
.ActiveLength > 0)
1804
if (
_readBuffer
.ActiveLength > 0)
1830
if (
_readBuffer
.ActiveLength == 0)
1840
Debug.Assert(
_readBuffer
.AvailableLength ==
_readBuffer
.Capacity);
1841
int bytesRead = _stream.Read(
_readBuffer
.AvailableSpan);
1842
_readBuffer
.Commit(bytesRead);
1858
return destination.Length >=
_readBuffer
.Capacity || destination.Length == 0 ?
1869
if (
_readBuffer
.ActiveLength == 0)
1874
Debug.Assert(
_readBuffer
.AvailableLength ==
_readBuffer
.Capacity);
1875
int bytesRead = await _stream.ReadAsync(
_readBuffer
.AvailableMemory).ConfigureAwait(false);
1876
_readBuffer
.Commit(bytesRead);
1887
Debug.Assert(count <=
_readBuffer
.ActiveLength);
1891
ReadOnlyMemory<byte> source =
_readBuffer
.ActiveMemory.Slice(0, count);
1892
_readBuffer
.Discard(count);
1909
if (
_readBuffer
.ActiveLength > 0)
1925
int remaining =
_readBuffer
.ActiveLength;
1947
int remaining =
_readBuffer
.ActiveLength;
1962
Debug.Assert(
_readBuffer
.ActiveLength == 0, "HttpConnection's buffer should have been empty.");
1979
remaining = (int)Math.Min((ulong)
_readBuffer
.ActiveLength, length);
1994
int currentCapacity =
_readBuffer
.Capacity;
2000
origReadBuffer =
_readBuffer
.DangerousGetUnderlyingBuffer();
2017
bool anyDataAvailable =
_readBuffer
.ActiveLength > 0;
2019
byte[] pooledBuffer =
_readBuffer
.DangerousGetUnderlyingBuffer();
2025
_readBuffer
.Commit(1);
2076
if (
_readBuffer
.ActiveLength > 0)
2083
_readBuffer
.Discard(
_readBuffer
.ActiveLength);
2137
Debug.Assert(
_readBuffer
.ActiveLength == 0, "Unexpected data in connection read buffer.");