Application

1 write to Application

Microsoft.AspNetCore.Server.Kestrel.Core (1)

src\Shared\ServerInfrastructure\DuplexPipe.cs (1)

51Application = application;

122 references to Application

InMemory.FunctionalTests (91)

Http2\Http2ConnectionTests.cs (17)

2734var outputWriter = _pair.Application.Output; 3755Http2FrameWriter.WriteHeader(frame, _pair.Application.Output); 3756await FlushAsync(_pair.Application.Output); 4312_pair.Application.Output.Complete(); 4391_pair.Application.Output.Complete(); 5100_pair.Application.Output.Complete(new ConnectionResetException(string.Empty)); 5113_pair.Application.Output.Complete(new ConnectionResetException(string.Empty)); 5129var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 5155_pair.Application.Output.Complete(); 5183_pair.Application.Output.Complete(); 5191var readTask = _pair.Application.Input.ReadAsync(); 5192_pair.Application.Input.CancelPendingRead(); 5201readTask = _pair.Application.Input.ReadAsync(); 5202_pair.Application.Input.CancelPendingRead(); 5306var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 5319_pair.Application.Output.Complete(ioException); 5339_pair.Application.Output.Complete(exception);

Http2\Http2TestBase.cs (46)

182_pair.Application.Output.Complete(ex); 419_pair.Application?.Input.Complete(); 420_pair.Application?.Output.Complete(); 616var writableBuffer = _pair.Application.Output; 631var writableBuffer = _pair.Application.Output; 650var writableBuffer = _pair.Application.Output; 692var writableBuffer = _pair.Application.Output; 737var writableBuffer = _pair.Application.Output; 783var writableBuffer = _pair.Application.Output; 797_pair.Application.Output.WriteSettings(_clientSettings); 798await FlushAsync(_pair.Application.Output); 803var writableBuffer = _pair.Application.Output; 813var writableBuffer = _pair.Application.Output; 827var writableBuffer = _pair.Application.Output; 839var writableBuffer = _pair.Application.Output; 857var writableBuffer = _pair.Application.Output; 869var outputWriter = _pair.Application.Output; 890var outputWriter = _pair.Application.Output; 904var outputWriter = _pair.Application.Output; 921var outputWriter = _pair.Application.Output; 939var outputWriter = _pair.Application.Output; 955var outputWriter = _pair.Application.Output; 967var outputWriter = _pair.Application.Output; 994var outputWriter = _pair.Application.Output; 1006var outputWriter = _pair.Application.Output; 1024var outputWriter = _pair.Application.Output; 1035var outputWriter = _pair.Application.Output; 1057var outputWriter = _pair.Application.Output; 1075var outputWriter = _pair.Application.Output; 1084var outputWriter = _pair.Application.Output; 1096var outputWriter = _pair.Application.Output; 1113var outputWriter = _pair.Application.Output; 1127var outputWriter = _pair.Application.Output; 1143var outputWriter = _pair.Application.Output; 1155var outputWriter = _pair.Application.Output; 1165var outputWriter = _pair.Application.Output; 1174var outputWriter = _pair.Application.Output; 1184var outputWriter = _pair.Application.Output; 1191var outputWriter = _pair.Application.Output; 1201var outputWriter = _pair.Application.Output; 1214var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 1222_pair.Application.Input.AdvanceTo(result.Buffer.Start, result.Buffer.End); 1232var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 1261_pair.Application.Input.AdvanceTo(consumed, examined); 1280_pair.Application.Output.Complete(); 1304_pair.Application.Output.Complete();

Http2\Http2TimeoutTests.cs (3)

322_pair.Application.Output.Complete(); 390Assert.True((await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout()).IsCompleted); 445Assert.True((await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout()).IsCompleted);

Http3\Http3StreamTests.cs (13)

