3 writes to _readBuffer
System.Net.Http (3)
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (3)
87_readBuffer = new ArrayBuffer(InitialReadBufferSize, usePool: false); 1977_readBuffer = new ArrayBuffer(pooledBuffer); 1995_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); 247Debug.Assert(_readBuffer.ActiveLength == 0); 258int read = await _stream.ReadAsync(_readBuffer.AvailableMemory).ConfigureAwait(false); 299private int ReadBufferSize => _readBuffer.Capacity; 301private ReadOnlyMemory<byte> RemainingBuffer => _readBuffer.ActiveMemory; 305Debug.Assert(bytesToConsume <= _readBuffer.ActiveLength); 306_readBuffer.Discard(bytesToConsume); 535Debug.Assert(_readBuffer.ActiveLength == 0, "Unexpected data in read buffer"); 603Debug.Assert(_readBuffer.ActiveLength == 0); 638_readBuffer.Commit(bytesRead); 650if (_readBuffer.ActiveLength == 0) 1031Span<byte> buffer = _readBuffer.ActiveSpan; 1037_readBuffer.Discard(bytesConsumed); 1133Span<byte> buffer = _readBuffer.ActiveSpan; 1143_readBuffer.Discard(bytesConsumed); 1591ReadOnlySpan<byte> buffer = _readBuffer.ActiveReadOnlySpan; 1607_readBuffer.Discard(bytesConsumed); 1627Debug.Assert(_readBuffer.AvailableLength == _readBuffer.Capacity); 1628Debug.Assert(_readBuffer.AvailableLength >= InitialReadBufferSize); 1631await _stream.ReadAsync(_readBuffer.AvailableMemory).ConfigureAwait(false) : 1632_stream.Read(_readBuffer.AvailableSpan); 1634_readBuffer.Commit(bytesRead); 1644_readBuffer.EnsureAvailableSpace(1); 1647await _stream.ReadAsync(_readBuffer.AvailableMemory).ConfigureAwait(false) : 1648_stream.Read(_readBuffer.AvailableSpan); 1650_readBuffer.Commit(bytesRead); 1663return _readBuffer.ActiveStartOffset == 0 1671int searchOffset = _readBuffer.ActiveLength; 1682Debug.Assert(_readBuffer.ActiveStartOffset == 0); 1683Debug.Assert(_readBuffer.ActiveLength > searchOffset); 1686if (TryFindEndOfLine(_readBuffer.ActiveReadOnlySpan.Slice(searchOffset), out int offset)) 1693int readLength = _readBuffer.ActiveLength; 1696Debug.Assert(searchOffset == readLength - 1 && _readBuffer.ActiveReadOnlySpan[searchOffset] == '\n'); 1748ReadOnlySpan<byte> available = _readBuffer.ActiveSpan; 1752_readBuffer.Discard(toCopy); 1761if (_readBuffer.ActiveLength > 0) 1779if (_readBuffer.ActiveLength > 0) 1805if (_readBuffer.ActiveLength == 0) 1815Debug.Assert(_readBuffer.AvailableLength == _readBuffer.Capacity); 1816int bytesRead = _stream.Read(_readBuffer.AvailableSpan); 1817_readBuffer.Commit(bytesRead); 1833return destination.Length >= _readBuffer.Capacity || destination.Length == 0 ? 1844if (_readBuffer.ActiveLength == 0) 1849Debug.Assert(_readBuffer.AvailableLength == _readBuffer.Capacity); 1850int bytesRead = await _stream.ReadAsync(_readBuffer.AvailableMemory).ConfigureAwait(false); 1851_readBuffer.Commit(bytesRead); 1862Debug.Assert(count <= _readBuffer.ActiveLength); 1866ReadOnlyMemory<byte> source = _readBuffer.ActiveMemory.Slice(0, count); 1867_readBuffer.Discard(count); 1884if (_readBuffer.ActiveLength > 0) 1900int remaining = _readBuffer.ActiveLength; 1922int remaining = _readBuffer.ActiveLength; 1937Debug.Assert(_readBuffer.ActiveLength == 0, "HttpConnection's buffer should have been empty."); 1954remaining = (int)Math.Min((ulong)_readBuffer.ActiveLength, length); 1969int currentCapacity = _readBuffer.Capacity; 1975origReadBuffer = _readBuffer.DangerousGetUnderlyingBuffer(); 1992bool anyDataAvailable = _readBuffer.ActiveLength > 0; 1994byte[] pooledBuffer = _readBuffer.DangerousGetUnderlyingBuffer(); 2000_readBuffer.Commit(1); 2051if (_readBuffer.ActiveLength > 0) 2058_readBuffer.Discard(_readBuffer.ActiveLength); 2112Debug.Assert(_readBuffer.ActiveLength == 0, "Unexpected data in connection read buffer.");