99 references to PipeOptions
InMemory.FunctionalTests (2)
Microsoft.AspNetCore.Http.Connections (2)
Microsoft.AspNetCore.Http.Connections.Client (3)
Microsoft.AspNetCore.Http.Connections.Tests (2)
Microsoft.AspNetCore.Server.IIS (2)
Microsoft.AspNetCore.Server.Kestrel.Core (6)
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (22)
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (16)
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)
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
Microsoft.AspNetCore.SignalR.Specification.Tests (1)
Microsoft.AspNetCore.SignalR.Tests (28)
Internal\MessageBufferTests.cs (28)
23var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions());
51var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions(pauseWriterThreshold: 200000, resumeWriterThreshold: 100000));
88var pipeOptions = new PipeOptions(pauseWriterThreshold: 100, resumeWriterThreshold: 50);
89var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions);
129var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions());
179var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions());
234var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions());
278var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions());
302var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions());
345var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions());
382var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions());
424var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), new PipeOptions());
461var pipeOptions = new PipeOptions(pauseWriterThreshold: 250, resumeWriterThreshold: 120);
462var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions);
472DuplexPipe.UpdateConnectionPair(ref pipes, connection, new PipeOptions(pauseWriterThreshold: 100, resumeWriterThreshold: 50));
503var pipeOptions = new PipeOptions(pauseWriterThreshold: 100, resumeWriterThreshold: 50);
504var pipes = DuplexPipe.CreateConnectionPair(new PipeOptions(), pipeOptions);
601var input = new Pipe(pipeOptions ?? new PipeOptions());
Microsoft.AspNetCore.SignalR.Tests.Utils (1)
System.IO.Pipelines (1)