3048Http3FrameWriter.WriteHeader(Http3FrameType.Settings, len, outboundcontrolStream.Pair.Application.Output); 3050var parameterLength = VariableLengthIntegerHelper.WriteInteger(outboundcontrolStream.Pair.Application.Output.GetSpan(), (long)Internal.Http3.Http3SettingType.MaxFieldSectionSize); 3051outboundcontrolStream.Pair.Application.Output.Advance(parameterLength); 3052await outboundcontrolStream.Pair.Application.Output.FlushAsync(); 3159await WriteOneByteAtATime(bufferPipe.Reader, stream.Pair.Application.Output); 3165await WriteOneByteAtATime(bufferPipe.Reader, stream.Pair.Application.Output); 3176mem = stream.Pair.Application.Output.GetMemory(); 3178stream.Pair.Application.Output.Advance(1); 3181await stream.Pair.Application.Output.FlushAsync(); 3200await WriteOneByteAtATime(bufferPipe.Reader, stream.Pair.Application.Output); 3244await WriteOneByteAtATime(bufferPipe.Reader, outboundcontrolStream.Pair.Application.Output); 3266await WriteOneByteAtATime(bufferPipe.Reader, outboundcontrolStream.Pair.Application.Output); 3277await WriteOneByteAtATime(bufferPipe.Reader, outboundcontrolStream.Pair.Application.Output);

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (11)

510var writableBuffer = Pair.Application.Output; 537return Pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 598Pair.Application.Input.AdvanceTo(consumed, examined); 605var outputWriter = Pair.Application.Output; 622var writableBuffer = Pair.Application.Output; 726var outputWriter = Pair.Application.Output; 869var writableBuffer = Pair.Application.Output; 950Pair.Application.Input.AdvanceTo(consumed, examined); 1129_pair.Application.Input.Complete(); 1130_pair.Application.Output.Complete(); 1212_pair.Application.Output.Complete(abortReason);

TestTransport\InMemoryTransportConnection.cs (1)

33Application = pair.Application;

Microsoft.AspNetCore.Server.Kestrel.Core.Tests (3)

Http1\Http1ConnectionTestsBase.cs (1)

39_application = pair.Application;

Http3\Http3HttpProtocolFeatureCollectionTests.cs (1)

24transport: DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()).Application,

TestHelpers\TestInput.cs (1)

31Application = pair.Application;

Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (28)

Http1LargeWritingBenchmark.cs (1)

95var reader = _pair.Application.Input;

Http1ReadingBenchmark.cs (2)

65_pair.Application.Output.WriteAsync(_readData).GetAwaiter().GetResult(); 125var reader = _pair.Application.Input;

Http1WritingBenchmark.cs (1)

129var reader = _pair.Application.Input;

Http2\Http2ConnectionBenchmarkBase.cs (12)

97_connectionPair.Application.Output.Write(Http2Connection.ClientPreface); 98_connectionPair.Application.Output.WriteSettings(new Http2PeerSettings 102_connectionPair.Application.Output.FlushAsync().GetAwaiter().GetResult(); 105ReceiveFrameAsync(_connectionPair.Application.Input).GetAwaiter().GetResult(); 107ReceiveFrameAsync(_connectionPair.Application.Input).GetAwaiter().GetResult(); 109ReceiveFrameAsync(_connectionPair.Application.Input).GetAwaiter().GetResult(); 118_connectionPair.Application.Output.WriteStartStream(streamId: _currentStreamId, _hpackEncoder, _requestHeadersEnumerator, _headersBuffer, endStream: true, frame: _sendHttpFrame); 119await _connectionPair.Application.Output.FlushAsync(); 123await ReceiveFrameAsync(_connectionPair.Application.Input); 137_connectionPair.Application.Output.WriteWindowUpdateAsync(streamId: 0, _dataWritten, _sendHttpFrame); 138await _connectionPair.Application.Output.FlushAsync(); 188_connectionPair.Application.Output.Complete();

InMemoryTransportBenchmark.cs (1)

179Application = pair.Application;

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (11)

510var writableBuffer = Pair.Application.Output; 542return Pair.Application.Input.ReadAsync(); 598Pair.Application.Input.AdvanceTo(consumed, examined); 605var outputWriter = Pair.Application.Output; 622var writableBuffer = Pair.Application.Output; 726var outputWriter = Pair.Application.Output; 869var writableBuffer = Pair.Application.Output; 950Pair.Application.Input.AdvanceTo(consumed, examined); 1129_pair.Application.Input.Complete(); 1130_pair.Application.Output.Complete(); 1212_pair.Application.Output.Complete(abortReason);