Pipe

Dcp\ApplicationExecutorTests.cs (1)

448var s = new Pipe();

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

Http2\PipeReaderFactory.cs (1)

24var pipe = new Pipe(options);

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

1133_inputPipe = new Pipe(inputOptions); 1134_outputPipe = new Pipe(outputOptions);

Circuits\RemoteJSDataStream.cs (1)

78_pipe = new Pipe();

ServerStreamingServerCallHandlerTests.cs (5)

47var pipe = new Pipe(); 95var pipe = new Pipe(); 137var pipe = new Pipe(); 177var pipe = new Pipe(); 226var pipe = new Pipe();

Internal\HttpConnectionContext.cs (1)

709var input = new Pipe(_options.TransportPipeOptions);

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

Internal\WebSocketsTransport.cs (1)

707var input = new Pipe(_httpConnectionOptions.TransportPipeOptions);

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

Features\FormFeatureTests.cs (1)

92var pipe = new Pipe();

CachedResponseBodyTests.cs (3)

31var pipe = new Pipe(); 53var pipe = new Pipe(); 77var pipe = new Pipe();

ResponseCachingBenchmark.cs (2)

54var pipe = new Pipe(); 72var pipe = new Pipe();

CachedResponseBodyTests.cs (3)

39var pipe = new Pipe(); 60var pipe = new Pipe(); 83var pipe = new Pipe();

Core\IISHttpContext.cs (2)

305var pipe = new Pipe(new PipeOptions( 502_bodyInputPipe = new Pipe(new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.ThreadPool, minimumSegmentSize: MinAllocBufferSize));

src\Shared\ServerInfrastructure\DuplexPipe.cs (2)

33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)

517=> new Pipe(new PipeOptions

Internal\Http2\Http2Connection.cs (1)

165_input = new Pipe(GetInputPipeOptions());

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

src\Shared\ServerInfrastructure\DuplexPipe.cs (2)

33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

BufferWriterTests.cs (1)

16Pipe = new Pipe(new PipeOptions(useSynchronizationContext: false, pauseWriterThreshold: 0, resumeWriterThreshold: 0));

Http1\Http1OutputProducerTests.cs (1)

231var pipe = new Pipe(pipeOptions);

Http2\Http2FrameWriterTests.cs (4)

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)); 93var sut = CreateFrameWriter(new Pipe());

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));

PipelineExtensionTests.cs (1)

23_pipe = new Pipe(new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false));

ChunkWriterBenchmark.cs (1)

24var pipe = new Pipe(new PipeOptions(_memoryPool));

Http2\Http2FrameWriterBenchmark.cs (1)

30_pipe = new Pipe(options);

PipeThroughputBenchmark.cs (1)

23_pipe = new Pipe(new PipeOptions(_memoryPool));

RequestParsingBenchmark.cs (1)

49Pipe = new Pipe(new PipeOptions(_memoryPool));

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

1133_inputPipe = new Pipe(inputOptions); 1134_outputPipe = new Pipe(outputOptions);

src\Shared\ServerInfrastructure\DuplexPipe.cs (2)

33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

Internal\QuicStreamContext.cs (2)

63_inputPipe = new Pipe(inputOptions); 64_outputPipe = new Pipe(outputOptions);

src\Shared\ServerInfrastructure\DuplexPipe.cs (2)

33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

src\Shared\ServerInfrastructure\DuplexPipe.cs (2)

33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

src\Shared\ServerInfrastructure\DuplexPipe.cs (2)

33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

SendUtilsTests.cs (1)

37var pipe = new Pipe();

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

HubConnectionHandlerTests.cs (1)

5286var input = new Pipe();

Internal\MessageBufferTests.cs (3)

520var input = new Pipe(inputOptions); 521var output = new Pipe(outputOptions); 544var input = new Pipe(pipeOptions ?? new PipeOptions());

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

HttpContextBuilder.cs (2)

43_requestPipe = new Pipe(); 45var responsePipe = new Pipe();

FormReaderBenchmark.cs (1)

30var pipe = new Pipe();

FormPipeReaderTests.cs (3)

191Pipe bodyPipe = new Pipe(); 533var pipe = new Pipe(); 630Pipe bodyPipe = new Pipe();

RemoteCallback.cs (1)

108var pipe = new Pipe();

Dcp\ApplicationExecutorTests.cs (7)

