1 write to _incomingBuffer
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
139_incomingBuffer = new ArrayBuffer(initialSize: 0, usePool: true);
47 references to _incomingBuffer
System.Net.Http (47)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (47)
409if (_incomingBuffer.ActiveLength < FrameHeader.Size) 416_incomingBuffer.EnsureAvailableSpace(FrameHeader.Size); 418int bytesRead = await _stream.ReadAsync(_incomingBuffer.AvailableMemory).ConfigureAwait(false); 419_incomingBuffer.Commit(bytesRead); 426else if (_incomingBuffer.ActiveLength == 0) 436while (_incomingBuffer.ActiveLength < FrameHeader.Size); 440FrameHeader frameHeader = FrameHeader.ReadFrom(_incomingBuffer.ActiveSpan); 445string response = Encoding.ASCII.GetString(_incomingBuffer.ActiveSpan.Slice(0, Math.Min(20, _incomingBuffer.ActiveLength))); 449_incomingBuffer.Discard(FrameHeader.Size); 452_incomingBuffer.Discard(FrameHeader.Size); 455if (_incomingBuffer.ActiveLength < frameHeader.PayloadLength) 457_incomingBuffer.EnsureAvailableSpace(frameHeader.PayloadLength - _incomingBuffer.ActiveLength); 463int bytesRead = await _stream.ReadAsync(_incomingBuffer.AvailableMemory).ConfigureAwait(false); 464_incomingBuffer.Commit(bytesRead); 467while (_incomingBuffer.ActiveLength < frameHeader.PayloadLength); 474throw new HttpIOException(HttpRequestError.ResponseEnded, SR.Format(SR.net_http_invalid_response_premature_eof_bytecount, requiredBytes - _incomingBuffer.ActiveLength)); 530if (_incomingBuffer.ActiveLength < FrameHeader.Size) 536if (!zeroByteReadTask.IsCompletedSuccessfully && _incomingBuffer.ActiveLength == 0) 539_incomingBuffer.ClearAndReturnBuffer(); 545_incomingBuffer.EnsureAvailableSpace(InitialConnectionBufferSize); 547int bytesRead = await _stream.ReadAsync(_incomingBuffer.AvailableMemory).ConfigureAwait(false); 549_incomingBuffer.Commit(bytesRead); 556while (_incomingBuffer.ActiveLength < FrameHeader.Size); 620_incomingBuffer.Dispose(); 671GetFrameData(_incomingBuffer.ActiveSpan.Slice(0, frameHeader.PayloadLength), frameHeader.PaddedFlag, frameHeader.PriorityFlag), 674_incomingBuffer.Discard(frameHeader.PayloadLength); 687_incomingBuffer.ActiveSpan.Slice(0, frameHeader.PayloadLength), 690_incomingBuffer.Discard(frameHeader.PayloadLength); 755ReadOnlySpan<byte> span = _incomingBuffer.ActiveSpan.Slice(0, frameHeader.PayloadLength); 776_incomingBuffer.Discard(frameHeader.PayloadLength); 788ReadOnlySpan<byte> frameData = GetFrameData(_incomingBuffer.ActiveSpan.Slice(0, frameHeader.PayloadLength), hasPad: frameHeader.PaddedFlag, hasPriority: false); 805_incomingBuffer.Discard(frameHeader.PayloadLength); 842ReadOnlySpan<byte> settings = _incomingBuffer.ActiveSpan.Slice(0, frameHeader.PayloadLength); 922_incomingBuffer.Discard(frameHeader.PayloadLength); 975_incomingBuffer.Discard(frameHeader.PayloadLength); 996ReadOnlySpan<byte> pingContent = _incomingBuffer.ActiveSpan.Slice(0, FrameHeader.PingLength); 1009_incomingBuffer.Discard(frameHeader.PayloadLength); 1021int amount = BinaryPrimitives.ReadInt32BigEndian(_incomingBuffer.ActiveSpan) & 0x7FFFFFFF; 1030_incomingBuffer.Discard(frameHeader.PayloadLength); 1067_incomingBuffer.Discard(frameHeader.PayloadLength); 1071var protocolError = (Http2ProtocolErrorCode)BinaryPrimitives.ReadInt32BigEndian(_incomingBuffer.ActiveSpan); 1074_incomingBuffer.Discard(frameHeader.PayloadLength); 1129int lastStreamId = (int)(BinaryPrimitives.ReadUInt32BigEndian(_incomingBuffer.ActiveSpan) & 0x7FFFFFFF); 1130Http2ProtocolErrorCode errorCode = (Http2ProtocolErrorCode)BinaryPrimitives.ReadInt32BigEndian(_incomingBuffer.ActiveSpan.Slice(sizeof(int))); 1133_incomingBuffer.Discard(frameHeader.PayloadLength);