4 instantiations of MessagePump
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (2)
Utilities.cs (2)
116=> new MessagePump(Options.Create(new HttpSysOptions()), new DefaultMemoryPoolFactory(), loggerFactory ?? new LoggerFactory(), new AuthenticationSchemeProvider(Options.Create(new AuthenticationOptions()))); 122return new MessagePump(Options.Create(options), new DefaultMemoryPoolFactory(), loggerFactory ?? new LoggerFactory(), new AuthenticationSchemeProvider(Options.Create(new AuthenticationOptions())));
Microsoft.AspNetCore.Server.HttpSys.NonHelixTests (2)
Utilities.cs (2)
35=> new MessagePump(Options.Create(new HttpSysOptions()), new DefaultMemoryPoolFactory(), loggerFactory ?? new LoggerFactory(), new AuthenticationSchemeProvider(Options.Create(new AuthenticationOptions()))); 41return new MessagePump(Options.Create(options), new DefaultMemoryPoolFactory(), loggerFactory ?? new LoggerFactory(), new AuthenticationSchemeProvider(Options.Create(new AuthenticationOptions())));
32 references to MessagePump
Microsoft.AspNetCore.Server.HttpSys (13)
ApplicationRequestContextFactory.cs (2)
11private readonly MessagePump _messagePump; 13public ApplicationRequestContextFactory(IHttpApplication<TContext> application, MessagePump messagePump)
MessagePump.cs (5)
44_logger = loggerFactory.CreateLogger<MessagePump>(); 226var pump = (MessagePump)state!; 283private readonly MessagePump _messagePump; 287MessagePump messagePump)
RequestProcessing\RequestContextOfT.cs (3)
14private readonly MessagePump _messagePump; 16public RequestContext(IHttpApplication<TContext> application, MessagePump messagePump, HttpSysListener server, uint? bufferSize, ulong requestId) 25var messagePump = _messagePump;
WebHostBuilderHttpSysExtensions.cs (3)
33services.AddSingleton<MessagePump>(); 34services.AddSingleton<IServer>(services => services.GetRequiredService<MessagePump>()); 37services.AddSingleton<IServerDelegationFeature>(services => services.GetRequiredService<MessagePump>());
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (16)
DelegateTests.cs (2)
255using var receiverRestarted = (MessagePump)Utilities.CreateHttpServer(out receiverAddress, async httpContext =>
MessagePumpTests.cs (6)
24using (var server = Utilities.CreatePump(LoggerFactory)) 46using (var server = Utilities.CreatePump(LoggerFactory)) 63using (var server = Utilities.CreatePump(LoggerFactory)) 84using (var server = Utilities.CreatePump(LoggerFactory)) 101using (var server = Utilities.CreatePump(LoggerFactory)) 115using (var server = Utilities.CreatePump(LoggerFactory))
RequestTests.cs (1)
601var server = Utilities.CreatePump(LoggerFactory);
ServerTests.cs (3)
342var server = Utilities.CreatePump(LoggerFactory); 384using (var server = Utilities.CreatePump(LoggerFactory)) 605using var attachedServer = Utilities.CreatePump(options =>
Utilities.cs (4)
115internal static MessagePump CreatePump(ILoggerFactory loggerFactory) 118internal static MessagePump CreatePump(Action<HttpSysOptions> configureOptions, ILoggerFactory loggerFactory) 129var server = CreatePump(configureOptions, loggerFactory); 156var server = CreatePump(loggerFactory);
Microsoft.AspNetCore.Server.HttpSys.NonHelixTests (3)
Utilities.cs (3)
34internal static MessagePump CreatePump(ILoggerFactory loggerFactory = null) 37internal static MessagePump CreatePump(Action<HttpSysOptions> configureOptions, ILoggerFactory loggerFactory = null) 48var server = CreatePump(configureOptions);