445var logStreamPipesChannel = Channel.CreateUnbounded<(string Type, Pipe Pipe)>(); 448var s = new Pipe(); 603public Pipe StandardOut { get; set; } = default!; 604public Pipe StandardErr { get; set; } = default!; 605public Pipe StartupOut { get; set; } = default!; 606public Pipe StartupErr { get; set; } = default!; 609private static async Task<LogStreamPipes> GetStreamPipesAsync(Channel<(string Type, Pipe Pipe)> logStreamPipesChannel)

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

Http2\PipeReaderFactory.cs (2)

24var pipe = new Pipe(options); 30private static async Task CopyToAsync(Stream stream, Pipe pipe, CancellationToken cancellationToken)

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

1098private Pipe _inputPipe; 1099private Pipe _outputPipe;

Circuits\RemoteJSDataStream.cs (1)

18private readonly Pipe _pipe;

ServerStreamingServerCallHandlerTests.cs (5)

47var pipe = new Pipe(); 95var pipe = new Pipe(); 137var pipe = new Pipe(); 177var pipe = new Pipe(); 226var pipe = new Pipe();

Internal\HttpConnectionContext.cs (1)

709var input = new Pipe(_options.TransportPipeOptions);

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

Internal\WebSocketsTransport.cs (1)

707var input = new Pipe(_httpConnectionOptions.TransportPipeOptions);

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

Features\FormFeatureTests.cs (1)

92var pipe = new Pipe();

CachedResponseBodyTests.cs (3)

31var pipe = new Pipe(); 53var pipe = new Pipe(); 77var pipe = new Pipe();

ResponseCachingBenchmark.cs (3)

54var pipe = new Pipe(); 72var pipe = new Pipe(); 84private static DefaultHttpContext CreateHttpContext(Pipe pipe)

CachedResponseBodyTests.cs (3)

39var pipe = new Pipe(); 60var pipe = new Pipe(); 83var pipe = new Pipe();

Core\IISHttpContext.cs (2)

65protected Pipe? _bodyInputPipe; 305var pipe = new Pipe(new PipeOptions(

Core\OutputProducer.cs (2)

17private readonly Pipe _pipe; 26public OutputProducer(Pipe pipe)

src\Shared\ServerInfrastructure\DuplexPipe.cs (4)

7/// A <see cref="Pipe"/> is a reader-writer pair, where content written to the writer can be read from the reader. 16/// <see cref="Pipe"/>s, as these underlie the <see cref="IDuplexPipe"/> instances. In either view, it is composed of 33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

Internal\Http\Http1ChunkedEncodingMessageBody.cs (2)

27private readonly Pipe _requestBodyPipe; 516private static Pipe CreateRequestBodyPipe(Http1Connection context)

Internal\Http2\Http2Connection.cs (1)

108private readonly Pipe _input;

Internal\Http2\Http2OutputProducer.cs (2)

32private readonly Pipe _pipe; 765private static Pipe CreateDataPipe(MemoryPool<byte> pool, bool scheduleInline)

Internal\Http2\Http2Stream.cs (2)

42public Pipe RequestBodyPipe { get; private set; } = default!; 646private Pipe CreateRequestBodyPipe()

Internal\Http3\Http3OutputProducer.cs (2)

24private readonly Pipe _pipe; 477private static Pipe CreateDataPipe(MemoryPool<byte> pool)

Internal\Http3\Http3Stream.cs (2)

69public Pipe RequestBodyPipe { get; private set; } = default!; 1182private Pipe CreateRequestBodyPipe(uint windowSize)

src\Shared\ServerInfrastructure\DuplexPipe.cs (4)

7/// A <see cref="Pipe"/> is a reader-writer pair, where content written to the writer can be read from the reader. 16/// <see cref="Pipe"/>s, as these underlie the <see cref="IDuplexPipe"/> instances. In either view, it is composed of 33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

BufferWriterTests.cs (1)

13protected Pipe Pipe;

Http1\Http1OutputProducerTests.cs (3)

231var pipe = new Pipe(pipeOptions); 254public TestHttpOutputProducer(Pipe pipe, string connectionId, ConnectionContext connectionContext, MemoryPool<byte> memoryPool, KestrelTrace log, ITimeoutControl timeoutControl, IHttpMinResponseDataRateFeature minResponseDataRateFeature, ConnectionMetricsContext metricsContext, IHttpOutputAborter outputAborter) 260public Pipe Pipe { get; }

Http2\Http2FrameWriterTests.cs (4)

38var pipe = new Pipe(new PipeOptions(_dirtyMemoryPool, PipeScheduler.Inline, PipeScheduler.Inline)); 50private Http2FrameWriter CreateFrameWriter(Pipe pipe) 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 (4)

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)); 89private Http3FrameWriter CreateFrameWriter(Pipe pipe)

