25 instantiations of PipeOptions
Microsoft.AspNetCore.Http.Connections (2)
HttpConnectionDispatcherOptions.cs (2)
152internal PipeOptions TransportPipeOptions => _transportPipeOptions ??= new PipeOptions(pauseWriterThreshold: TransportMaxBufferSize, resumeWriterThreshold: TransportMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false); 154internal 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.Server.IIS (2)
Core\IISHttpContext.cs (2)
308var pipe = new Pipe(new PipeOptions( 555_bodyInputPipe = new Pipe(new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.ThreadPool, minimumSegmentSize: MinAllocBufferSize));
Microsoft.AspNetCore.Server.Kestrel.Core (6)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)
548=> new Pipe(new PipeOptions
Internal\Http2\Http2Connection.cs (1)
1882private PipeOptions GetInputPipeOptions() => new PipeOptions(pool: _context.MemoryPool,
Internal\Http2\Http2OutputProducer.cs (1)
763=> new Pipe(new PipeOptions
Internal\Http2\Http2Stream.cs (1)
649=> new Pipe(new PipeOptions
Internal\Http3\Http3OutputProducer.cs (1)
476=> new Pipe(new PipeOptions
Internal\Http3\Http3Stream.cs (1)
1242=> new Pipe(new PipeOptions
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.Specification.Tests (1)
src\aspnetcore\src\SignalR\common\testassets\Tests.Utils\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();
56 references to PipeOptions
Microsoft.AspNetCore.Http.Connections (6)
HttpConnectionDispatcherOptions.cs (4)
20private PipeOptions? _transportPipeOptions; 21private PipeOptions? _appPipeOptions; 152internal PipeOptions TransportPipeOptions => _transportPipeOptions ??= new PipeOptions(pauseWriterThreshold: TransportMaxBufferSize, resumeWriterThreshold: TransportMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false); 154internal PipeOptions AppPipeOptions => _appPipeOptions ??= new PipeOptions(pauseWriterThreshold: ApplicationMaxBufferSize, resumeWriterThreshold: ApplicationMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);
src\aspnetcore\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\aspnetcore\src\SignalR\common\Shared\DuplexPipe.cs (2)
18public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
Microsoft.AspNetCore.Server.IIS (2)
src\aspnetcore\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)
1882private PipeOptions GetInputPipeOptions() => new PipeOptions(pool: _context.MemoryPool,
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (2)
31public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
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\aspnetcore\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\aspnetcore\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)
40PipeOptions inputOptions, 41PipeOptions outputOptions,
SocketConnectionContextFactory.cs (2)
120public PipeOptions InputOptions { get; init; } = default!; 121public PipeOptions OutputOptions { get; init; } = default!;
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (2)
31public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
Microsoft.AspNetCore.SignalR.Specification.Tests (3)
src\aspnetcore\src\SignalR\common\Shared\DuplexPipe.cs (2)
18public static DuplexPipePair CreateConnectionPair(PipeOptions inputOptions, PipeOptions outputOptions)
src\aspnetcore\src\SignalR\common\testassets\Tests.Utils\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)
37private readonly PipeOptions _options; 96/// <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> 97public Pipe() : this(PipeOptions.Default) 103public 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> 93/// <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> 105/// <summary>Gets the minimum size of the segment requested from the <see cref="System.IO.Pipelines.PipeOptions.Pool" />.</summary> 106/// <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)
80int flushThreshold = (int)(4 * PipeOptions.Default.MinimumSegmentSize * JsonSerializer.FlushThreshold);