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); 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 ? 1843if (_readBuffer.ActiveLength == 0) 1848Debug.Assert(_readBuffer.AvailableLength == _readBuffer.Capacity); 1849int bytesRead = await _stream.ReadAsync(_readBuffer.AvailableMemory).ConfigureAwait(false); 1850_readBuffer.Commit(bytesRead); 1861Debug.Assert(count <= _readBuffer.ActiveLength); 1865ReadOnlyMemory<byte> source = _readBuffer.ActiveMemory.Slice(0, count); 1866_readBuffer.Discard(count); 1883if (_readBuffer.ActiveLength > 0) 1899int remaining = _readBuffer.ActiveLength; 1921int remaining = _readBuffer.ActiveLength; 1936Debug.Assert(_readBuffer.ActiveLength == 0, "HttpConnection's buffer should have been empty."); 1953remaining = (int)Math.Min((ulong)_readBuffer.ActiveLength, length); 1968int currentCapacity = _readBuffer.Capacity; 1974origReadBuffer = _readBuffer.DangerousGetUnderlyingBuffer(); 1991bool anyDataAvailable = _readBuffer.ActiveLength > 0; 1993byte[] pooledBuffer = _readBuffer.DangerousGetUnderlyingBuffer(); 1999_readBuffer.Commit(1); 2050if (_readBuffer.ActiveLength > 0) 2057_readBuffer.Discard(_readBuffer.ActiveLength); 2111Debug.Assert(_readBuffer.ActiveLength == 0, "Unexpected data in connection read buffer.");