PipelineExtensionTests.cs (1)

18private readonly Pipe _pipe;

ChunkWriterBenchmark.cs (1)

24var pipe = new Pipe(new PipeOptions(_memoryPool));

Http2\Http2FrameWriterBenchmark.cs (1)

20private Pipe _pipe;

PipeThroughputBenchmark.cs (1)

16private Pipe _pipe;

RequestParsingBenchmark.cs (1)

20public Pipe Pipe { get; set; }

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

1098private Pipe _inputPipe; 1099private Pipe _outputPipe;

src\Shared\ServerInfrastructure\DuplexPipe.cs (4)

7/// A <see cref="Pipe"/> is a reader-writer pair, where content written to the writer can be read from the reader. 16/// <see cref="Pipe"/>s, as these underlie the <see cref="IDuplexPipe"/> instances. In either view, it is composed of 33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

Internal\QuicStreamContext.cs (2)

26private readonly Pipe _inputPipe; 27private readonly Pipe _outputPipe;

src\Shared\ServerInfrastructure\DuplexPipe.cs (4)

7/// A <see cref="Pipe"/> is a reader-writer pair, where content written to the writer can be read from the reader. 16/// <see cref="Pipe"/>s, as these underlie the <see cref="IDuplexPipe"/> instances. In either view, it is composed of 33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

src\Shared\ServerInfrastructure\DuplexPipe.cs (4)

7/// A <see cref="Pipe"/> is a reader-writer pair, where content written to the writer can be read from the reader. 16/// <see cref="Pipe"/>s, as these underlie the <see cref="IDuplexPipe"/> instances. In either view, it is composed of 33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

src\Shared\ServerInfrastructure\DuplexPipe.cs (4)

7/// A <see cref="Pipe"/> is a reader-writer pair, where content written to the writer can be read from the reader. 16/// <see cref="Pipe"/>s, as these underlie the <see cref="IDuplexPipe"/> instances. In either view, it is composed of 33var input = new Pipe(inputOptions); 34var output = new Pipe(outputOptions);

SendUtilsTests.cs (1)

37var pipe = new Pipe();

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

HubConnectionHandlerTests.cs (1)

5286var input = new Pipe();

Internal\MessageBufferTests.cs (3)

520var input = new Pipe(inputOptions); 521var output = new Pipe(outputOptions); 544var input = new Pipe(pipeOptions ?? new PipeOptions());

src\SignalR\common\Shared\DuplexPipe.cs (2)

20var input = new Pipe(inputOptions); 21var output = new Pipe(outputOptions);

HttpContextBuilder.cs (2)

25private readonly Pipe _requestPipe; 45var responsePipe = new Pipe();

ResponseBodyPipeWriter.cs (2)

12private readonly Pipe _pipe; 17internal ResponseBodyPipeWriter(Pipe pipe, Func<Task> onFirstWriteAsync)

ResponseBodyReaderStream.cs (2)

22private readonly Pipe _pipe; 24internal ResponseBodyReaderStream(Pipe pipe, Action abortRequest, Action readComplete)

FormReaderBenchmark.cs (1)

30var pipe = new Pipe();

FormPipeReaderTests.cs (3)

191Pipe bodyPipe = new Pipe(); 533var pipe = new Pipe(); 630Pipe bodyPipe = new Pipe();

RemoteCallback.cs (1)

108var pipe = new Pipe();

System\IO\Pipelines\Pipe.cs (4)

17private static readonly Action<object?> s_signalReaderAwaitable = state => ((Pipe)state!).ReaderCancellationRequested(); 18private static readonly Action<object?> s_signalWriterAwaitable = state => ((Pipe)state!).WriterCancellationRequested(); 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> 91/// <summary>Initializes a new instance of the <see cref="System.IO.Pipelines.Pipe" /> class with the specified options.</summary>

System\IO\Pipelines\Pipe.DefaultPipeReader.cs (2)

15private readonly Pipe _pipe; 17public DefaultPipeReader(Pipe pipe)

System\IO\Pipelines\Pipe.DefaultPipeWriter.cs (2)

15private readonly Pipe _pipe; 17public DefaultPipeWriter(Pipe pipe)

System\IO\Pipelines\PipeOptions.cs (8)