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