3 writes to _readBuffer
System.Net.Http (3)
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (3)
87
_readBuffer
= new ArrayBuffer(InitialReadBufferSize, usePool: false);
1976
_readBuffer
= new ArrayBuffer(pooledBuffer);
1994
_readBuffer
= new ArrayBuffer(origReadBuffer);
66 references to _readBuffer
System.Net.Http (66)
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (66)
169
_readAheadTask = _stream.ReadAsync(
_readBuffer
.AvailableMemory);
247
Debug.Assert(
_readBuffer
.ActiveLength == 0);
258
int read = await _stream.ReadAsync(
_readBuffer
.AvailableMemory).ConfigureAwait(false);
299
private int ReadBufferSize =>
_readBuffer
.Capacity;
301
private ReadOnlyMemory<byte> RemainingBuffer =>
_readBuffer
.ActiveMemory;
305
Debug.Assert(bytesToConsume <=
_readBuffer
.ActiveLength);
306
_readBuffer
.Discard(bytesToConsume);
535
Debug.Assert(
_readBuffer
.ActiveLength == 0, "Unexpected data in read buffer");
603
Debug.Assert(
_readBuffer
.ActiveLength == 0);
638
_readBuffer
.Commit(bytesRead);
650
if (
_readBuffer
.ActiveLength == 0)
1031
Span<byte> buffer =
_readBuffer
.ActiveSpan;
1037
_readBuffer
.Discard(bytesConsumed);
1133
Span<byte> buffer =
_readBuffer
.ActiveSpan;
1143
_readBuffer
.Discard(bytesConsumed);
1591
ReadOnlySpan<byte> buffer =
_readBuffer
.ActiveReadOnlySpan;
1607
_readBuffer
.Discard(bytesConsumed);
1627
Debug.Assert(
_readBuffer
.AvailableLength ==
_readBuffer
.Capacity);
1628
Debug.Assert(
_readBuffer
.AvailableLength >= InitialReadBufferSize);
1631
await _stream.ReadAsync(
_readBuffer
.AvailableMemory).ConfigureAwait(false) :
1632
_stream.Read(
_readBuffer
.AvailableSpan);
1634
_readBuffer
.Commit(bytesRead);
1644
_readBuffer
.EnsureAvailableSpace(1);
1647
await _stream.ReadAsync(
_readBuffer
.AvailableMemory).ConfigureAwait(false) :
1648
_stream.Read(
_readBuffer
.AvailableSpan);
1650
_readBuffer
.Commit(bytesRead);
1663
return
_readBuffer
.ActiveStartOffset == 0
1671
int searchOffset =
_readBuffer
.ActiveLength;
1682
Debug.Assert(
_readBuffer
.ActiveStartOffset == 0);
1683
Debug.Assert(
_readBuffer
.ActiveLength > searchOffset);
1686
if (TryFindEndOfLine(
_readBuffer
.ActiveReadOnlySpan.Slice(searchOffset), out int offset))
1693
int readLength =
_readBuffer
.ActiveLength;
1696
Debug.Assert(searchOffset == readLength - 1 &&
_readBuffer
.ActiveReadOnlySpan[searchOffset] == '\n');
1748
ReadOnlySpan<byte> available =
_readBuffer
.ActiveSpan;
1752
_readBuffer
.Discard(toCopy);
1761
if (
_readBuffer
.ActiveLength > 0)
1779
if (
_readBuffer
.ActiveLength > 0)
1805
if (
_readBuffer
.ActiveLength == 0)
1815
Debug.Assert(
_readBuffer
.AvailableLength ==
_readBuffer
.Capacity);
1816
int bytesRead = _stream.Read(
_readBuffer
.AvailableSpan);
1817
_readBuffer
.Commit(bytesRead);
1833
return destination.Length >=
_readBuffer
.Capacity || destination.Length == 0 ?
1843
if (
_readBuffer
.ActiveLength == 0)
1848
Debug.Assert(
_readBuffer
.AvailableLength ==
_readBuffer
.Capacity);
1849
int bytesRead = await _stream.ReadAsync(
_readBuffer
.AvailableMemory).ConfigureAwait(false);
1850
_readBuffer
.Commit(bytesRead);
1861
Debug.Assert(count <=
_readBuffer
.ActiveLength);
1865
ReadOnlyMemory<byte> source =
_readBuffer
.ActiveMemory.Slice(0, count);
1866
_readBuffer
.Discard(count);
1883
if (
_readBuffer
.ActiveLength > 0)
1899
int remaining =
_readBuffer
.ActiveLength;
1921
int remaining =
_readBuffer
.ActiveLength;
1936
Debug.Assert(
_readBuffer
.ActiveLength == 0, "HttpConnection's buffer should have been empty.");
1953
remaining = (int)Math.Min((ulong)
_readBuffer
.ActiveLength, length);
1968
int currentCapacity =
_readBuffer
.Capacity;
1974
origReadBuffer =
_readBuffer
.DangerousGetUnderlyingBuffer();
1991
bool anyDataAvailable =
_readBuffer
.ActiveLength > 0;
1993
byte[] pooledBuffer =
_readBuffer
.DangerousGetUnderlyingBuffer();
1999
_readBuffer
.Commit(1);
2050
if (
_readBuffer
.ActiveLength > 0)
2057
_readBuffer
.Discard(
_readBuffer
.ActiveLength);
2111
Debug.Assert(
_readBuffer
.ActiveLength == 0, "Unexpected data in connection read buffer.");