11 instantiations of PipeOptions
Microsoft.AspNetCore.Http.Connections (2)
HttpConnectionDispatcherOptions.cs (2)
140
internal PipeOptions TransportPipeOptions => _transportPipeOptions ??= new
PipeOptions
(pauseWriterThreshold: TransportMaxBufferSize, resumeWriterThreshold: TransportMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);
142
internal PipeOptions AppPipeOptions => _appPipeOptions ??= new
PipeOptions
(pauseWriterThreshold: ApplicationMaxBufferSize, resumeWriterThreshold: ApplicationMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);
Microsoft.AspNetCore.Server.Kestrel.Core (6)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)
548
=> new Pipe(new
PipeOptions
Internal\Http2\Http2Connection.cs (1)
1882
private PipeOptions GetInputPipeOptions() => new
PipeOptions
(pool: _context.MemoryPool,
Internal\Http2\Http2OutputProducer.cs (1)
763
=> new Pipe(new
PipeOptions
Internal\Http2\Http2Stream.cs (1)
646
=> new Pipe(new
PipeOptions
Internal\Http3\Http3OutputProducer.cs (1)
476
=> new Pipe(new
PipeOptions
Internal\Http3\Http3Stream.cs (1)
1239
=> new Pipe(new
PipeOptions
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (2)
Internal\QuicStreamContext.cs (2)
60
var inputOptions = new
PipeOptions
(MemoryPool, PipeScheduler.ThreadPool, PipeScheduler.Inline, maxReadBufferSize, maxReadBufferSize / 2, useSynchronizationContext: false);
61
var outputOptions = new
PipeOptions
(MemoryPool, PipeScheduler.Inline, PipeScheduler.ThreadPool, maxWriteBufferSize, maxWriteBufferSize / 2, useSynchronizationContext: false);
System.IO.Pipelines (1)
System\IO\Pipelines\PipeOptions.cs (1)
16
public static PipeOptions Default { get; } = new
PipeOptions
();
28 references to PipeOptions
Microsoft.AspNetCore.Http.Connections (6)
HttpConnectionDispatcherOptions.cs (4)
20
private
PipeOptions
? _transportPipeOptions;
21
private
PipeOptions
? _appPipeOptions;
140
internal
PipeOptions
TransportPipeOptions => _transportPipeOptions ??= new PipeOptions(pauseWriterThreshold: TransportMaxBufferSize, resumeWriterThreshold: TransportMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);
142
internal
PipeOptions
AppPipeOptions => _appPipeOptions ??= new PipeOptions(pauseWriterThreshold: ApplicationMaxBufferSize, resumeWriterThreshold: ApplicationMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);
src\aspnetcore\src\SignalR\common\Shared\DuplexPipe.cs (2)
18
public static DuplexPipePair CreateConnectionPair(
PipeOptions
inputOptions,
PipeOptions
outputOptions)
Microsoft.AspNetCore.Server.Kestrel.Core (3)
Internal\Http2\Http2Connection.cs (1)
1882
private
PipeOptions
GetInputPipeOptions() => new PipeOptions(pool: _context.MemoryPool,
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (2)
31
public static DuplexPipePair CreateConnectionPair(
PipeOptions
inputOptions,
PipeOptions
outputOptions)
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (4)
Internal\QuicStreamContext.cs (2)
60
var
inputOptions = new PipeOptions(MemoryPool, PipeScheduler.ThreadPool, PipeScheduler.Inline, maxReadBufferSize, maxReadBufferSize / 2, useSynchronizationContext: false);
61
var
outputOptions = new PipeOptions(MemoryPool, PipeScheduler.Inline, PipeScheduler.ThreadPool, maxWriteBufferSize, maxWriteBufferSize / 2, useSynchronizationContext: false);
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (2)
31
public static DuplexPipePair CreateConnectionPair(
PipeOptions
inputOptions,
PipeOptions
outputOptions)
System.IO.Pipelines (14)
System\IO\Pipelines\Pipe.cs (4)
34
private 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>
87
public Pipe() : this(
PipeOptions
.Default)
93
public 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>
16
public 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)
80
int flushThreshold = (int)(4 *
PipeOptions
.Default.MinimumSegmentSize * JsonSerializer.FlushThreshold);