1 write to _incomingBuffer
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
138_incomingBuffer = new ArrayBuffer(initialSize: 0, usePool: true);
47 references to _incomingBuffer
System.Net.Http (47)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (47)
408if (_incomingBuffer.ActiveLength < FrameHeader.Size) 415_incomingBuffer.EnsureAvailableSpace(FrameHeader.Size); 417int bytesRead = await _stream.ReadAsync(_incomingBuffer.AvailableMemory).ConfigureAwait(false); 418_incomingBuffer.Commit(bytesRead); 425else if (_incomingBuffer.ActiveLength == 0) 435while (_incomingBuffer.ActiveLength < FrameHeader.Size); 439FrameHeader frameHeader = FrameHeader.ReadFrom(_incomingBuffer.ActiveSpan); 444string response = Encoding.ASCII.GetString(_incomingBuffer.ActiveSpan.Slice(0, Math.Min(20, _incomingBuffer.ActiveLength))); 448_incomingBuffer.Discard(FrameHeader.Size); 451_incomingBuffer.Discard(FrameHeader.Size); 454if (_incomingBuffer.ActiveLength < frameHeader.PayloadLength) 456_incomingBuffer.EnsureAvailableSpace(frameHeader.PayloadLength - _incomingBuffer.ActiveLength); 462int bytesRead = await _stream.ReadAsync(_incomingBuffer.AvailableMemory).ConfigureAwait(false); 463_incomingBuffer.Commit(bytesRead); 466while (_incomingBuffer.ActiveLength < frameHeader.PayloadLength); 473throw new HttpIOException(HttpRequestError.ResponseEnded, SR.Format(SR.net_http_invalid_response_premature_eof_bytecount, requiredBytes - _incomingBuffer.ActiveLength)); 529if (_incomingBuffer.ActiveLength < FrameHeader.Size) 535if (!zeroByteReadTask.IsCompletedSuccessfully && _incomingBuffer.ActiveLength == 0) 538_incomingBuffer.ClearAndReturnBuffer(); 544_incomingBuffer.EnsureAvailableSpace(InitialConnectionBufferSize); 546int bytesRead = await _stream.ReadAsync(_incomingBuffer.AvailableMemory).ConfigureAwait(false); 548_incomingBuffer.Commit(bytesRead); 555while (_incomingBuffer.ActiveLength < FrameHeader.Size); 619_incomingBuffer.Dispose(); 670GetFrameData(_incomingBuffer.ActiveSpan.Slice(0, frameHeader.PayloadLength), frameHeader.PaddedFlag, frameHeader.PriorityFlag), 673_incomingBuffer.Discard(frameHeader.PayloadLength); 686_incomingBuffer.ActiveSpan.Slice(0, frameHeader.PayloadLength), 689_incomingBuffer.Discard(frameHeader.PayloadLength); 754ReadOnlySpan<byte> span = _incomingBuffer.ActiveSpan.Slice(0, frameHeader.PayloadLength); 775_incomingBuffer.Discard(frameHeader.PayloadLength); 787ReadOnlySpan<byte> frameData = GetFrameData(_incomingBuffer.ActiveSpan.Slice(0, frameHeader.PayloadLength), hasPad: frameHeader.PaddedFlag, hasPriority: false); 804_incomingBuffer.Discard(frameHeader.PayloadLength); 841ReadOnlySpan<byte> settings = _incomingBuffer.ActiveSpan.Slice(0, frameHeader.PayloadLength); 921_incomingBuffer.Discard(frameHeader.PayloadLength); 974_incomingBuffer.Discard(frameHeader.PayloadLength); 995ReadOnlySpan<byte> pingContent = _incomingBuffer.ActiveSpan.Slice(0, FrameHeader.PingLength); 1008_incomingBuffer.Discard(frameHeader.PayloadLength); 1020int amount = BinaryPrimitives.ReadInt32BigEndian(_incomingBuffer.ActiveSpan) & 0x7FFFFFFF; 1029_incomingBuffer.Discard(frameHeader.PayloadLength); 1066_incomingBuffer.Discard(frameHeader.PayloadLength); 1070var protocolError = (Http2ProtocolErrorCode)BinaryPrimitives.ReadInt32BigEndian(_incomingBuffer.ActiveSpan); 1073_incomingBuffer.Discard(frameHeader.PayloadLength); 1128int lastStreamId = (int)(BinaryPrimitives.ReadUInt32BigEndian(_incomingBuffer.ActiveSpan) & 0x7FFFFFFF); 1129Http2ProtocolErrorCode errorCode = (Http2ProtocolErrorCode)BinaryPrimitives.ReadInt32BigEndian(_incomingBuffer.ActiveSpan.Slice(sizeof(int))); 1132_incomingBuffer.Discard(frameHeader.PayloadLength);