3 types derived from PipeScheduler
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (1)
Internal\IOQueue.cs (1)
11internal sealed class IOQueue : PipeScheduler, IThreadPoolWorkItem
System.IO.Pipelines (2)
System\IO\Pipelines\InlineScheduler.cs (1)
6internal sealed class InlineScheduler : PipeScheduler
System\IO\Pipelines\ThreadPoolScheduler.netcoreapp.cs (1)
9internal sealed class ThreadPoolScheduler : PipeScheduler
79 references to PipeScheduler
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 (4)
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 (2)
10public static PipeOptions DefaultOptions = new PipeOptions(writerScheduler: PipeScheduler.ThreadPool, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);
Microsoft.AspNetCore.Server.IIS (2)
Core\IISHttpContext.cs (2)
313readerScheduler: PipeScheduler.Inline, 555_bodyInputPipe = new Pipe(new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.ThreadPool, minimumSegmentSize: MinAllocBufferSize));
Microsoft.AspNetCore.Server.Kestrel.Core (13)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)
552writerScheduler: PipeScheduler.Inline,
Internal\Http2\Http2Connection.cs (2)
195_scheduleInline = context.ServiceContext.Scheduler == PipeScheduler.Inline; 1884writerScheduler: PipeScheduler.Inline,
Internal\Http2\Http2FrameWriter.cs (1)
133_scheduleInline = serviceContext.Scheduler == PipeScheduler.Inline;
Internal\Http2\Http2OutputProducer.cs (3)
66var scheduleInline = context.ServiceContext.Scheduler == PipeScheduler.Inline; 766readerScheduler: PipeScheduler.Inline, 767writerScheduler: PipeScheduler.ThreadPool,
Internal\Http2\Http2Stream.cs (1)
653writerScheduler: PipeScheduler.Inline,
Internal\Http3\Http3OutputProducer.cs (2)
479readerScheduler: PipeScheduler.Inline, 480writerScheduler: PipeScheduler.ThreadPool,
Internal\Http3\Http3Stream.cs (1)
1246writerScheduler: PipeScheduler.Inline,
Internal\KestrelServerImpl.cs (1)
101Scheduler = PipeScheduler.ThreadPool,
Internal\ServiceContext.cs (1)
20public PipeScheduler Scheduler { get; set; } = default!;
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (4)
Internal\NamedPipeConnectionListener.cs (4)
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 (4)
Internal\QuicStreamContext.cs (4)
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 (25)
Client\SocketConnectionFactory.cs (6)
37var applicationScheduler = _options.UnsafePreferInlineScheduling ? PipeScheduler.Inline : PipeScheduler.ThreadPool; 38var transportScheduler = applicationScheduler; 40var awaiterScheduler = OperatingSystem.IsWindows() ? transportScheduler : PipeScheduler.Inline;
Internal\SocketAwaitableEventArgs.cs (2)
19private readonly PipeScheduler _ioScheduler; 27public SocketAwaitableEventArgs(PipeScheduler ioScheduler)
Internal\SocketConnection.cs (1)
37PipeScheduler socketScheduler,
Internal\SocketReceiver.cs (1)
11public SocketReceiver(PipeScheduler ioScheduler) : base(ioScheduler)
Internal\SocketSender.cs (1)
16public SocketSender(PipeScheduler scheduler) : base(scheduler)
Internal\SocketSenderPool.cs (3)
15private readonly PipeScheduler _scheduler; 18public SocketSenderPool(PipeScheduler scheduler) 23public PipeScheduler Scheduler => _scheduler;
SocketConnectionContextFactory.cs (11)
42var applicationScheduler = options.UnsafePreferInlineScheduling ? PipeScheduler.Inline : PipeScheduler.ThreadPool; 51var transportScheduler = options.UnsafePreferInlineScheduling ? PipeScheduler.Inline : new IOQueue(); 58SocketSenderPool = new SocketSenderPool(PipeScheduler.Inline), 66var transportScheduler = options.UnsafePreferInlineScheduling ? PipeScheduler.Inline : PipeScheduler.ThreadPool; 75SocketSenderPool = new SocketSenderPool(PipeScheduler.Inline), 119public PipeScheduler Scheduler { get; init; } = default!;
Microsoft.AspNetCore.SignalR.Specification.Tests (2)
src\aspnetcore\src\SignalR\common\testassets\Tests.Utils\TestClient.cs (2)
43var options = new PipeOptions(readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false,
System.IO.Pipelines (23)
System\IO\Pipelines\Pipe.cs (5)
56private PipeScheduler ReaderScheduler => _options.ReaderScheduler; 57private PipeScheduler WriterScheduler => _options.WriterScheduler; 911private static void ScheduleCallbacks(PipeScheduler scheduler, PipeCompletionCallbacks completionCallbacks) 919private static void TrySchedule(PipeScheduler scheduler, in CompletionData completionData) 945private static void ScheduleWithContext(PipeScheduler scheduler, in CompletionData completionData)
System\IO\Pipelines\PipeOptions.cs (12)
20/// <param name="readerScheduler">The <see cref="System.IO.Pipelines.PipeScheduler" /> to be used to execute <see cref="System.IO.Pipelines.PipeReader" /> callbacks and async continuations.</param> 21/// <param name="writerScheduler">The <see cref="System.IO.Pipelines.PipeScheduler" /> used to execute <see cref="System.IO.Pipelines.PipeWriter" /> callbacks and async continuations.</param> 28PipeScheduler? readerScheduler = null, 29PipeScheduler? writerScheduler = null, 86ReaderScheduler = readerScheduler ?? PipeScheduler.ThreadPool; 87WriterScheduler = writerScheduler ?? PipeScheduler.ThreadPool; 109/// <summary>Gets the <see cref="System.IO.Pipelines.PipeScheduler" /> used to execute <see cref="System.IO.Pipelines.PipeWriter" /> callbacks and async continuations.</summary> 110/// <value>A <see cref="System.IO.Pipelines.PipeScheduler" /> object used to execute <see cref="System.IO.Pipelines.PipeWriter" /> callbacks and async continuations.</value> 111public PipeScheduler WriterScheduler { get; } 113/// <summary>Gets the <see cref="System.IO.Pipelines.PipeScheduler" /> used to execute <see cref="System.IO.Pipelines.PipeReader" /> callbacks and async continuations.</summary> 114/// <value>A <see cref="System.IO.Pipelines.PipeScheduler" /> that is used to execute <see cref="System.IO.Pipelines.PipeReader" /> callbacks and async continuations.</value> 115public PipeScheduler ReaderScheduler { get; }
System\IO\Pipelines\PipeScheduler.cs (6)
14/// <summary>The <see cref="System.IO.Pipelines.PipeScheduler" /> implementation that queues callbacks to the thread pool.</summary> 15/// <value>A <see cref="System.IO.Pipelines.PipeScheduler" /> instance that queues callbacks to the thread pool.</value> 16public static PipeScheduler ThreadPool => s_threadPoolScheduler; 18/// <summary>The <see cref="System.IO.Pipelines.PipeScheduler" /> implementation that runs callbacks inline.</summary> 19/// <value>A <see cref="System.IO.Pipelines.PipeScheduler" /> instance that runs callbacks inline.</value> 20public static PipeScheduler Inline => s_inlineScheduler;