Skip to content

Commit 00a1b8e

Browse files
committed
Clean up
1 parent 1f99139 commit 00a1b8e

File tree

2 files changed

+3
-5
lines changed

2 files changed

+3
-5
lines changed

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

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -65,13 +65,13 @@ public void Start()
6565
// Start first stream inline to catch creation errors.
6666
var initialStream = CreateServerStream();
6767

68-
_listeningTasks[i] = Task.Run(() => StartAsync(initialStream, i));
68+
_listeningTasks[i] = Task.Run(() => StartAsync(initialStream));
6969
}
7070
}
7171

7272
public EndPoint EndPoint => _endpoint;
7373

74-
private async Task StartAsync(NamedPipeServerStream nextStream, int index)
74+
private async Task StartAsync(NamedPipeServerStream nextStream)
7575
{
7676
try
7777
{
@@ -83,8 +83,6 @@ private async Task StartAsync(NamedPipeServerStream nextStream, int index)
8383

8484
await stream.WaitForConnectionAsync(_listeningToken);
8585

86-
_log.LogInformation("Connection accepted on " + index);
87-
8886
var connection = new NamedPipeConnection(stream, _endpoint, _log, _memoryPool, _inputOptions, _outputOptions);
8987
connection.Start();
9088

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 = 1;
80+
options.AcceptQueueCount = 16;
8181
await using var connectionListener = await NamedPipeTestHelpers.CreateConnectionListenerFactory(LoggerFactory, options: options);
8282

8383
// Act

0 commit comments

Comments
 (0)