97 instantiations of PipeOptions
InMemory.FunctionalTests (2)
TestTransport\InMemoryTransportConnection.cs (2)
32var pair = DuplexPipe.CreateConnectionPair(new PipeOptions(memoryPool, readerScheduler: scheduler, useSynchronizationContext: false), new PipeOptions(memoryPool, writerScheduler: scheduler, useSynchronizationContext: false));
Microsoft.AspNetCore.Http.Connections (2)
HttpConnectionDispatcherOptions.cs (2)
140internal PipeOptions TransportPipeOptions => _transportPipeOptions ??= new PipeOptions(pauseWriterThreshold: TransportMaxBufferSize, resumeWriterThreshold: TransportMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false); 142internal PipeOptions AppPipeOptions => _appPipeOptions ??= new PipeOptions(pauseWriterThreshold: ApplicationMaxBufferSize, resumeWriterThreshold: ApplicationMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);
Microsoft.AspNetCore.Http.Connections.Client (3)
HttpConnectionOptions.cs (2)
125internal PipeOptions TransportPipeOptions => _transportPipeOptions ??= new PipeOptions(pauseWriterThreshold: TransportMaxBufferSize, resumeWriterThreshold: TransportMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false); 127internal PipeOptions AppPipeOptions => _appPipeOptions ??= new PipeOptions(pauseWriterThreshold: ApplicationMaxBufferSize, resumeWriterThreshold: ApplicationMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);
Internal\ClientPipeOptions.cs (1)
10public static PipeOptions DefaultOptions = new PipeOptions(writerScheduler: PipeScheduler.ThreadPool, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);
Microsoft.AspNetCore.Http.Connections.Tests (2)
ServerSentEventsTests.cs (2)
66var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, new PipeOptions(readerScheduler: PipeScheduler.Inline)); 88var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, new PipeOptions(readerScheduler: PipeScheduler.Inline));
Microsoft.AspNetCore.Server.IIS (2)
Core\IISHttpContext.cs (2)
305var pipe = new Pipe(new PipeOptions( 502_bodyInputPipe = new Pipe(new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.ThreadPool, minimumSegmentSize: MinAllocBufferSize));
Microsoft.AspNetCore.Server.Kestrel.Core (6)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)
517=> new Pipe(new PipeOptions
Internal\Http2\Http2Connection.cs (1)
1842private PipeOptions GetInputPipeOptions() => new PipeOptions(pool: _context.MemoryPool,
Internal\Http2\Http2OutputProducer.cs (1)
766=> new Pipe(new PipeOptions
Internal\Http2\Http2Stream.cs (1)
647=> new Pipe(new PipeOptions
Internal\Http3\Http3OutputProducer.cs (1)
478=> new Pipe(new PipeOptions
Internal\Http3\Http3Stream.cs (1)
1183=> new Pipe(new PipeOptions
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (22)
BufferWriterTests.cs (1)
16Pipe = new Pipe(new PipeOptions(useSynchronizationContext: false, pauseWriterThreshold: 0, resumeWriterThreshold: 0));
Http1\Http1ConnectionTestsBase.cs (1)
35var options = new PipeOptions(_pipelineFactory, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http1\Http1OutputProducerTests.cs (8)
36var pipeOptions = new PipeOptions 61var pipeOptions = new PipeOptions 89var pipeOptions = new PipeOptions 143var pipeOptions = new PipeOptions 163var pipeOptions = new PipeOptions 183var pipeOptions = new PipeOptions 205var pipeOptions = new PipeOptions 228pipeOptions = pipeOptions ?? new PipeOptions();
Http2\Http2FrameWriterTests.cs (3)
38var pipe = new Pipe(new PipeOptions(_dirtyMemoryPool, PipeScheduler.Inline, PipeScheduler.Inline)); 60var pipe = new Pipe(new PipeOptions(_dirtyMemoryPool, PipeScheduler.Inline, PipeScheduler.Inline)); 76var pipe = new Pipe(new PipeOptions(_dirtyMemoryPool, PipeScheduler.Inline, PipeScheduler.Inline));
Http3\Http3FrameWriterTests.cs (3)
41var pipe = new Pipe(new PipeOptions(_dirtyMemoryPool, PipeScheduler.Inline, PipeScheduler.Inline)); 55var pipe = new Pipe(new PipeOptions(_dirtyMemoryPool, PipeScheduler.Inline, PipeScheduler.Inline)); 74var pipe = new Pipe(new PipeOptions(_dirtyMemoryPool, PipeScheduler.Inline, PipeScheduler.Inline));
Http3\Http3HttpProtocolFeatureCollectionTests.cs (2)
24transport: DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()).Application,
HttpResponseHeadersTests.cs (1)
26var options = new PipeOptions(memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
PipelineExtensionTests.cs (1)
23_pipe = new Pipe(new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false));
StartLineTests.cs (1)
519var options = new PipeOptions(MemoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
TestHelpers\TestInput.cs (1)
28var options = new PipeOptions(pool: _memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (16)
ChunkWriterBenchmark.cs (1)
24var pipe = new Pipe(new PipeOptions(_memoryPool));
HeaderCollectionBenchmark.cs (1)
328var options = new PipeOptions(memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http1ConnectionBenchmark.cs (1)
31var options = new PipeOptions(memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http1ConnectionParsingOverheadBenchmark.cs (1)
27var options = new PipeOptions(memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http1LargeWritingBenchmark.cs (1)
67var options = new PipeOptions(_memoryPool, useSynchronizationContext: false);
Http1ReadingBenchmark.cs (1)
96var options = new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http1WritingBenchmark.cs (1)
101var options = new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http2\Http2ConnectionBenchmarkBase.cs (1)
48var options = new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http2\Http2FrameWriterBenchmark.cs (1)
29var options = new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
HttpProtocolFeatureCollection.cs (1)
230var options = new PipeOptions(memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
InMemoryTransportBenchmark.cs (2)
172var inputOptions = new PipeOptions(useSynchronizationContext: false); 173var outputOptions = new PipeOptions(useSynchronizationContext: false);
PipeThroughputBenchmark.cs (1)
23_pipe = new Pipe(new PipeOptions(_memoryPool));
RequestParsingBenchmark.cs (2)
28var options = new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false); 49Pipe = new Pipe(new PipeOptions(_memoryPool));
ResponseHeaderCollectionBenchmark.cs (1)
176var options = new PipeOptions(memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (2)
Internal\NamedPipeConnectionListener.cs (2)
57_inputOptions = new PipeOptions(_memoryPool, PipeScheduler.ThreadPool, PipeScheduler.Inline, maxReadBufferSize, maxReadBufferSize / 2, useSynchronizationContext: false); 58_outputOptions = new PipeOptions(_memoryPool, PipeScheduler.Inline, PipeScheduler.ThreadPool, maxWriteBufferSize, maxWriteBufferSize / 2, useSynchronizationContext: false);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (2)
Internal\QuicStreamContext.cs (2)
60var inputOptions = new PipeOptions(MemoryPool, PipeScheduler.ThreadPool, PipeScheduler.Inline, maxReadBufferSize, maxReadBufferSize / 2, useSynchronizationContext: false); 61var outputOptions = new PipeOptions(MemoryPool, PipeScheduler.Inline, PipeScheduler.ThreadPool, maxWriteBufferSize, maxWriteBufferSize / 2, useSynchronizationContext: false);
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (6)
Client\SocketConnectionFactory.cs (2)
42_inputOptions = new PipeOptions(_memoryPool, applicationScheduler, transportScheduler, maxReadBufferSize, maxReadBufferSize / 2, useSynchronizationContext: false); 43_outputOptions = new PipeOptions(_memoryPool, transportScheduler, applicationScheduler, maxWriteBufferSize, maxWriteBufferSize / 2, useSynchronizationContext: false);
SocketConnectionContextFactory.cs (4)
56InputOptions = new PipeOptions(memoryPool, applicationScheduler, transportScheduler, maxReadBufferSize, maxReadBufferSize / 2, useSynchronizationContext: false), 57OutputOptions = new PipeOptions(memoryPool, transportScheduler, applicationScheduler, maxWriteBufferSize, maxWriteBufferSize / 2, useSynchronizationContext: false), 73InputOptions = new PipeOptions(memoryPool, applicationScheduler, transportScheduler, maxReadBufferSize, maxReadBufferSize / 2, useSynchronizationContext: false), 74OutputOptions = new PipeOptions(memoryPool, transportScheduler, applicationScheduler, maxWriteBufferSize, maxWriteBufferSize / 2, useSynchronizationContext: false),
Microsoft.AspNetCore.SignalR.Client.Tests (2)
HubConnectionTests.cs (1)
226var connection = new TestConnection(pipeOptions: new PipeOptions(readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, pauseWriterThreshold: 100, useSynchronizationContext: false, resumeWriterThreshold: 50));
TestConnection.cs (1)
55var options = pipeOptions ?? new PipeOptions(readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
BroadcastBenchmark.cs (1)
41var options = new PipeOptions();
Microsoft.AspNetCore.SignalR.Specification.Tests (1)
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (1)
43var options = new PipeOptions(readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false,
Microsoft.AspNetCore.SignalR.Tests (26)
Internal\MessageBufferTests.cs (26)
22var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 50var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions(pauseWriterThreshold: 200000, resumeWriterThreshold: 100000)); 87var pipeOptions = new PipeOptions(pauseWriterThreshold: 100, resumeWriterThreshold: 50); 88var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 128var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 177var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 221var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 245var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 288var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 325var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 367var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions()); 404var pipeOptions = new PipeOptions(pauseWriterThreshold: 250, resumeWriterThreshold: 120); 405var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 415DuplexPipe.UpdateConnectionPair(ref pipes, connection, new PipeOptions(pauseWriterThreshold: 100, resumeWriterThreshold: 50)); 446var pipeOptions = new PipeOptions(pauseWriterThreshold: 100, resumeWriterThreshold: 50); 447var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions); 544var input = new Pipe(pipeOptions ?? new PipeOptions());
Microsoft.AspNetCore.SignalR.Tests.Utils (1)
TestClient.cs (1)
43var options = new PipeOptions(readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false,
System.IO.Pipelines (1)
System\IO\Pipelines\PipeOptions.cs (1)
16public static PipeOptions Default { get; } = new PipeOptions();
151 references to PipeOptions
ClientSample (4)
src\SignalR\common\Shared\DuplexPipe.cs (2)
18public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
Tcp\TcpConnection.cs (2)
63var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
InMemory.FunctionalTests (10)
Http2\Http2TestBase.cs (4)
471var inputPipeOptions = GetInputPipeOptions(_serviceContext, _memoryPool, PipeScheduler.ThreadPool); 472var outputPipeOptions = GetOutputPipeOptions(_serviceContext, _memoryPool, PipeScheduler.ThreadPool); 1406private static PipeOptions GetInputPipeOptions(ServiceContext serviceContext, MemoryPool<byte> memoryPool, PipeScheduler writerScheduler) => new PipeOptions 1417private static PipeOptions GetOutputPipeOptions(ServiceContext serviceContext, MemoryPool<byte> memoryPool, PipeScheduler readerScheduler) => new PipeOptions
Http2\PipeReaderFactory.cs (1)
17public static PipeReader CreateFromStream(PipeOptions options, Stream stream, CancellationToken cancellationToken)
Http2\TlsTests.cs (1)
74var reader = PipeReaderFactory.CreateFromStream(PipeOptions.Default, sslStream, CancellationToken.None);
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (4)
363public static PipeOptions GetInputPipeOptions(ServiceContext serviceContext, MemoryPool<byte> memoryPool, PipeScheduler writerScheduler) => new PipeOptions 374public static PipeOptions GetOutputPipeOptions(ServiceContext serviceContext, MemoryPool<byte> memoryPool, PipeScheduler readerScheduler) => new PipeOptions 1130var inputOptions = Http3InMemory.GetInputPipeOptions(_testBase._serviceContext, _testBase._memoryPool, PipeScheduler.ThreadPool); 1131var outputOptions = Http3InMemory.GetOutputPipeOptions(_testBase._serviceContext, _testBase._memoryPool, PipeScheduler.ThreadPool);
Microsoft.AspNetCore.Http.Connections (6)
HttpConnectionDispatcherOptions.cs (4)
20private PipeOptions? _transportPipeOptions; 21private PipeOptions? _appPipeOptions; 140internal PipeOptions TransportPipeOptions => _transportPipeOptions ??= new PipeOptions(pauseWriterThreshold: TransportMaxBufferSize, resumeWriterThreshold: TransportMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false); 142internal PipeOptions AppPipeOptions => _appPipeOptions ??= new PipeOptions(pauseWriterThreshold: ApplicationMaxBufferSize, resumeWriterThreshold: ApplicationMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);
src\SignalR\common\Shared\DuplexPipe.cs (2)
18public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
Microsoft.AspNetCore.Http.Connections.Client (7)
HttpConnectionOptions.cs (4)
31private PipeOptions? _transportPipeOptions; 32private PipeOptions? _appPipeOptions; 125internal PipeOptions TransportPipeOptions => _transportPipeOptions ??= new PipeOptions(pauseWriterThreshold: TransportMaxBufferSize, resumeWriterThreshold: TransportMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false); 127internal PipeOptions AppPipeOptions => _appPipeOptions ??= new PipeOptions(pauseWriterThreshold: ApplicationMaxBufferSize, resumeWriterThreshold: ApplicationMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);
Internal\ClientPipeOptions.cs (1)
10public static PipeOptions DefaultOptions = new PipeOptions(writerScheduler: PipeScheduler.ThreadPool, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);
src\SignalR\common\Shared\DuplexPipe.cs (2)
18public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
Microsoft.AspNetCore.Http.Connections.Tests (34)
LongPollingTests.cs (8)
25var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default); 45var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default); 67var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default); 90var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
ServerSentEventsTests.cs (8)
24var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default); 45var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default); 66var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, new PipeOptions(readerScheduler: PipeScheduler.Inline)); 88var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, new PipeOptions(readerScheduler: PipeScheduler.Inline)); 116var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
WebSocketsTests.cs (18)
33var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default); 80var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default); 122var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default); 174var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default); 205var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default); 239var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default); 273var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default); 312var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default); 354var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
Microsoft.AspNetCore.Server.IIS (2)
src\Shared\ServerInfrastructure\DuplexPipe.cs (2)
31public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
Microsoft.AspNetCore.Server.Kestrel.Core (3)
Internal\Http2\Http2Connection.cs (1)
1842private PipeOptions GetInputPipeOptions() => new PipeOptions(pool: _context.MemoryPool,
src\Shared\ServerInfrastructure\DuplexPipe.cs (2)
31public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (12)
Http1\Http1ConnectionTestsBase.cs (1)
35var options = new PipeOptions(_pipelineFactory, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http1\Http1OutputProducerTests.cs (8)
36var pipeOptions = new PipeOptions 61var pipeOptions = new PipeOptions 89var pipeOptions = new PipeOptions 143var pipeOptions = new PipeOptions 163var pipeOptions = new PipeOptions 183var pipeOptions = new PipeOptions 205var pipeOptions = new PipeOptions 224PipeOptions pipeOptions = null,
HttpResponseHeadersTests.cs (1)
26var options = new PipeOptions(memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
StartLineTests.cs (1)
519var options = new PipeOptions(MemoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
TestHelpers\TestInput.cs (1)
28var options = new PipeOptions(pool: _memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (17)
HeaderCollectionBenchmark.cs (1)
328var options = new PipeOptions(memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http1ConnectionBenchmark.cs (1)
31var options = new PipeOptions(memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http1ConnectionParsingOverheadBenchmark.cs (1)
27var options = new PipeOptions(memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http1LargeWritingBenchmark.cs (1)
67var options = new PipeOptions(_memoryPool, useSynchronizationContext: false);
Http1ReadingBenchmark.cs (1)
96var options = new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http1WritingBenchmark.cs (1)
101var options = new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http2\Http2ConnectionBenchmarkBase.cs (1)
48var options = new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
Http2\Http2FrameWriterBenchmark.cs (1)
29var options = new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
HttpProtocolFeatureCollection.cs (1)
230var options = new PipeOptions(memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
InMemoryTransportBenchmark.cs (2)
172var inputOptions = new PipeOptions(useSynchronizationContext: false); 173var outputOptions = new PipeOptions(useSynchronizationContext: false);
RequestParsingBenchmark.cs (1)
28var options = new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
ResponseHeaderCollectionBenchmark.cs (1)
176var options = new PipeOptions(memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (4)
363public static PipeOptions GetInputPipeOptions(ServiceContext serviceContext, MemoryPool<byte> memoryPool, PipeScheduler writerScheduler) => new PipeOptions 374public static PipeOptions GetOutputPipeOptions(ServiceContext serviceContext, MemoryPool<byte> memoryPool, PipeScheduler readerScheduler) => new PipeOptions 1130var inputOptions = Http3InMemory.GetInputPipeOptions(_testBase._serviceContext, _testBase._memoryPool, PipeScheduler.ThreadPool); 1131var outputOptions = Http3InMemory.GetOutputPipeOptions(_testBase._serviceContext, _testBase._memoryPool, PipeScheduler.ThreadPool);
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (8)
Internal\NamedPipeConnection.cs (3)
10using PipeOptions = System.IO.Pipelines.PipeOptions; 40PipeOptions inputOptions, 41PipeOptions outputOptions)
Internal\NamedPipeConnectionListener.cs (3)
14using PipeOptions = System.IO.Pipelines.PipeOptions; 28private readonly PipeOptions _inputOptions; 29private readonly PipeOptions _outputOptions;
src\Shared\ServerInfrastructure\DuplexPipe.cs (2)
31public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (4)
Internal\QuicStreamContext.cs (2)
60var inputOptions = new PipeOptions(MemoryPool, PipeScheduler.ThreadPool, PipeScheduler.Inline, maxReadBufferSize, maxReadBufferSize / 2, useSynchronizationContext: false); 61var outputOptions = new PipeOptions(MemoryPool, PipeScheduler.Inline, PipeScheduler.ThreadPool, maxWriteBufferSize, maxWriteBufferSize / 2, useSynchronizationContext: false);
src\Shared\ServerInfrastructure\DuplexPipe.cs (2)
31public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (8)
Client\SocketConnectionFactory.cs (2)
20private readonly PipeOptions _inputOptions; 21private readonly PipeOptions _outputOptions;
Internal\SocketConnection.cs (2)
39PipeOptions inputOptions, 40PipeOptions outputOptions,
SocketConnectionContextFactory.cs (2)
120public PipeOptions InputOptions { get; init; } = default!; 121public PipeOptions OutputOptions { get; init; } = default!;
src\Shared\ServerInfrastructure\DuplexPipe.cs (2)
31public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
Microsoft.AspNetCore.Shared.Tests (2)
src\Shared\ServerInfrastructure\DuplexPipe.cs (2)
31public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
Microsoft.AspNetCore.SignalR.Client.Tests (3)
TestConnection.cs (2)
48public TestConnection(Func<Task> onStart = null, Func<Task> onDispose = null, bool autoHandshake = true, bool hasInherentKeepAlive = false, PipeOptions pipeOptions = null) 55var options = pipeOptions ?? new PipeOptions(readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false);
TestTransport.cs (1)
43var options = ClientPipeOptions.DefaultOptions;
Microsoft.AspNetCore.SignalR.Microbenchmarks (3)
BroadcastBenchmark.cs (1)
41var options = new PipeOptions();
DefaultHubDispatcherBenchmark.cs (2)
42var pair = DuplexPipe.CreateConnectionPair(PipeOptions.Default, PipeOptions.Default);
Microsoft.AspNetCore.SignalR.Specification.Tests (3)
src\SignalR\common\Shared\DuplexPipe.cs (2)
18public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (1)
43var options = new PipeOptions(readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false,
Microsoft.AspNetCore.SignalR.Tests (7)
EndToEndTests.cs (1)
721var options = ClientPipeOptions.DefaultOptions;
Internal\MessageBufferTests.cs (6)
87var pipeOptions = new PipeOptions(pauseWriterThreshold: 100, resumeWriterThreshold: 50); 404var pipeOptions = new PipeOptions(pauseWriterThreshold: 250, resumeWriterThreshold: 120); 446var pipeOptions = new PipeOptions(pauseWriterThreshold: 100, resumeWriterThreshold: 50); 518public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions) 542public static void UpdateConnectionPair(ref DuplexPipePair duplexPipePair, ConnectionContext connection, PipeOptions pipeOptions = null)
Microsoft.AspNetCore.SignalR.Tests.Utils (3)
src\SignalR\common\Shared\DuplexPipe.cs (2)
18public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
TestClient.cs (1)
43var options = new PipeOptions(readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false,
System.IO.Pipelines (14)
System\IO\Pipelines\Pipe.cs (4)
34private readonly PipeOptions _options; 86/// <summary>Initializes a new instance of the <see cref="System.IO.Pipelines.Pipe" /> class using <see cref="System.IO.Pipelines.PipeOptions.Default" /> as options.</summary> 87public Pipe() : this(PipeOptions.Default) 93public Pipe(PipeOptions options)
System\IO\Pipelines\PipeOptions.cs (10)
14/// <summary>Gets the default instance of <see cref="System.IO.Pipelines.PipeOptions" />.</summary> 15/// <value>A <see cref="System.IO.Pipelines.PipeOptions" /> object initialized with default parameters.</value> 16public static PipeOptions Default { get; } = new PipeOptions(); 18/// <summary>Initializes a new instance of the <see cref="System.IO.Pipelines.PipeOptions" /> class with the specified parameters.</summary> 25/// <param name="useSynchronizationContext"><see langword="true" /> if asynchronous continuations should be executed on the <see cref="System.Threading.SynchronizationContext" /> they were captured on; <see langword="false" /> otherwise. This takes precedence over the schedulers specified in <see cref="System.IO.Pipelines.PipeOptions.ReaderScheduler" /> and <see cref="System.IO.Pipelines.PipeOptions.WriterScheduler" />.</param> 88/// <summary>Gets a value that determines if asynchronous callbacks and continuations should be executed on the <see cref="System.Threading.SynchronizationContext" /> they were captured on. This takes precedence over the schedulers specified in <see cref="System.IO.Pipelines.PipeOptions.ReaderScheduler" /> and <see cref="System.IO.Pipelines.PipeOptions.WriterScheduler" />.</summary> 100/// <summary>Gets the minimum size of the segment requested from the <see cref="System.IO.Pipelines.PipeOptions.Pool" />.</summary> 101/// <value>The minimum size of the segment requested from the <see cref="System.IO.Pipelines.PipeOptions.Pool" />.</value>
System.Text.Json (1)
System\Text\Json\Serialization\Metadata\JsonTypeInfoOfT.WriteHelpers.cs (1)
79int flushThreshold = (int)(4 * PipeOptions.Default.MinimumSegmentSize * JsonSerializer.FlushThreshold);