Skip to content

Commit ac3a927

Browse files
committed
Update
1 parent 00a1b8e commit ac3a927

File tree

4 files changed

+9
-6
lines changed

4 files changed

+9
-6
lines changed

src/Servers/Kestrel/Transport.NamedPipes/src/Internal/NamedPipeConnectionListener.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ public void Start()
5858
{
5959
Debug.Assert(_listeningTasks == null, "Already started");
6060

61-
_listeningTasks = new Task[_options.AcceptQueueCount];
61+
_listeningTasks = new Task[_options.ListenerQueueCount];
6262

6363
for (var i = 0; i < _listeningTasks.Length; i++)
6464
{

src/Servers/Kestrel/Transport.NamedPipes/src/NamedPipeTransportOptions.cs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,9 +12,12 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes;
1212
public sealed class NamedPipeTransportOptions
1313
{
1414
/// <summary>
15-
///
15+
/// The number of listener queues used to accept name pipe connections.
1616
/// </summary>
17-
public int AcceptQueueCount { get; set; } = Math.Min(Environment.ProcessorCount, 16);
17+
/// <remarks>
18+
/// Defaults to <see cref="Environment.ProcessorCount" /> rounded down and clamped between 1 and 16.
19+
/// </remarks>
20+
public int ListenerQueueCount { get; set; } = Math.Min(Environment.ProcessorCount, 16);
1821

1922
/// <summary>
2023
/// Gets or sets the maximum unconsumed incoming bytes the transport will buffer.

src/Servers/Kestrel/Transport.NamedPipes/src/PublicAPI.Unshipped.txt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
11
#nullable enable
22
Microsoft.AspNetCore.Hosting.WebHostBuilderNamedPipeExtensions
33
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes.NamedPipeTransportOptions
4-
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes.NamedPipeTransportOptions.AcceptQueueCount.get -> int
5-
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes.NamedPipeTransportOptions.AcceptQueueCount.set -> void
64
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes.NamedPipeTransportOptions.CurrentUserOnly.get -> bool
75
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes.NamedPipeTransportOptions.CurrentUserOnly.set -> void
6+
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes.NamedPipeTransportOptions.ListenerQueueCount.get -> int
7+
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes.NamedPipeTransportOptions.ListenerQueueCount.set -> void
88
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes.NamedPipeTransportOptions.MaxReadBufferSize.get -> long?
99
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes.NamedPipeTransportOptions.MaxReadBufferSize.set -> void
1010
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes.NamedPipeTransportOptions.MaxWriteBufferSize.get -> long?

src/Servers/Kestrel/Transport.NamedPipes/test/NamedPipeConnectionListenerTests.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ public async Task AcceptAsync_ParallelConnections_ClientConnectionsSuccessfullyA
7777

7878
var currentCallCount = 0;
7979
var options = new NamedPipeTransportOptions();
80-
options.AcceptQueueCount = 16;
80+
options.ListenerQueueCount = 16;
8181
await using var connectionListener = await NamedPipeTestHelpers.CreateConnectionListenerFactory(LoggerFactory, options: options);
8282

8383
// Act

0 commit comments

Comments
 (0)