1486 references to DefaultTimeout
InMemory.FunctionalTests (255)
ChunkedResponseTests.cs (1)
497
await flushWh.Task.
DefaultTimeout
();
ConnectionLimitTests.cs (1)
51
await releasedTcs.Task.
DefaultTimeout
();
Http2\Http2ConnectionTests.cs (36)
476
await WaitForAllStreamsAsync().
DefaultTimeout
();
570
await serverTcs.Task.
DefaultTimeout
();
582
await WaitForStreamAsync(stream.StreamId).
DefaultTimeout
();
1173
await stream1ReadFinished.Task.
DefaultTimeout
();
1179
await stream3ReadFinished.Task.
DefaultTimeout
();
1188
await stream1Read.Task.
DefaultTimeout
();
1191
await stream3Read.Task.
DefaultTimeout
();
1634
await firstRequestBlock.Task.
DefaultTimeout
();
1641
await firstRequestReceived.Task.
DefaultTimeout
();
1781
await tcs.Task.
DefaultTimeout
();
1999
}).
DefaultTimeout
();
2001
await StartStreamAsync(1, _browserRequestHeaders, endStream: true).
DefaultTimeout
();
2033
await requestAbortedTcs.Task.
DefaultTimeout
();
2291
await finishFirstRequest.Task.
DefaultTimeout
();
2297
await finishSecondRequest.Task.
DefaultTimeout
();
2303
await firstRequestReceived.Task.
DefaultTimeout
();
2307
await secondRequestReceived.Task.
DefaultTimeout
();
3271
await _runningStreams[1].Task.
DefaultTimeout
();
3292
await _runningStreams[3].Task.
DefaultTimeout
();
3368
await writeTasks[1].
DefaultTimeout
();
3373
await writeTasks[3].
DefaultTimeout
();
3377
await writeTasks[5].
DefaultTimeout
();
4169
await _closingStateReached.Task.
DefaultTimeout
();
4200
await _closedStateReached.Task.
DefaultTimeout
();
4634
await backpressureObservedTcs.Task.
DefaultTimeout
();
4638
await backpressureReleasedTcs.Task.
DefaultTimeout
();
5111
await _closedStateReached.Task.
DefaultTimeout
();
5126
await _closedStateReached.Task.
DefaultTimeout
();
5140
await _closedStateReached.Task.
DefaultTimeout
();
5170
await _closedStateReached.Task.
DefaultTimeout
();
5201
await _closingStateReached.Task.
DefaultTimeout
();
5220
await _closedStateReached.Task.
DefaultTimeout
();
5236
await _closingStateReached.Task.
DefaultTimeout
();
5285
await _closedStateReached.Task.
DefaultTimeout
();
5304
await _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)).
DefaultTimeout
();
5324
await _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)).
DefaultTimeout
();
Http2\Http2KeepAliveTests.cs (40)
16
await InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
20
await StopConnectionAsync(expectedLastStreamId: 0, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
30
await InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
50
await StopConnectionAsync(expectedLastStreamId: 0, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
59
await InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
72
await StopConnectionAsync(expectedLastStreamId: 0, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
81
await InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
86
await SendPingAsync(Http2PingFrameFlags.NONE).
DefaultTimeout
();
95
await StopConnectionAsync(expectedLastStreamId: 0, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
104
await InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
112
await StopConnectionAsync(expectedLastStreamId: 0, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
121
await InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
135
await StopConnectionAsync(expectedLastStreamId: 0, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
144
await InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
154
await SendPingAsync(Http2PingFrameFlags.ACK).
DefaultTimeout
();
163
await SendPingAsync(Http2PingFrameFlags.ACK).
DefaultTimeout
();
173
await StopConnectionAsync(expectedLastStreamId: 0, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
183
await InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
215
await InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
229
await StartStreamAsync(1, _browserRequestHeaders, endStream: true).
DefaultTimeout
();
237
await StopConnectionAsync(expectedLastStreamId: 1, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
246
await InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
251
await StartStreamAsync(1, _browserRequestHeaders, endStream: true).
DefaultTimeout
();
261
await StopConnectionAsync(expectedLastStreamId: 1, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
280
}, expectedWindowUpdate: false).
DefaultTimeout
();
285
await StartStreamAsync(1, _browserRequestHeaders, endStream: false).
DefaultTimeout
();
288
await SendDataAsync(1, new byte[16384], false).
DefaultTimeout
();
289
await SendDataAsync(1, new byte[16384], false).
DefaultTimeout
();
290
await SendDataAsync(1, new byte[16384], false).
DefaultTimeout
();
291
await SendDataAsync(1, new byte[16383], false).
DefaultTimeout
();
297
await SendPingAsync(Http2PingFrameFlags.NONE).
DefaultTimeout
();
315
await StopConnectionAsync(expectedLastStreamId: 1, ignoreNonGoAwayFrames: true).
DefaultTimeout
();
334
}, expectedWindowUpdate: false).
DefaultTimeout
();
339
await StartStreamAsync(1, _browserRequestHeaders, endStream: false).
DefaultTimeout
();
342
await SendDataAsync(1, new byte[16384], false).
DefaultTimeout
();
343
await SendDataAsync(1, new byte[16384], false).
DefaultTimeout
();
344
await SendDataAsync(1, new byte[16384], false).
DefaultTimeout
();
345
await SendDataAsync(1, new byte[16383], false).
DefaultTimeout
();
359
await SendPingAsync(Http2PingFrameFlags.ACK).
DefaultTimeout
();
373
await StopConnectionAsync(expectedLastStreamId: 1, ignoreNonGoAwayFrames: true).
DefaultTimeout
();
Http2\Http2StreamTests.cs (44)
2622
await StopConnectionAsync(expectedLastStreamId: 1, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
2722
await StopConnectionAsync(expectedLastStreamId: 3, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
2781
await StopConnectionAsync(expectedLastStreamId: 1, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
2836
await StopConnectionAsync(expectedLastStreamId: 1, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
2966
await StopConnectionAsync(expectedLastStreamId: 3, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
2991
}).
DefaultTimeout
();
2993
await StartStreamAsync(1, headers, endStream: true).
DefaultTimeout
();
3023
await StopConnectionAsync(expectedLastStreamId: 1, ignoreNonGoAwayFrames: false).
DefaultTimeout
();
3191
await sem.WaitAsync().
DefaultTimeout
();
3224
await sem.WaitAsync().
DefaultTimeout
();
3275
await sem.WaitAsync().
DefaultTimeout
();
3319
await sem.WaitAsync().
DefaultTimeout
();
4744
await context.Response.CompleteAsync().
DefaultTimeout
();
4751
await clientTcs.Task.
DefaultTimeout
();
4799
await context.Response.CompleteAsync().
DefaultTimeout
();
4800
await context.Response.CompleteAsync().
DefaultTimeout
(); // Can be called twice, no-ops
4807
await clientTcs.Task.
DefaultTimeout
();
4867
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.CompleteAsync().
DefaultTimeout
());
4923
await context.Response.CompleteAsync().
DefaultTimeout
();
4924
await context.Response.CompleteAsync().
DefaultTimeout
(); // Can be called twice, no-ops
4929
await clientTcs.Task.
DefaultTimeout
();
4984
await context.Response.CompleteAsync().
DefaultTimeout
();
4990
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.WriteAsync("2 Hello World").
DefaultTimeout
());
4994
await clientTcs.Task.
DefaultTimeout
();
5041
await context.Response.WriteAsync("Hello World").
DefaultTimeout
();
5045
await context.Response.CompleteAsync().
DefaultTimeout
();
5049
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.WriteAsync("2 Hello World").
DefaultTimeout
());
5053
await clientTcs.Task.
DefaultTimeout
();
5134
await tcs.Task.
DefaultTimeout
();
5164
await context.Response.CompleteAsync().
DefaultTimeout
();
5171
await clientTcs.Task.
DefaultTimeout
();
5240
await context.Response.CompleteAsync().
DefaultTimeout
();
5245
await clientTcs.Task.
DefaultTimeout
();
5315
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.CompleteAsync().
DefaultTimeout
());
5321
await clientTcs.Task.
DefaultTimeout
();
5392
await clientTcs.Task.
DefaultTimeout
();
5455
await context.Response.CompleteAsync().
DefaultTimeout
();
5464
await clientTcs.Task.
DefaultTimeout
();
5537
await context.Response.CompleteAsync().
DefaultTimeout
();
5549
await clientTcs.Task.
DefaultTimeout
();
5619
await context.Response.CompleteAsync().
DefaultTimeout
();
5630
await clientTcs.Task.
DefaultTimeout
();
5703
await context.Response.CompleteAsync().
DefaultTimeout
();
5717
await clientTcs.Task.
DefaultTimeout
();
Http2\Http2TestBase.cs (5)
277
await sem.WaitAsync().
DefaultTimeout
();
305
await sem.WaitAsync().
DefaultTimeout
();
325
await sem.WaitAsync().
DefaultTimeout
();
778
return Task.WhenAll(_runningStreams.Values.Select(tcs => tcs.Task)).
DefaultTimeout
();
1330
await _connectionTask.
DefaultTimeout
();
Http2\Http2TimeoutTests.cs (4)
91
await setTimeoutTcs.Task.
DefaultTimeout
();
320
await sendTask.
DefaultTimeout
();
369
await app.WriteStartedTask.
DefaultTimeout
();
422
await app.WriteStartedTask.
DefaultTimeout
();
Http2\Http2WebSocketTests.cs (2)
238
await tcs.Task.
DefaultTimeout
();
675
await tcs.Task.
DefaultTimeout
();
Http3\Http3ConnectionTests.cs (10)
159
await requestStream.OnDisposedTask.
DefaultTimeout
();
182
await request.OnStreamCompletedTask.
DefaultTimeout
();
301
await controlStream.EndStreamAsync().
DefaultTimeout
();
304
await controlStream.OnStreamCompletedTask.
DefaultTimeout
();
332
await completionSource.Task.
DefaultTimeout
();
590
await requestStream.OnDisposedTask.
DefaultTimeout
();
729
await requestStream.OnDisposedTask.
DefaultTimeout
();
734
await abortTcs.Task.
DefaultTimeout
();
766
await _requestTcs.Task.
DefaultTimeout
();
810
await requestStream.OnDisposedTask.
DefaultTimeout
();
Http3\Http3StreamTests.cs (39)
780
await appTcs.Task.
DefaultTimeout
();
1140
await context.Response.CompleteAsync().
DefaultTimeout
();
1147
await clientTcs.Task.
DefaultTimeout
();
1188
await context.Response.CompleteAsync().
DefaultTimeout
();
1189
await context.Response.CompleteAsync().
DefaultTimeout
(); // Can be called twice, no-ops
1196
await clientTcs.Task.
DefaultTimeout
();
1242
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.CompleteAsync().
DefaultTimeout
());
1291
await context.Response.CompleteAsync().
DefaultTimeout
();
1292
await context.Response.CompleteAsync().
DefaultTimeout
(); // Can be called twice, no-ops
1297
await clientTcs.Task.
DefaultTimeout
();
1339
await context.Response.CompleteAsync().
DefaultTimeout
();
1345
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.WriteAsync("2 Hello World").
DefaultTimeout
());
1349
await clientTcs.Task.
DefaultTimeout
();
1389
await context.Response.WriteAsync("Hello World").
DefaultTimeout
();
1393
await context.Response.CompleteAsync().
DefaultTimeout
();
1397
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.WriteAsync("2 Hello World").
DefaultTimeout
());
1401
await clientTcs.Task.
DefaultTimeout
();
1459
await tcs.Task.
DefaultTimeout
();
1491
await context.Response.CompleteAsync().
DefaultTimeout
();
1498
await clientTcs.Task.
DefaultTimeout
();
1548
await context.Response.CompleteAsync().
DefaultTimeout
();
1553
await clientTcs.Task.
DefaultTimeout
();
1604
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.CompleteAsync().
DefaultTimeout
());
1610
await clientTcs.Task.
DefaultTimeout
();
1668
await clientTcs.Task.
DefaultTimeout
();
1718
await context.Response.CompleteAsync().
DefaultTimeout
();
1727
await clientTcs.Task.
DefaultTimeout
();
1779
await context.Response.CompleteAsync().
DefaultTimeout
();
1791
await clientTcs.Task.
DefaultTimeout
();
1841
await context.Response.CompleteAsync().
DefaultTimeout
();
1852
await clientTcs.Task.
DefaultTimeout
();
1906
await context.Response.CompleteAsync().
DefaultTimeout
();
1920
await clientTcs.Task.
DefaultTimeout
();
2074
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
2555
await requestStream.OnStreamCompletedTask.
DefaultTimeout
();
2629
await requestStream.OnStreamCompletedTask.
DefaultTimeout
();
2684
await requestStream.OnStreamCompletedTask.
DefaultTimeout
();
2769
CoreStrings.FormatHttp3ControlStreamErrorUnsupportedType(typeId)).
DefaultTimeout
();
2838
await clientTcs.Task.
DefaultTimeout
();
Http3\Http3TimeoutTests.cs (22)
23
await Http3Api.InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
39
await Http3Api.InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
63
await Http3Api.InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
72
await requestStream.OnDisposedTask.
DefaultTimeout
();
98
}).
DefaultTimeout
();
118
await requestStream.OnDisposedTask.
DefaultTimeout
();
138
await requestStream.SendHeadersPartialAsync().
DefaultTimeout
();
183
await requestStream.OnUnidentifiedStreamCreatedTask.
DefaultTimeout
();
189
await requestStream.OnStreamCreatedTask.
DefaultTimeout
();
199
await requestStream.SendHeadersAsync(headers).
DefaultTimeout
();
201
await requestStream.OnHeaderReceivedTask.
DefaultTimeout
();
221
await Http3Api.InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
228
await outboundControlStream.OnUnidentifiedStreamCreatedTask.
DefaultTimeout
();
256
await Http3Api.InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
263
await outboundControlStream.OnStreamCreatedTask.
DefaultTimeout
();
285
await Http3Api.InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
295
await outboundControlStream.OnStreamCreatedTask.
DefaultTimeout
();
311
await Http3Api.InitializeConnectionAsync(_noopApplication).
DefaultTimeout
();
321
await outboundControlStream.OnUnidentifiedStreamCreatedTask.
DefaultTimeout
();
326
await outboundControlStream.OnStreamCreatedTask.
DefaultTimeout
();
464
await app.WriteStartedTask.
DefaultTimeout
();
506
await app.WriteStartedTask.
DefaultTimeout
();
HttpsConnectionMiddlewareTests.cs (1)
1103
await stream.WriteAsync(request, 0, request.Length).
DefaultTimeout
();
HttpsTests.cs (6)
187
await loggerProvider.FilterLogger.LogTcs.Task.
DefaultTimeout
();
216
await loggerProvider.FilterLogger.LogTcs.Task.
DefaultTimeout
();
311
await tcs.Task.
DefaultTimeout
();
387
await loggerProvider.FilterLogger.LogTcs.Task.
DefaultTimeout
();
421
await loggerProvider.FilterLogger.LogTcs.Task.
DefaultTimeout
();
705
await loggerProvider.FilterLogger.LogTcs.Task.
DefaultTimeout
();
KeepAliveTimeoutTests.cs (2)
110
await _firstRequestReceived.Task.
DefaultTimeout
();
155
await _firstRequestReceived.Task.
DefaultTimeout
();
KestrelMetricsTests.cs (12)
73
await connection.Send(sendString).
DefaultTimeout
();
76
await sync.WaitForSyncPoint().
DefaultTimeout
();
89
"Hello World?").
DefaultTimeout
();
91
await connection.WaitForConnectionClose().
DefaultTimeout
();
244
await waitForConnectionCloseRequest.Task.
DefaultTimeout
();
302
await requestReceivedTcs.Task.
DefaultTimeout
();
416
await connection.Send(sendString).
DefaultTimeout
();
420
await connection.ReceiveEnd().
DefaultTimeout
();
422
await connection.WaitForConnectionClose().
DefaultTimeout
();
590
await waitForConnectionCloseRequest.Task.
DefaultTimeout
();
829
await connectionDuration.WaitForMeasurementsAsync(minCount: 1).
DefaultTimeout
();
835
await shutdownTask.
DefaultTimeout
();
RequestBodyTimeoutTests.cs (4)
72
await appRunningEvent.Task.
DefaultTimeout
();
131
await appRunningEvent.Task.
DefaultTimeout
();
198
await appRunningTcs.Task.
DefaultTimeout
();
207
await exceptionSwallowedTcs.Task.
DefaultTimeout
();
RequestTests.cs (5)
266
await Task.WhenAll(pathTcs.Task, rawTargetTcs.Task, queryTcs.Task).
DefaultTimeout
();
1213
await tcs.Task.
DefaultTimeout
();
1216
await tcs2.Task.
DefaultTimeout
();
1644
await delayEvent.Task.
DefaultTimeout
();
1664
await appEvent.Task.
DefaultTimeout
();
ResponseDrainingTests.cs (1)
56
await outputBufferedTcs.Task.
DefaultTimeout
();
ResponseTests.cs (14)
68
await onCompletedTcs.Task.
DefaultTimeout
();
156
await context.Response.WriteAsync("hello", cts.Token).
DefaultTimeout
();
202
await writeBlockedTcs.Task.
DefaultTimeout
();
471
await onCompletedTcs.Task.
DefaultTimeout
();
935
await logTcs.Task.
DefaultTimeout
();
1141
await logTcs.Task.
DefaultTimeout
();
1198
await logTcs.Task.
DefaultTimeout
();
1229
await requestAborted.Task.
DefaultTimeout
();
1253
await requestAborted.Task.
DefaultTimeout
();
1561
await responseWritten.Task.
DefaultTimeout
();
2567
await tcs.Task.
DefaultTimeout
();
2613
await tcs.Task.
DefaultTimeout
();
3354
await onStartingTcs.Task.
DefaultTimeout
();
3405
await onCompletedTcs.Task.
DefaultTimeout
();
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)
153
await _connectionTask.
DefaultTimeout
();
UpgradeTests.cs (5)
57
await upgrade.Task.
DefaultTimeout
();
112
await upgrade.Task.
DefaultTimeout
();
154
var ex = await Assert.ThrowsAsync<InvalidOperationException>(async () => await upgradeTcs.Task.
DefaultTimeout
());
384
await appCompletedTcs.Task.
DefaultTimeout
();
430
await appCompletedTcs.Task.
DefaultTimeout
();
Interop.FunctionalTests (160)
Http2\Http2RequestTests.cs (5)
138
await connectionDuration.WaitForMeasurementsAsync(minCount: 1).
DefaultTimeout
();
207
await host.StartAsync().
DefaultTimeout
();
267
await host.StartAsync().
DefaultTimeout
();
272
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
280
await stopTask.
DefaultTimeout
();
Http3\Http3RequestTests.cs (53)
99
await connectionDuration.WaitForMeasurementsAsync(minCount: 1).
DefaultTimeout
();
146
await host.StartAsync().
DefaultTimeout
();
304
await requestStream.FlushAsync().
DefaultTimeout
();
413
await host.StartAsync().
DefaultTimeout
();
428
await requestStream.FlushAsync().
DefaultTimeout
();
442
await host.StopAsync().
DefaultTimeout
();
483
await host.StartAsync().
DefaultTimeout
();
499
await requestStream.FlushAsync().
DefaultTimeout
();
503
await requestStream.FlushAsync().
DefaultTimeout
();
506
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
517
await cancelledTcs.Task.
DefaultTimeout
();
524
await host.StopAsync().
DefaultTimeout
();
555
await host.StartAsync().
DefaultTimeout
();
569
await requestStream.FlushAsync().
DefaultTimeout
();
580
await cancelledTcs.Task.
DefaultTimeout
();
583
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
590
await host.StopAsync().
DefaultTimeout
();
613
await host.StartAsync().
DefaultTimeout
();
642
await host.StopAsync().
DefaultTimeout
();
673
await host.StartAsync().
DefaultTimeout
();
689
await cancelledTcs.Task.
DefaultTimeout
();
692
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
696
await serverWriteTask.
DefaultTimeout
();
698
await host.StopAsync().
DefaultTimeout
();
720
await host.StartAsync().
DefaultTimeout
();
743
await host.StopAsync().
DefaultTimeout
();
993
await clientHasCancelledSyncPoint.WaitForSyncPoint().
DefaultTimeout
();
1008
await host.StartAsync().
DefaultTimeout
();
1024
await requestStream.FlushAsync().
DefaultTimeout
();
1027
await requestStream.FlushAsync().
DefaultTimeout
();
1039
await clientHasCancelledSyncPoint.WaitToContinue().
DefaultTimeout
();
1042
await cancelledTcs.Task.
DefaultTimeout
();
1049
await host.StopAsync().
DefaultTimeout
();
1105
await host.StartAsync().
DefaultTimeout
();
1121
await requestStream.FlushAsync().
DefaultTimeout
();
1129
await requestStream.FlushAsync().
DefaultTimeout
();
1147
await host.StopAsync().
DefaultTimeout
();
1253
await host.StartAsync().
DefaultTimeout
();
1272
await host.StopAsync().
DefaultTimeout
();
1314
await host.StartAsync().
DefaultTimeout
();
1331
await cancelledTcs.Task.
DefaultTimeout
();
1333
await host.StopAsync().
DefaultTimeout
();
1726
await connectionStartedTcs.Task.
DefaultTimeout
();
1735
await connectionClosedTcs.Task.
DefaultTimeout
();
1880
await host.StartAsync().
DefaultTimeout
();
1895
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
1910
await host.StopAsync().
DefaultTimeout
();
2034
await host.StartAsync().
DefaultTimeout
();
2085
await requestAbortedTcs.Task.
DefaultTimeout
();
2087
await stopTask.
DefaultTimeout
();
2134
await host.StartAsync().
DefaultTimeout
();
2169
await stopTask.
DefaultTimeout
();
2197
await host.StopAsync().
DefaultTimeout
();
Http3\Http3TlsTests.cs (15)
54
await host.StartAsync().
DefaultTimeout
();
69
await host.StopAsync().
DefaultTimeout
();
101
await host.StartAsync().
DefaultTimeout
();
113
await host.StopAsync().
DefaultTimeout
();
143
await host.StartAsync().
DefaultTimeout
();
155
await host.StopAsync().
DefaultTimeout
();
192
await host.StartAsync().
DefaultTimeout
();
214
await host.StopAsync().
DefaultTimeout
();
242
await host.StartAsync().
DefaultTimeout
();
252
await host.StopAsync().
DefaultTimeout
();
282
host.StartAsync().
DefaultTimeout
());
320
await host.StartAsync().
DefaultTimeout
();
335
await host.StopAsync().
DefaultTimeout
();
468
await host.StartAsync().
DefaultTimeout
();
500
await host.StopAsync().
DefaultTimeout
();
HttpClientHttp2InteropTests.cs (87)
67
await host.StopAsync().
DefaultTimeout
();
81
await context.Request.BodyReader.CopyToAsync(context.Response.BodyWriter).
DefaultTimeout
();
96
await host.StopAsync().
DefaultTimeout
();
120
await content.CopyToAsync(context.Response.Body).
DefaultTimeout
();
140
await BulkContent.VerifyContent(await response.Content.ReadAsStreamAsync()).
DefaultTimeout
();
144
await host.StopAsync().
DefaultTimeout
();
167
await context.Request.BodyReader.CopyToAsync(context.Response.BodyWriter).
DefaultTimeout
();
193
await host.StopAsync().
DefaultTimeout
();
216
await stream.WriteAsync(Content, 0, Content.Length, timer.Token).
DefaultTimeout
();
301
await streamingContent.SendAsync("Hello World").
DefaultTimeout
();
308
await streamingContent.SendAsync("Hello World").
DefaultTimeout
();
313
await host.StopAsync().
DefaultTimeout
();
341
await context.Response.CompleteAsync().
DefaultTimeout
();
378
await streamingContent.SendAsync("Hello World").
DefaultTimeout
();
389
await streamingContent.SendAsync("Hello World").
DefaultTimeout
();
395
await host.StopAsync().
DefaultTimeout
();
412
await context.Response.CompleteAsync().
DefaultTimeout
();
444
await streamingContent.SendAsync("Hello World").
DefaultTimeout
();
448
await host.StopAsync().
DefaultTimeout
();
541
await host.StopAsync().
DefaultTimeout
();
558
await headersReceived.Task.
DefaultTimeout
();
577
await host.StopAsync().
DefaultTimeout
();
601
await host.StopAsync().
DefaultTimeout
();
617
await receivedHeaders.Task.
DefaultTimeout
();
630
await host.StopAsync().
DefaultTimeout
();
657
await host.StopAsync().
DefaultTimeout
();
689
await host.StopAsync().
DefaultTimeout
();
709
await headersReceived.Task.
DefaultTimeout
();
740
await serverReset.Task.
DefaultTimeout
();
743
await Assert.ThrowsAsync<HttpProtocolException>(() => streamingContent.SendAsync("Hello World").
DefaultTimeout
());
746
await host.StopAsync().
DefaultTimeout
();
768
await responseHeadersReceived.Task.
DefaultTimeout
();
793
await streamingContent.SendAsync("Hello World").
DefaultTimeout
();
799
await serverReset.Task.
DefaultTimeout
();
802
await Assert.ThrowsAsync<HttpProtocolException>(() => streamingContent.SendAsync("Hello World").
DefaultTimeout
());
805
await host.StopAsync().
DefaultTimeout
();
845
await requestReceived.Task.
DefaultTimeout
();
846
await streamingContent.SendStarted.
DefaultTimeout
();
848
await serverResult.Task.
DefaultTimeout
();
851
await host.StopAsync().
DefaultTimeout
();
890
await streamingContent.SendAsync("Hello World").
DefaultTimeout
();
891
await requestReceived.Task.
DefaultTimeout
();
893
await serverResult.Task.
DefaultTimeout
();
896
await host.StopAsync().
DefaultTimeout
();
916
await serverResult.Task.
DefaultTimeout
();
917
await context.Response.WriteAsync("Hello World").
DefaultTimeout
();
933
await requestReceived.Task.
DefaultTimeout
();
935
await serverResult.Task.
DefaultTimeout
();
938
await host.StopAsync().
DefaultTimeout
();
956
await context.Response.WriteAsync("Hello World").
DefaultTimeout
();
957
await serverResult.Task.
DefaultTimeout
();
958
await context.Response.WriteAsync("Hello World").
DefaultTimeout
();
976
await serverResult.Task.
DefaultTimeout
();
978
await host.StopAsync().
DefaultTimeout
();
996
await context.Response.WriteAsync("Hello World").
DefaultTimeout
();
997
await serverResult.Task.
DefaultTimeout
();
1017
await serverResult.Task.
DefaultTimeout
();
1019
await host.StopAsync().
DefaultTimeout
();
1065
await serverResult.Task.
DefaultTimeout
();
1071
await host.StopAsync().
DefaultTimeout
();
1109
await serverResult.Task.
DefaultTimeout
();
1120
await host.StopAsync().
DefaultTimeout
();
1174
await serverResult.Task.
DefaultTimeout
();
1180
await host.StopAsync().
DefaultTimeout
();
1214
await requestBlock.Task.
DefaultTimeout
();
1244
await host.StopAsync().
DefaultTimeout
();
1275
await requestBlock.Task.
DefaultTimeout
();
1305
await host.StopAsync().
DefaultTimeout
();
1338
await host.StopAsync().
DefaultTimeout
();
1373
await host.StopAsync().
DefaultTimeout
();
1404
await host.StopAsync().
DefaultTimeout
();
1422
await requestFinished.Task.
DefaultTimeout
();
1440
await streamingContent.SendAsync(oneKbString).
DefaultTimeout
();
1449
await host.StopAsync().
DefaultTimeout
();
1469
await context.Response.WriteAsync(oneKbString).
DefaultTimeout
();
1471
await context.Response.WriteAsync(new string('a', 1023)).
DefaultTimeout
();
1472
await context.Response.CompleteAsync().
DefaultTimeout
();
1482
await responseFinished.Task.
DefaultTimeout
();
1485
await host.StopAsync().
DefaultTimeout
();
1500
await requestFinished.Task.
DefaultTimeout
();
1526
await streamingContent0.SendAsync(oneKbString).
DefaultTimeout
();
1527
await streamingContent1.SendAsync(oneKbString).
DefaultTimeout
();
1540
await host.StopAsync().
DefaultTimeout
();
1571
await host.StopAsync().
DefaultTimeout
();
1593
await host.StopAsync().
DefaultTimeout
();
1638
await host.StopAsync().
DefaultTimeout
();
1683
await host.StopAsync().
DefaultTimeout
();
Microsoft.AspNetCore.Components.WebAssembly.Tests (4)
PullFromJSDataStreamTest.cs (4)
59
await pullFromJSDataStream.CopyToAsync(mem).
DefaultTimeout
();
72
var ex = await Assert.ThrowsAsync<EndOfStreamException>(async () => await pullFromJSDataStream.CopyToAsync(mem).
DefaultTimeout
());
86
var ex = await Assert.ThrowsAsync<EndOfStreamException>(async () => await pullFromJSDataStream.CopyToAsync(mem).
DefaultTimeout
());
100
var ex = await Assert.ThrowsAsync<EndOfStreamException>(async () => await pullFromJSDataStream.CopyToAsync(mem).
DefaultTimeout
());
Microsoft.AspNetCore.ConcurrencyLimiter.Tests (2)
MiddlewareTests.cs (2)
43
await middleware.Invoke(context).
DefaultTimeout
();
59
await middleware.Invoke(new DefaultHttpContext()).
DefaultTimeout
();
Microsoft.AspNetCore.Diagnostics.Tests (6)
DeveloperExceptionPageMiddlewareTest.cs (1)
609
await requestDurationCollector.WaitForMeasurementsAsync(minCount: 1).
DefaultTimeout
();
ExceptionHandlerMiddlewareTest.cs (2)
341
await requestDurationCollector.WaitForMeasurementsAsync(minCount: 1).
DefaultTimeout
();
408
await requestDurationCollector.WaitForMeasurementsAsync(minCount: 1).
DefaultTimeout
();
ExceptionHandlerTest.cs (3)
1031
await instrumentCollector.WaitForMeasurementsAsync(minCount: 1).
DefaultTimeout
();
1101
await instrumentCollector.WaitForMeasurementsAsync(minCount: 1).
DefaultTimeout
();
1163
await instrumentCollector.WaitForMeasurementsAsync(minCount: 1).
DefaultTimeout
();
Microsoft.AspNetCore.FunctionalTests (1)
WebApplicationFunctionalTests.cs (1)
154
await configChangedTcs.Task.
DefaultTimeout
();
Microsoft.AspNetCore.Grpc.JsonTranscoding.Tests (2)
ServerStreamingServerCallHandlerTests.cs (2)
70
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
251
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
Microsoft.AspNetCore.Hosting.Tests (2)
HostingMetricsTests.cs (2)
138
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
145
await processRequestTask.
DefaultTimeout
();
Microsoft.AspNetCore.Http.Connections.Tests (98)
HttpConnectionDispatcherTests.cs (89)
242
await executeTask.
DefaultTimeout
();
499
await task.
DefaultTimeout
();
555
await task.
DefaultTimeout
();
729
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
735
await pollTask.
DefaultTimeout
();
1199
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
1293
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
1298
await sync.WaitForSyncPoint().
DefaultTimeout
();
1309
await dispatcherTask.
DefaultTimeout
();
1337
await sync.WaitForSyncPoint().
DefaultTimeout
();
1348
await dispatcherTask.
DefaultTimeout
();
1381
await sync.WaitForSyncPoint().
DefaultTimeout
();
1392
await dispatcherTask.
DefaultTimeout
();
1423
await task.
DefaultTimeout
();
1453
await dispatcher.ExecuteAsync(context2, options, app).
DefaultTimeout
();
1470
await request1.
DefaultTimeout
();
1513
await request1.
DefaultTimeout
();
1596
await request1.
DefaultTimeout
();
1597
await request2.
DefaultTimeout
();
1772
await task1.
DefaultTimeout
();
1777
await task2.
DefaultTimeout
();
1857
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
1864
await connectionHandlerTask.
DefaultTimeout
();
1909
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
1916
await connectionHandlerTask.
DefaultTimeout
();
1960
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
1963
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
1997
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
2030
_ = dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
2040
await dispatcher.ExecuteAsync(deleteContext, options, app).
DefaultTimeout
();
2083
await dispatcher.ExecuteAsync(deleteContext, options, app).
DefaultTimeout
();
2085
await pollTask.
DefaultTimeout
();
2123
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
2131
await dispatcher.ExecuteAsync(deleteContext, options, app).
DefaultTimeout
();
2188
await dispatcher.ExecuteAsync(deleteContext, options, app).
DefaultTimeout
();
2190
await pollTask.
DefaultTimeout
();
2222
await waitForMessageTcs1.Task.
DefaultTimeout
();
2225
await waitForMessageTcs2.Task.
DefaultTimeout
();
2232
await dispatcher.ExecuteAsync(context, options, connectionDelegate).
DefaultTimeout
();
2236
await messageTcs1.Task.
DefaultTimeout
();
2241
await dispatcher.ExecuteAsync(context, options, connectionDelegate).
DefaultTimeout
();
2245
await messageTcs2.Task.
DefaultTimeout
();
2251
await dispatcher.ExecuteAsync(context, options, connectionDelegate).
DefaultTimeout
();
2403
await websocketFeature.Accepted.
DefaultTimeout
();
2425
await initialWebSocketTask.
DefaultTimeout
();
2427
await calledOnReconnectedTcs.Task.
DefaultTimeout
();
2435
await websocketFeature.Accepted.
DefaultTimeout
();
2441
await newWebSocketTask.
DefaultTimeout
();
2477
await websocketFeature.Accepted.
DefaultTimeout
();
2501
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
2516
await initialWebSocketTask.
DefaultTimeout
();
2591
await sendTask.
DefaultTimeout
();
2592
await disposeTask.
DefaultTimeout
();
2640
await connection.ApplicationStream.WriteAsync(buffer, 0, buffer.Length).
DefaultTimeout
();
2650
await sendTask.
DefaultTimeout
();
2697
await connection.ApplicationStream.WriteAsync(buffer, 0, buffer.Length).
DefaultTimeout
();
2700
var sendTask = dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
2706
await dispatcher.ExecuteAsync(pollContext, options, app).
DefaultTimeout
();
2708
await sendTask.
DefaultTimeout
();
2742
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
2748
await pollTask.
DefaultTimeout
();
2794
await dispatcher.ExecuteAsync(deleteContext, options, app).
DefaultTimeout
();
2796
await pollTask.
DefaultTimeout
();
2806
await connection.ConnectionClosed.WaitForCancellationAsync().
DefaultTimeout
();
2835
await connection.ConnectionClosed.WaitForCancellationAsync().
DefaultTimeout
();
2862
await websocket.Accepted.
DefaultTimeout
();
2863
await websocket.Client.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, "", cancellationToken: default).
DefaultTimeout
();
2865
await connection.ConnectionClosed.WaitForCancellationAsync().
DefaultTimeout
();
2894
await connection.ConnectionClosed.WaitForCancellationAsync().
DefaultTimeout
();
2896
await executeTask.
DefaultTimeout
();
2942
await tcs.Task.
DefaultTimeout
();
2946
await tcs.Task.
DefaultTimeout
();
2972
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
2977
await connection.Application.Output.WriteAsync(new byte[] { 1 }).
DefaultTimeout
();
2978
await pollTask.
DefaultTimeout
();
2990
await connection.Application.Output.WriteAsync(new byte[] { 1 }).
DefaultTimeout
();
2991
await pollTask.
DefaultTimeout
();
3029
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
3034
await connection.Application.Output.WriteAsync(new byte[] { 1 }).
DefaultTimeout
();
3035
await pollTask.
DefaultTimeout
();
3045
await connection.Application.Output.WriteAsync(new byte[] { 1 }).
DefaultTimeout
();
3046
await pollTask.
DefaultTimeout
();
3084
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
3133
await connection.ConnectionClosed.WaitForCancellationAsync().
DefaultTimeout
();
3159
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
3166
await connection.Application.Output.WriteAsync(new byte[] { 1 }).
DefaultTimeout
();
3167
await pollTask.
DefaultTimeout
();
3182
await tcs.Task.
DefaultTimeout
();
3583
await dispatcher.ExecuteAsync(context, options, app).
DefaultTimeout
();
MapConnectionHandlerTests.cs (1)
404
await client.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, "", CancellationToken.None).
DefaultTimeout
();
WebSocketsTests.cs (8)
162
await transport.
DefaultTimeout
();
195
await transport.
DefaultTimeout
();
261
await transport.
DefaultTimeout
();
298
await feature.Client.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, null, CancellationToken.None).
DefaultTimeout
();
300
await transport.
DefaultTimeout
();
332
await feature.Client.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, null, CancellationToken.None).
DefaultTimeout
();
339
await transport.
DefaultTimeout
();
386
await feature.Client.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, null, CancellationToken.None).
DefaultTimeout
();
Microsoft.AspNetCore.HttpLogging.Tests (28)
FileLoggerProcessorTests.cs (20)
49
await WaitForFile(filePath, _messageOne.Length).
DefaultTimeout
();
88
await WaitForFile(filePathToday, _messageOne.Length).
DefaultTimeout
();
95
await WaitForFile(filePathTomorrow, _messageTwo.Length).
DefaultTimeout
();
135
await WaitForFile(filePath2, _messageTwo.Length).
DefaultTimeout
();
178
await WaitForFile(lastFilePath, _messageOne.Length).
DefaultTimeout
();
181
await WaitForRoll(GetLogFilePath(path, options.FileName, _today, i)).
DefaultTimeout
();
233
await WaitForFile(lastFilePath, _messageOne.Length).
DefaultTimeout
();
239
await WaitForCondition(() => testSink.Writes.FirstOrDefault()?.EventId.Name == "MaxFilesReached").
DefaultTimeout
();
255
await WaitForCondition(() => testSink2.Writes.FirstOrDefault()?.EventId.Name == "MaxFilesReached").
DefaultTimeout
();
292
await WaitForFile(filePath, _messageOne.Length).
DefaultTimeout
();
305
await WaitForFile(filePath, _messageOne.Length).
DefaultTimeout
();
327
await WaitForFile(GetLogFilePath(path, options.FileName, _today, 6), _messageOne.Length).
DefaultTimeout
();
328
await WaitForRoll(GetLogFilePath(path, options.FileName, _today, 0)).
DefaultTimeout
();
329
await WaitForRoll(GetLogFilePath(path, options.FileName, _today, 1)).
DefaultTimeout
();
378
await WaitForFile(filePath2, _messageTwo.Length).
DefaultTimeout
();
389
await WaitForFile(filePath3, _messageThree.Length).
DefaultTimeout
();
444
await WaitForFile(filePath3, _messageThree.Length).
DefaultTimeout
();
455
await WaitForFile(filePath4, _messageFour.Length).
DefaultTimeout
();
510
await WaitForFile(filePath1, _messageOne.Length).
DefaultTimeout
();
525
await WaitForFile(filePath2, _messageTwo.Length).
DefaultTimeout
();
W3CLoggerTests.cs (2)
33
await logger.Processor.WaitForWrites(4).
DefaultTimeout
();
77
await logger.Processor.WaitForWrites(4).
DefaultTimeout
();
W3CLoggingMiddlewareTests.cs (6)
88
await logger.Processor.WaitForWrites(4).
DefaultTimeout
();
133
await logger.Processor.WaitForWrites(4).
DefaultTimeout
();
174
await logger.Processor.WaitForWrites(4).
DefaultTimeout
();
206
await logger.Processor.WaitForWrites(4).
DefaultTimeout
();
253
await logger.Processor.WaitForWrites(4).
DefaultTimeout
();
291
await logger.Processor.WaitForWrites(4).
DefaultTimeout
();
Microsoft.AspNetCore.InternalTesting.Tests (2)
TaskExtensionsTest.cs (2)
45
await Assert.ThrowsAsync<TimeoutException>(async () => await Task.Delay(30000, cts.Token).
DefaultTimeout
(50));
53
await Assert.ThrowsAsync<TimeoutException>(async () => await Task.Delay(30000, cts.Token).
DefaultTimeout
(50));
Microsoft.AspNetCore.RateLimiting.Tests (29)
RateLimitingMetricsTests.cs (11)
45
await middleware.Invoke(context).
DefaultTimeout
();
94
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
102
await middlewareTask.
DefaultTimeout
();
147
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
157
await middlewareTask.
DefaultTimeout
();
213
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
228
await middlewareTask1.
DefaultTimeout
();
229
await middlewareTask2.
DefaultTimeout
();
282
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
303
await middlewareTask1.
DefaultTimeout
();
304
await middlewareTask2.
DefaultTimeout
();
RateLimitingMiddlewareTests.cs (18)
102
await middleware.Invoke(context).
DefaultTimeout
();
127
await middleware.Invoke(context).
DefaultTimeout
();
209
await middleware.Invoke(context).
DefaultTimeout
();
245
await middleware.Invoke(context).
DefaultTimeout
();
247
await middleware.Invoke(context).
DefaultTimeout
();
276
await middleware.Invoke(context).
DefaultTimeout
();
308
await middleware.Invoke(context).
DefaultTimeout
();
340
await middleware.Invoke(context).
DefaultTimeout
();
372
await middleware.Invoke(context).
DefaultTimeout
();
415
await middleware.Invoke(context).
DefaultTimeout
();
451
await middleware.Invoke(context).
DefaultTimeout
();
457
await middleware.Invoke(context).
DefaultTimeout
();
502
await middleware.Invoke(context).
DefaultTimeout
();
510
await middleware.Invoke(context).
DefaultTimeout
();
538
await middleware.Invoke(context).
DefaultTimeout
();
547
await middleware.Invoke(context).
DefaultTimeout
();
575
await middleware.Invoke(context).
DefaultTimeout
();
615
await middleware.Invoke(context).
DefaultTimeout
();
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (38)
Http3Tests.cs (2)
192
await headersReceived.Task.
DefaultTimeout
();
222
await headersReceived.Task.
DefaultTimeout
();
Listener\ResponseBodyTests.cs (8)
249
await disconnectCts.Task.
DefaultTimeout
();
285
await disconnectCts.Task.
DefaultTimeout
();
320
await disconnectCts.Task.
DefaultTimeout
();
347
await disconnectCts.Task.
DefaultTimeout
();
382
await disconnectCts.Task.
DefaultTimeout
();
421
await disconnectCts.Task.
DefaultTimeout
();
460
await disconnectCts.Task.
DefaultTimeout
();
494
await disconnectCts.Task.
DefaultTimeout
();
RequestTests.cs (4)
525
await result.Task.
DefaultTimeout
();
547
await registered.Task.
DefaultTimeout
();
551
await result.Task.
DefaultTimeout
();
561
await requestAborted.Task.
DefaultTimeout
();
ResponseBodyTests.cs (4)
28
await startingTcs.Task.
DefaultTimeout
();
57
await startingTcs.Task.
DefaultTimeout
();
58
await responseReceived.Task.
DefaultTimeout
();
79
await responseReceived.Task.
DefaultTimeout
();
ResponseSendFileTests.cs (16)
392
await testComplete.Task.
DefaultTimeout
();
420
await testComplete.Task.
DefaultTimeout
();
447
await testComplete.Task.
DefaultTimeout
();
474
await testComplete.Task.
DefaultTimeout
();
520
await requestReceived.Task.
DefaultTimeout
();
526
await testComplete.Task.
DefaultTimeout
();
527
await cancellationReceived.Task.
DefaultTimeout
();
563
await requestReceived.Task.
DefaultTimeout
();
569
await testComplete.Task.
DefaultTimeout
();
570
await cancellationReceived.Task.
DefaultTimeout
();
619
await firstSendComplete.Task.
DefaultTimeout
();
625
await testComplete.Task.
DefaultTimeout
();
626
await cancellationReceived.Task.
DefaultTimeout
();
668
await firstSendComplete.Task.
DefaultTimeout
();
674
await testComplete.Task.
DefaultTimeout
();
675
await cancellationReceived.Task.
DefaultTimeout
();
ResponseTests.cs (2)
270
await readStarted.Task.
DefaultTimeout
();
276
await readCompleted.Task.
DefaultTimeout
();
ResponseTrailersTests.cs (2)
232
await trailersReceived.Task.
DefaultTimeout
();
254
await trailersReceived.Task.
DefaultTimeout
();
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (23)
CertificatePathWatcherTests.cs (4)
157
await signalTcs.Task.
DefaultTimeout
();
203
await signalTcs.Task.
DefaultTimeout
();
385
await logNoLastModifiedTcs.Task.
DefaultTimeout
();
397
await changeTcs.Task.
DefaultTimeout
();
ConcurrentPipeWriterTests.cs (2)
128
await mockPipeWriter.FlushTcs.Task.
DefaultTimeout
();
148
await mockPipeWriter.FlushTcs.Task.
DefaultTimeout
();
HeartbeatTests.cs (5)
70
await tcs.Task.
DefaultTimeout
();
124
await handlerStartedTcs.Task.
DefaultTimeout
();
132
await blockedHeartbeatTask.
DefaultTimeout
();
167
await handlerStartedTcs.Task.
DefaultTimeout
();
175
await blockedHeartbeatTask.
DefaultTimeout
();
HttpConnectionTests.cs (1)
48
await aborted.Task.
DefaultTimeout
();
KestrelServerTests.cs (10)
588
await Task.WhenAll(new[] { stopTask1, stopTask2, stopTask3 }).
DefaultTimeout
();
705
await stopTask1.
DefaultTimeout
();
706
await stopTask2.
DefaultTimeout
();
707
await continuationTask.
DefaultTimeout
();
824
await server.StartAsync(new DummyApplication(), CancellationToken.None).
DefaultTimeout
();
845
await changeCallback().
DefaultTimeout
();
874
await changeCallback().
DefaultTimeout
();
903
await server.StopAsync(CancellationToken.None).
DefaultTimeout
();
962
await server.StartAsync(new DummyApplication(), CancellationToken.None).
DefaultTimeout
();
969
await server.StopAsync(CancellationToken.None).
DefaultTimeout
();
MessageBodyTests.cs (1)
878
await logEvent.Task.
DefaultTimeout
();
Microsoft.AspNetCore.Server.Kestrel.Tests (1)
KestrelConfigurationLoaderTests.cs (1)
999
await fileTcs.Task.
DefaultTimeout
();
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (22)
QuicConnectionContextTests.cs (5)
143
await connectionClosedTcs.Task.
DefaultTimeout
();
185
await closedTcs.Task.
DefaultTimeout
();
235
await closedTcs.Task.
DefaultTimeout
();
589
await allConnectionsOnServerTcs.Task.
DefaultTimeout
();
593
await Task.WhenAll(streamTasks).
DefaultTimeout
();
QuicConnectionListenerTests.cs (5)
59
await serverConnection.DisposeAsync().AsTask().
DefaultTimeout
();
79
await serverConnection1.DisposeAsync().AsTask().
DefaultTimeout
();
104
await serverConnection2.DisposeAsync().AsTask().
DefaultTimeout
();
358
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
399
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
QuicStreamContextTests.cs (2)
290
await closedTcs.Task.
DefaultTimeout
();
363
await closedTcs.Task.
DefaultTimeout
();
WebHostTests.cs (10)
131
await host.StartAsync().
DefaultTimeout
();
135
await host.StopAsync().
DefaultTimeout
();
166
await host.StartAsync().
DefaultTimeout
();
170
await host.StopAsync().
DefaultTimeout
();
203
await host.StartAsync().
DefaultTimeout
();
207
await host.StopAsync().
DefaultTimeout
();
241
await host.StartAsync().
DefaultTimeout
();
274
await host.StopAsync().
DefaultTimeout
();
312
await host.StartAsync().
DefaultTimeout
();
343
await host.StopAsync().
DefaultTimeout
();
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (96)
HubConnectionTests.cs (86)
104
await connection.StartAsync().
DefaultTimeout
();
173
await connection.StartAsync().
DefaultTimeout
();
198
await connection.StartAsync().
DefaultTimeout
();
226
await connection.StartAsync().
DefaultTimeout
();
256
await connection.StartAsync().
DefaultTimeout
();
259
await connection.StopAsync().
DefaultTimeout
();
260
await connection.StartAsync().
DefaultTimeout
();
288
await connection.StartAsync().
DefaultTimeout
();
292
await connection.StopAsync().
DefaultTimeout
();
294
await connection.StartAsync().
DefaultTimeout
();
332
await connection.StartAsync().
DefaultTimeout
();
347
await connection.StartAsync().
DefaultTimeout
();
352
await connection.StopAsync().
DefaultTimeout
();
355
await restartTcs.Task.
DefaultTimeout
();
385
await connection.StartAsync().
DefaultTimeout
();
416
await connection.StartAsync().
DefaultTimeout
();
426
await connection.InvokeAsync("CallEcho", originalMessage).
DefaultTimeout
();
454
await connection.StartAsync().
DefaultTimeout
();
501
await connection.StartAsync().
DefaultTimeout
();
535
await connection.StartAsync().
DefaultTimeout
();
570
await connection.StartAsync().
DefaultTimeout
();
607
await connection.StartAsync().
DefaultTimeout
();
655
await connection.StartAsync().
DefaultTimeout
();
693
await connection.StartAsync().
DefaultTimeout
();
698
await connection.InvokeAsync("CallEcho", originalMessage).
DefaultTimeout
();
739
await connection.StartAsync().
DefaultTimeout
();
740
await connection.InvokeAsync("CallHandlerThatDoesntExist").
DefaultTimeout
();
742
await closeTcs.Task.
DefaultTimeout
();
767
await connection.StartAsync().
DefaultTimeout
();
797
await connection.StartAsync().
DefaultTimeout
();
802
await channelWriter.Writer.WriteAsync("1").AsTask().
DefaultTimeout
();
804
await channelWriter.Writer.WriteAsync("2").AsTask().
DefaultTimeout
();
844
await connection.StartAsync().
DefaultTimeout
();
890
await connection.StartAsync().
DefaultTimeout
();
934
await connection.StartAsync().
DefaultTimeout
();
975
await connection.StartAsync().
DefaultTimeout
();
1016
await connection.StartAsync().
DefaultTimeout
();
1051
await connection.StartAsync().
DefaultTimeout
();
1079
await connection.StartAsync().
DefaultTimeout
();
1106
await connection.StartAsync().
DefaultTimeout
();
1133
await connection.StartAsync().
DefaultTimeout
();
1160
await connection.StartAsync().
DefaultTimeout
();
1187
await connection.StartAsync().
DefaultTimeout
();
1215
await connection.StartAsync().
DefaultTimeout
();
1243
await connection.StartAsync().
DefaultTimeout
();
1271
await connection.StartAsync().
DefaultTimeout
();
1298
await connection.StartAsync().
DefaultTimeout
();
1325
await connection.StartAsync().
DefaultTimeout
();
1367
await connection.StartAsync().
DefaultTimeout
();
1421
await connection.StartAsync().
DefaultTimeout
();
1460
await connection.StartAsync().
DefaultTimeout
();
1492
await hubConnection.StartAsync().
DefaultTimeout
();
1525
var ex = await Assert.ThrowsAnyAsync<HttpRequestException>(() => hubConnection.StartAsync().
DefaultTimeout
());
1547
await hubConnection.StartAsync().
DefaultTimeout
();
1579
await hubConnection.StartAsync().
DefaultTimeout
();
1610
await hubConnection.StartAsync().
DefaultTimeout
();
1651
await hubConnection.StartAsync().
DefaultTimeout
();
1686
await hubConnection.StartAsync().
DefaultTimeout
();
1726
await hubConnection.StartAsync().
DefaultTimeout
();
1777
await hubConnection.StartAsync().
DefaultTimeout
();
1836
await hubConnection.StartAsync().
DefaultTimeout
();
1896
var ex = await Assert.ThrowsAsync<AggregateException>(() => hubConnection.StartAsync().
DefaultTimeout
());
1943
await hubConnection.StartAsync().
DefaultTimeout
();
1979
await hubConnection.StartAsync().
DefaultTimeout
();
2006
await hubConnection.StartAsync().
DefaultTimeout
();
2045
await hubConnection.StartAsync().
DefaultTimeout
();
2075
await hubConnection.StartAsync().
DefaultTimeout
();
2170
await connection.StartAsync().
DefaultTimeout
();
2175
await reconnectingTcs.Task.
DefaultTimeout
();
2230
await connection.StartAsync().
DefaultTimeout
();
2235
await reconnectingTcs.Task.
DefaultTimeout
();
2296
await connection.StartAsync().
DefaultTimeout
();
2301
await reconnectingTcs.Task.
DefaultTimeout
();
2387
await hubConnection.StartAsync().
DefaultTimeout
();
2440
await hubConnection.StartAsync().
DefaultTimeout
();
2483
await hubConnection.StartAsync().
DefaultTimeout
();
2533
await hubConnection.StartAsync().
DefaultTimeout
();
2579
await connection.StartAsync().
DefaultTimeout
();
2644
await connection.StartAsync().
DefaultTimeout
();
2659
await tcs.Task.
DefaultTimeout
();
2719
await connection.StartAsync().
DefaultTimeout
();
2731
await tcs.Task.
DefaultTimeout
();
2783
await connection.StartAsync().
DefaultTimeout
();
2785
await connection.SendAsync(nameof(TestHub.Abort)).
DefaultTimeout
();
2820
await connection.StartAsync().
DefaultTimeout
();
2890
await connection.StartAsync().
DefaultTimeout
();
HubConnectionTests.Tracing.cs (6)
72
await connection.StartAsync().
DefaultTimeout
();
258
await connection.StartAsync().
DefaultTimeout
();
400
await connection.StartAsync().
DefaultTimeout
();
503
await connection.StartAsync().
DefaultTimeout
();
606
await connection.StartAsync().
DefaultTimeout
();
696
await connection.StartAsync().
DefaultTimeout
();
HubProtocolVersionTests.cs (4)
49
await connection.StartAsync().
DefaultTimeout
();
82
await connection.StartAsync().
DefaultTimeout
();
131
await connection.StartAsync().
DefaultTimeout
();
146
await tcs.Task.
DefaultTimeout
();
Microsoft.AspNetCore.SignalR.Client.Tests (311)
HttpConnectionTests.ConnectionLifecycle.cs (21)
31
await connection.StartAsync().
DefaultTimeout
();
32
await connection.StartAsync().
DefaultTimeout
();
47
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
51
await firstStart.
DefaultTimeout
();
52
await secondStart.
DefaultTimeout
();
66
await connection.StartAsync().
DefaultTimeout
();
124
await connection.StartAsync().
DefaultTimeout
();
202
await transportStart.WaitForSyncPoint().
DefaultTimeout
();
209
await startTask.
DefaultTimeout
();
212
await transportStop.WaitForSyncPoint().
DefaultTimeout
();
233
await connection.StartAsync().
DefaultTimeout
();
239
await transportStop.WaitForSyncPoint().
DefaultTimeout
();
251
await AssertDisposedAsync(connection).
DefaultTimeout
();
269
await connection.StartAsync().
DefaultTimeout
();
275
await testTransport.Receiving.
DefaultTimeout
();
314
await connection.StartAsync().
DefaultTimeout
();
347
() => connection.StartAsync().
DefaultTimeout
());
376
await startTask.
DefaultTimeout
();
393
await negotiateSyncPoint.WaitToContinue().
DefaultTimeout
();
411
await negotiateSyncPoint.WaitForSyncPoint().
DefaultTimeout
();
530
var ex = await Assert.ThrowsAsync<AggregateException>(async () => await connection.StartAsync(cts.Token).
DefaultTimeout
());
HttpConnectionTests.cs (3)
105
await connection.StartAsync().
DefaultTimeout
();
151
await connection.StartAsync().
DefaultTimeout
();
193
await connection.StartAsync().
DefaultTimeout
();
HttpConnectionTests.Negotiate.cs (13)
86
await connection.StartAsync().
DefaultTimeout
();
121
await connection.StartAsync().
DefaultTimeout
();
158
await connection.StartAsync().
DefaultTimeout
();
197
await connection.StartAsync().
DefaultTimeout
();
237
await connection.StartAsync().
DefaultTimeout
();
296
await connection.StartAsync().
DefaultTimeout
();
326
var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => connection.StartAsync().
DefaultTimeout
());
402
await connection.StartAsync().
DefaultTimeout
();
466
await connection.StartAsync().
DefaultTimeout
();
523
await connection.StartAsync().
DefaultTimeout
();
570
await connection.StartAsync().
DefaultTimeout
();
599
var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => connection.StartAsync().
DefaultTimeout
());
616
() => connection.StartAsync().
DefaultTimeout
());
HttpConnectionTests.Transport.cs (15)
69
await connection.StartAsync().
DefaultTimeout
();
95
await connection.StartAsync().
DefaultTimeout
();
145
await connection.StartAsync().
DefaultTimeout
();
185
await connection.StartAsync().
DefaultTimeout
();
217
await connection.StartAsync().
DefaultTimeout
();
244
await connection.StartAsync().
DefaultTimeout
();
274
await connection.StartAsync().
DefaultTimeout
();
291
await connection.StartAsync().
DefaultTimeout
();
296
await transport.Receiving.
DefaultTimeout
();
309
await connection.StartAsync(TransferFormat.Text).
DefaultTimeout
();
338
await Assert.ThrowsAsync<HttpRequestException>(async () => await connection.StartAsync().
DefaultTimeout
());
408
await connection.StartAsync().
DefaultTimeout
();
446
await connection.StartAsync().
DefaultTimeout
();
506
await connection.StartAsync().
DefaultTimeout
();
549
await connection.StartAsync().
DefaultTimeout
();
HubConnectionTests.ConnectionLifecycle.cs (46)
45
await connection.StartAsync().
DefaultTimeout
();
62
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
72
await firstStart.
DefaultTimeout
();
95
await connection.StartAsync().
DefaultTimeout
();
99
await connection.StopAsync().
DefaultTimeout
();
102
await connection.StartAsync().
DefaultTimeout
();
126
await connection.StartAsync().
DefaultTimeout
();
132
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
141
await stopTask.
DefaultTimeout
();
144
await startTask.
DefaultTimeout
();
177
await connection.StartAsync().
DefaultTimeout
();
182
await connection.StopAsync().
DefaultTimeout
();
217
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
226
await startTask.
DefaultTimeout
();
231
await ForceLastInvocationToComplete(testConnection).
DefaultTimeout
();
235
await targetTask.
DefaultTimeout
();
249
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
257
await startTask.
DefaultTimeout
();
279
await connection.StartAsync().
DefaultTimeout
();
283
await connection.StopAsync().
DefaultTimeout
();
284
await testConnection.Disposed.
DefaultTimeout
();
287
await closed.Task.
DefaultTimeout
();
297
await connection.StartAsync().
DefaultTimeout
();
300
await connection.StopAsync().
DefaultTimeout
();
301
await testConnection.Disposed.
DefaultTimeout
();
311
await connection.StopAsync().
DefaultTimeout
();
324
await connection.StartAsync().
DefaultTimeout
();
328
await connection.StopAsync().
DefaultTimeout
();
329
await testConnection.Disposed.
DefaultTimeout
();
332
await connection.StopAsync().
DefaultTimeout
();
347
await connection.StopAsync().
DefaultTimeout
();
351
await connection.StartAsync().
DefaultTimeout
();
369
await connection.StartAsync().
DefaultTimeout
();
374
await closed.Task.
DefaultTimeout
();
395
await connection.StartAsync().
DefaultTimeout
();
406
await stopTask.
DefaultTimeout
();
409
await connectionClosed.Task.
DefaultTimeout
();
415
await testConnection.Disposed.
DefaultTimeout
();
434
await connection.StartAsync().
DefaultTimeout
();
443
await testConnection.Disposed.
DefaultTimeout
();
446
await stopTask.
DefaultTimeout
();
447
await connectionClosed.Task.
DefaultTimeout
();
465
await connection.StartAsync().
DefaultTimeout
();
472
await syncPoint.WaitForSyncPoint().
DefaultTimeout
();
483
await disposeTask.
DefaultTimeout
();
624
await hubConnection.StartAsync().
DefaultTimeout
();
HubConnectionTests.cs (65)
37
await hubConnection.StartAsync().
DefaultTimeout
();
52
await hubConnection.StartAsync().
DefaultTimeout
();
55
await Assert.ThrowsAsync<InvalidOperationException>(async () => await hubConnection.SendAsync("test").
DefaultTimeout
());
77
await hubConnection.StartAsync().
DefaultTimeout
();
78
await hubConnection.StopAsync().
DefaultTimeout
();
91
await hubConnection.StopAsync().
DefaultTimeout
();
95
await hubConnection.StartAsync().
DefaultTimeout
();
97
await connection.ReceiveJsonMessage(new { type = HubProtocolConstants.InvocationMessageType, target = "method", arguments = new object[] { } }).
DefaultTimeout
();
99
await tcs.Task.
DefaultTimeout
();
116
await hubConnection.StartAsync().
DefaultTimeout
();
118
await connection.ReceiveJsonMessage(new { type = HubProtocolConstants.InvocationMessageType, target = "method", arguments = new object[] { } }).
DefaultTimeout
();
120
await methodCalledTcs.Task.
DefaultTimeout
();
121
await hubConnection.StopAsync().
DefaultTimeout
();
133
await hubConnection.StartAsync().
DefaultTimeout
();
135
await hubConnection.StopAsync().
DefaultTimeout
();
155
await hubConnection.StartAsync().
DefaultTimeout
();
173
await hubConnection.StartAsync().
DefaultTimeout
();
190
await hubConnection.StartAsync().
DefaultTimeout
();
194
await hubConnection.StopAsync().
DefaultTimeout
();
209
await hubConnection.StartAsync().
DefaultTimeout
();
211
hubConnection.SendAsync("testMethod", cancellationToken: new CancellationToken(canceled: true)).
DefaultTimeout
());
213
await hubConnection.StopAsync().
DefaultTimeout
();
229
await hubConnection.StartAsync().
DefaultTimeout
();
237
await Assert.ThrowsAsync<OperationCanceledException>(() => sendTask.
DefaultTimeout
());
239
await hubConnection.StopAsync().
DefaultTimeout
();
251
await hubConnection.StartAsync().
DefaultTimeout
();
255
await hubConnection.StopAsync().
DefaultTimeout
();
270
await hubConnection.StartAsync().
DefaultTimeout
();
274
await hubConnection.StopAsync().
DefaultTimeout
();
289
await hubConnection.StartAsync().
DefaultTimeout
();
299
).
DefaultTimeout
();
319
await hubConnection.StartAsync().
DefaultTimeout
();
331
).
DefaultTimeout
();
365
await hubConnection.StartAsync().
DefaultTimeout
();
384
await hubConnection.StartAsync().
DefaultTimeout
();
393
await hubConnection.RunTimerActions().
DefaultTimeout
();
416
await hubConnection.StartAsync().
DefaultTimeout
();
419
var invokeTask = hubConnection.InvokeAsync("Method").
DefaultTimeout
();
436
await hubConnection.StartAsync().
DefaultTimeout
();
448
await channel.Writer.WriteAsync(number).AsTask().
DefaultTimeout
();
462
).
DefaultTimeout
();
476
await hubConnection.StartAsync().
DefaultTimeout
();
507
await hubConnection.StartAsync().
DefaultTimeout
();
535
).
DefaultTimeout
();
551
await hubConnection.StartAsync().
DefaultTimeout
();
583
await hubConnection.StartAsync().
DefaultTimeout
();
609
await hubConnection.StartAsync().
DefaultTimeout
();
631
await tcs.Task.
DefaultTimeout
();
643
await hubConnection.StartAsync().
DefaultTimeout
();
675
await hubConnection.StartAsync().
DefaultTimeout
();
708
await hubConnection.StartAsync().
DefaultTimeout
();
735
await connection.ReceiveJsonMessage(new { type = HubProtocolConstants.InvocationMessageType, target = "Echo", arguments = new object[] { "42" } }).
DefaultTimeout
();
739
await connection.ReceiveJsonMessage(new { type = HubProtocolConstants.CloseMessageType }).
DefaultTimeout
();
741
await closedTcs.Task.
DefaultTimeout
();
743
await Assert.ThrowsAsync<TaskCanceledException>(() => tcs.Task.
DefaultTimeout
());
754
await hubConnection.StartAsync().
DefaultTimeout
();
786
await Assert.ThrowsAsync<InvalidOperationException>(() => connection.StartAsync().
DefaultTimeout
());
813
await hubConnection.StartAsync().
DefaultTimeout
();
822
await connection.ReceiveTextAsync("{\"type\":1,\"invocationId\":\"1\",\"target\":\"Result\",\"arguments\":[]}\u001e").
DefaultTimeout
();
837
await tcs.Task.
DefaultTimeout
();
904
await hubConnection.StartAsync().
DefaultTimeout
();
911
await reconnectFeature.DisableReconnectCalled.
DefaultTimeout
();
936
await hubConnection.StartAsync().
DefaultTimeout
();
938
await hubConnection.StopAsync().
DefaultTimeout
();
943
await reconnectFeature.DisableReconnectCalled.
DefaultTimeout
();
HubConnectionTests.Extensions.cs (14)
231
}).
DefaultTimeout
();
251
await hubConnection.StartAsync().
DefaultTimeout
();
260
}).
DefaultTimeout
();
269
}).
DefaultTimeout
();
293
await hubConnection.StartAsync().
DefaultTimeout
();
302
}).
DefaultTimeout
();
311
}).
DefaultTimeout
();
331
await hubConnection.StartAsync().
DefaultTimeout
();
340
}).
DefaultTimeout
();
349
}).
DefaultTimeout
();
373
await hubConnection.StartAsync().
DefaultTimeout
();
382
}).
DefaultTimeout
();
391
}).
DefaultTimeout
();
691
}).
DefaultTimeout
();
HubConnectionTests.Protocol.cs (78)
24
await hubConnection.StartAsync().
DefaultTimeout
();
26
var invokeTask = hubConnection.SendAsync("Foo").
DefaultTimeout
();
33
await invokeTask.
DefaultTimeout
();
57
await startTask.
DefaultTimeout
();
81
await connection.ReceiveJsonMessage(new { type = "foo" }).
DefaultTimeout
();
108
await startTask.
DefaultTimeout
();
124
await hubConnection.StartAsync().
DefaultTimeout
();
157
await hubConnection.StartAsync().
DefaultTimeout
();
159
await connection.ReceiveJsonMessage(new { type = 7 }).
DefaultTimeout
();
186
await hubConnection.StartAsync().
DefaultTimeout
();
188
await connection.ReceiveJsonMessage(new { type = 7, error = "Error!" }).
DefaultTimeout
();
207
await hubConnection.StartAsync().
DefaultTimeout
();
217
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 3 }).
DefaultTimeout
();
218
await channel.Completion.
DefaultTimeout
();
234
await hubConnection.StartAsync().
DefaultTimeout
();
238
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 3 }).
DefaultTimeout
();
240
await invokeTask.
DefaultTimeout
();
256
await hubConnection.StartAsync().
DefaultTimeout
();
260
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 3 }).
DefaultTimeout
();
278
await hubConnection.StartAsync().
DefaultTimeout
();
282
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 3, result = 42 }).
DefaultTimeout
();
300
await hubConnection.StartAsync().
DefaultTimeout
();
304
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 3, error = "An error occurred" }).
DefaultTimeout
();
323
await hubConnection.StartAsync().
DefaultTimeout
();
327
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 3, result = "Oops" }).
DefaultTimeout
();
346
await hubConnection.StartAsync().
DefaultTimeout
();
350
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 3, error = "An error occurred" }).
DefaultTimeout
();
369
await hubConnection.StartAsync().
DefaultTimeout
();
373
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 2, item = 42 }).
DefaultTimeout
();
392
await hubConnection.StartAsync().
DefaultTimeout
();
396
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 2, item = "1" }).
DefaultTimeout
();
397
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 2, item = "2" }).
DefaultTimeout
();
398
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 2, item = "3" }).
DefaultTimeout
();
399
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 3 }).
DefaultTimeout
();
420
await hubConnection.StartAsync().
DefaultTimeout
();
425
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 1, target = "Foo", arguments = args }).
DefaultTimeout
();
444
await hubConnection.StartAsync().
DefaultTimeout
();
452
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 1, target = "Foo", arguments = 1 }).
DefaultTimeout
();
476
await hubConnection.StartAsync().
DefaultTimeout
();
484
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 1, target = "Foo", arguments = 1 }).
DefaultTimeout
();
510
await hubConnection.StartAsync().
DefaultTimeout
();
516
await connection.ReceiveJsonMessage(new { type = 6 }).
DefaultTimeout
();
519
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 3 }).
DefaultTimeout
();
522
await invokeTask.
DefaultTimeout
();
540
await connection.ReceiveTextAsync("{").
DefaultTimeout
();
544
await connection.ReceiveTextAsync("}").
DefaultTimeout
();
548
await connection.ReceiveTextAsync("\u001e").
DefaultTimeout
();
550
await task.
DefaultTimeout
();
573
await connection.ReceiveTextAsync(payload).
DefaultTimeout
();
575
await hubConnection.StartAsync().
DefaultTimeout
();
600
await hubConnection.StartAsync().
DefaultTimeout
();
602
await connection.ReceiveTextAsync("{\"type\":1, ").
DefaultTimeout
();
606
await connection.ReceiveTextAsync("\"target\": \"Echo\", \"arguments\"").
DefaultTimeout
();
610
await connection.ReceiveTextAsync(":[\"hello\"]}\u001e").
DefaultTimeout
();
634
await hubConnection.StartAsync().
DefaultTimeout
();
660
await hubConnection.StartAsync().
DefaultTimeout
();
685
await hubConnection.StartAsync().
DefaultTimeout
();
689
await connection.ReceiveTextAsync("{\"type\":1,\"invocationId\":\"1\",\"target\":\"Result\",\"arguments\":[]}\u001e").
DefaultTimeout
();
709
await hubConnection.StartAsync().
DefaultTimeout
();
730
await hubConnection.StartAsync().
DefaultTimeout
();
736
await connection.ReceiveTextAsync("{\"type\":1,\"invocationId\":\"1\",\"target\":\"Result\",\"arguments\":[]}\u001e").
DefaultTimeout
();
741
await tcs.Task.
DefaultTimeout
();
757
await hubConnection.StartAsync().
DefaultTimeout
();
764
await connection.ReceiveTextAsync("{\"type\":1,\"invocationId\":\"1\",\"target\":\"Result\",\"arguments\":[]}\u001e").
DefaultTimeout
();
784
await hubConnection.StartAsync().
DefaultTimeout
();
793
await connection.ReceiveTextAsync("{\"type\":1,\"invocationId\":\"1\",\"target\":\"Result\",\"arguments\":[]}\u001e").
DefaultTimeout
();
813
await hubConnection.StartAsync().
DefaultTimeout
();
815
await connection.ReceiveTextAsync("{\"type\":1,\"invocationId\":\"1\",\"target\":\"Result\",\"arguments\":[]}\u001e").
DefaultTimeout
();
835
await hubConnection.StartAsync().
DefaultTimeout
();
840
await connection.ReceiveTextAsync("{\"type\":1,\"invocationId\":\"1\",\"target\":\"Result\",\"arguments\":[]}\u001e").
DefaultTimeout
();
860
await hubConnection.StartAsync().
DefaultTimeout
();
865
await connection.ReceiveTextAsync("{\"type\":1,\"invocationId\":\"1\",\"target\":\"Result\",\"arguments\":[15]}\u001e").
DefaultTimeout
();
885
await hubConnection.StartAsync().
DefaultTimeout
();
890
await connection.ReceiveTextAsync("{\"type\":1,\"invocationId\":\"1\",\"target\":\"Result\",\"arguments\":[]}\u001e").
DefaultTimeout
();
910
await hubConnection.StartAsync().
DefaultTimeout
();
915
await tcs.Task.
DefaultTimeout
();
920
await connection.ReceiveTextAsync("{\"type\":1,\"invocationId\":\"1\",\"target\":\"Result\",\"arguments\":[]}\u001e").
DefaultTimeout
();
921
await connection.ReceiveTextAsync("{\"type\":1,\"target\":\"Other\",\"arguments\":[]}\u001e").
DefaultTimeout
();
HubConnectionTests.Reconnect.cs (22)
60
await hubConnection.StartAsync().
DefaultTimeout
();
151
await hubConnection.StartAsync().
DefaultTimeout
();
174
await hubConnection.StopAsync().
DefaultTimeout
();
250
await hubConnection.StartAsync().
DefaultTimeout
();
345
await hubConnection.StartAsync().
DefaultTimeout
();
427
await hubConnection.StartAsync().
DefaultTimeout
();
462
await hubConnection.StopAsync().
DefaultTimeout
();
525
await hubConnection.StartAsync().
DefaultTimeout
();
546
await hubConnection.StopAsync().
DefaultTimeout
();
600
await hubConnection.StartAsync().
DefaultTimeout
();
659
await hubConnection.StartAsync().
DefaultTimeout
();
714
var startTask = hubConnection.StartAsync().
DefaultTimeout
();
794
await startTask.
DefaultTimeout
();
808
await secondRetryDelayTcs.Task.
DefaultTimeout
();
824
await hubConnection.StopAsync().
DefaultTimeout
();
901
await startTask.
DefaultTimeout
();
927
await secondRetryDelayTcs.Task.
DefaultTimeout
();
944
await hubConnection.StopAsync().
DefaultTimeout
();
1021
await hubConnection.StartAsync().
DefaultTimeout
();
1040
await stopTask.
DefaultTimeout
();
1098
await hubConnection.StartAsync().
DefaultTimeout
();
1109
await hubConnection.StopAsync().
DefaultTimeout
();
HubConnectionTests.Tracing.cs (7)
39
await hubConnection.StartAsync().
DefaultTimeout
();
76
await hubConnection.StartAsync().
DefaultTimeout
();
86
await connection.ReceiveJsonMessage(new { invocationId = "1", type = 3 }).
DefaultTimeout
();
87
await channel.Completion.
DefaultTimeout
();
114
await hubConnection.StartAsync().
DefaultTimeout
();
153
await hubConnection.StartAsync().
DefaultTimeout
();
204
await startTask.
DefaultTimeout
();
LongPollingTransportTests.cs (7)
61
await transportActiveTask.
DefaultTimeout
();
214
await ReadAsync().
DefaultTimeout
();
261
await longPollingTransport.StartAsync(TestUri, TransferFormat.Binary).
DefaultTimeout
();
267
await stopTask.
DefaultTimeout
();
574
await deleteTcs.Task.
DefaultTimeout
();
576
await task.
DefaultTimeout
();
743
await secondRequestReceived.Task.
DefaultTimeout
();
SendUtilsTests.cs (1)
44
await SendUtils.SendMessages(new Uri("http://fakeuri.org"), application, httpClient, logger: Logger).
DefaultTimeout
();
ServerSentEventsTransportTests.cs (16)
54
new Uri("http://fakeuri.org"), TransferFormat.Text).
DefaultTimeout
();
56
await eventStreamTcs.Task.
DefaultTimeout
();
57
await sseTransport.StopAsync().
DefaultTimeout
();
103
new Uri("http://fakeuri.org"), TransferFormat.Text).
DefaultTimeout
();
112
await sseTransport.StopAsync().
DefaultTimeout
();
115
await transportActiveTask.
DefaultTimeout
();
153
new Uri("http://fakeuri.org"), TransferFormat.Text).
DefaultTimeout
();
209
new Uri("http://fakeuri.org"), TransferFormat.Text).
DefaultTimeout
();
259
new Uri("http://fakeuri.org"), TransferFormat.Text).
DefaultTimeout
();
260
await eventStreamTcs.Task.
DefaultTimeout
();
286
new Uri("http://fakeuri.org"), TransferFormat.Text).
DefaultTimeout
();
340
new Uri("http://fakeuri.org"), TransferFormat.Text).
DefaultTimeout
();
374
var ex = await Assert.ThrowsAsync<ArgumentException>(() => sseTransport.StartAsync(new Uri("http://fakeuri.org"), TransferFormat.Binary).
DefaultTimeout
());
433
await sseTransport.StartAsync(new Uri("http://fakeuri.org"), TransferFormat.Text).
DefaultTimeout
();
434
await sseTransport.StopAsync().
DefaultTimeout
();
487
new Uri("http://fakeuri.org"), TransferFormat.Text).
DefaultTimeout
();
TimerAwaitableTests.cs (1)
25
await tcs.Task.
DefaultTimeout
();
WebSocketsTransportTests.cs (2)
33
new Uri("http://fakeuri.org"), TransferFormat.Text).
DefaultTimeout
();
35
await webSocketsTransport.StopAsync().
DefaultTimeout
();
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
HubConnectionReceiveBenchmark.cs (1)
157
await _waitTcs.Task.
DefaultTimeout
();
Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (27)
RedisEndToEnd.cs (22)
48
await connection.StartAsync().
DefaultTimeout
();
76
await secondConnection.StartAsync().
DefaultTimeout
();
77
await connection.StartAsync().
DefaultTimeout
();
78
await connection.InvokeAsync("AddSelfToGroup", groupName).
DefaultTimeout
();
79
await secondConnection.InvokeAsync("AddSelfToGroup", groupName).
DefaultTimeout
();
80
await connection.InvokeAsync("EchoGroup", groupName, "Hello, World!").
DefaultTimeout
();
106
await secondConnection.StartAsync().
DefaultTimeout
();
107
await connection.StartAsync().
DefaultTimeout
();
108
await connection.InvokeAsync("EchoUser", "userA", "Hello, World!").
DefaultTimeout
();
136
await secondConnection.StartAsync().
DefaultTimeout
();
137
await firstConnection.StartAsync().
DefaultTimeout
();
139
await firstConnection.InvokeAsync("EchoUser", "userA", "Hello, World!").
DefaultTimeout
();
166
await secondConnection.StartAsync().
DefaultTimeout
();
167
await connection.StartAsync().
DefaultTimeout
();
168
await connection.InvokeAsync("AddSelfToGroup", "*").
DefaultTimeout
();
169
await secondConnection.InvokeAsync("AddSelfToGroup", groupName).
DefaultTimeout
();
170
await connection.InvokeAsync("EchoGroup", groupName, "Hello, World!").
DefaultTimeout
();
175
await connection.InvokeAsync("EchoGroup", "*", "Hello, World!").
DefaultTimeout
();
200
await secondConnection.StartAsync().
DefaultTimeout
();
201
await connection.StartAsync().
DefaultTimeout
();
202
await connection.InvokeAsync("EchoUser", "userA", "Hello, World!").
DefaultTimeout
();
207
await connection.InvokeAsync("EchoUser", "*", "Hello, World!").
DefaultTimeout
();
RedisHubLifetimeManagerTests.cs (5)
67
await manager1.OnConnectedAsync(connection1).
DefaultTimeout
();
68
await manager2.OnConnectedAsync(connection2).
DefaultTimeout
();
119
await manager.OnDisconnectedAsync(connection).
DefaultTimeout
();
140
await manager.OnConnectedAsync(connection).
DefaultTimeout
();
144
await manager.AddToGroupAsync(connection.ConnectionId, groupName).
DefaultTimeout
();
Microsoft.AspNetCore.SignalR.Tests (291)
DefaultHubLifetimeManagerTests.cs (45)
32
await manager.OnConnectedAsync(connection1).
DefaultTimeout
();
33
await manager.OnConnectedAsync(connection2).
DefaultTimeout
();
35
var sendTask = manager.SendAllAsync("Hello", new object[] { "World" }, cts.Token).
DefaultTimeout
();
38
await sendTask.
DefaultTimeout
();
48
await tcs.Task.
DefaultTimeout
();
62
await manager.OnConnectedAsync(connection1).
DefaultTimeout
();
63
await manager.OnConnectedAsync(connection2).
DefaultTimeout
();
65
var sendTask = manager.SendAllExceptAsync("Hello", new object[] { "World" }, new List<string> { connection1.ConnectionId }, cts.Token).
DefaultTimeout
();
68
await sendTask.
DefaultTimeout
();
74
await tcs.Task.
DefaultTimeout
();
87
await manager.OnConnectedAsync(connection1).
DefaultTimeout
();
89
var sendTask = manager.SendConnectionAsync(connection1.ConnectionId, "Hello", new object[] { "World" }, cts.Token).
DefaultTimeout
();
92
await sendTask.
DefaultTimeout
();
98
await tcs.Task.
DefaultTimeout
();
109
await manager.OnConnectedAsync(connection1).
DefaultTimeout
();
111
var sendTask = manager.SendConnectionsAsync(new List<string> { connection1.ConnectionId }, "Hello", new object[] { "World" }, cts.Token).
DefaultTimeout
();
114
await sendTask.
DefaultTimeout
();
120
await tcs.Task.
DefaultTimeout
();
131
await manager.OnConnectedAsync(connection1).
DefaultTimeout
();
132
await manager.AddToGroupAsync(connection1.ConnectionId, "group").
DefaultTimeout
();
134
var sendTask = manager.SendGroupAsync("group", "Hello", new object[] { "World" }, cts.Token).
DefaultTimeout
();
137
await sendTask.
DefaultTimeout
();
143
await tcs.Task.
DefaultTimeout
();
156
await manager.OnConnectedAsync(connection1).
DefaultTimeout
();
157
await manager.OnConnectedAsync(connection2).
DefaultTimeout
();
158
await manager.AddToGroupAsync(connection1.ConnectionId, "group").
DefaultTimeout
();
159
await manager.AddToGroupAsync(connection2.ConnectionId, "group").
DefaultTimeout
();
161
var sendTask = manager.SendGroupExceptAsync("group", "Hello", new object[] { "World" }, new List<string> { connection1.ConnectionId }, cts.Token).
DefaultTimeout
();
164
await sendTask.
DefaultTimeout
();
170
await tcs.Task.
DefaultTimeout
();
183
await manager.OnConnectedAsync(connection1).
DefaultTimeout
();
184
await manager.AddToGroupAsync(connection1.ConnectionId, "group").
DefaultTimeout
();
186
var sendTask = manager.SendGroupsAsync(new List<string> { "group" }, "Hello", new object[] { "World" }, cts.Token).
DefaultTimeout
();
189
await sendTask.
DefaultTimeout
();
195
await tcs.Task.
DefaultTimeout
();
208
await manager.OnConnectedAsync(connection1).
DefaultTimeout
();
209
await manager.OnConnectedAsync(connection2).
DefaultTimeout
();
211
var sendTask = manager.SendUserAsync("user", "Hello", new object[] { "World" }, cts.Token).
DefaultTimeout
();
214
await sendTask.
DefaultTimeout
();
224
await tcs.Task.
DefaultTimeout
();
238
await manager.OnConnectedAsync(connection1).
DefaultTimeout
();
239
await manager.OnConnectedAsync(connection2).
DefaultTimeout
();
241
var sendTask = manager.SendUsersAsync(new List<string> { "user1", "user2" }, "Hello", new object[] { "World" }, cts.Token).
DefaultTimeout
();
244
await sendTask.
DefaultTimeout
();
254
await tcs.Task.
DefaultTimeout
();
EndToEndTests.cs (21)
45
await connection.StartAsync().
DefaultTimeout
();
67
await connection.StartAsync().
DefaultTimeout
();
81
await connection.StartAsync().
DefaultTimeout
();
100
await ws.ConnectAsync(new Uri(socketUrl), CancellationToken.None).
DefaultTimeout
();
104
await ws.SendAsync(new ArraySegment<byte>(bytes), WebSocketMessageType.Binary, endOfMessage: true, CancellationToken.None).
DefaultTimeout
();
114
await ws.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, "", CancellationToken.None).
DefaultTimeout
();
138
await ws.ConnectAsync(new Uri(socketUrl), CancellationToken.None).
DefaultTimeout
();
143
await ws.SendAsync(new ArraySegment<byte>(bytes), WebSocketMessageType.Binary, endOfMessage: false, CancellationToken.None).
DefaultTimeout
();
153
await ws.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, "", CancellationToken.None).
DefaultTimeout
();
191
await connection.StartAsync().
DefaultTimeout
();
240
var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => connection.StartAsync().
DefaultTimeout
());
271
await connection.StartAsync().
DefaultTimeout
();
328
await connection.StartAsync().
DefaultTimeout
();
389
var exception = await Assert.ThrowsAsync<HttpRequestException>(() => connection.StartAsync().
DefaultTimeout
());
420
await Assert.ThrowsAsync<WebSocketException>(() => connection.StartAsync().
DefaultTimeout
());
446
await connection.StartAsync().
DefaultTimeout
();
499
await connection.StartAsync().
DefaultTimeout
();
571
await connection.StartAsync().
DefaultTimeout
();
581
await closeTcs.Task.
DefaultTimeout
();
620
await connection.StartAsync().
DefaultTimeout
();
671
await connection.StartAsync().
DefaultTimeout
();
HubConnectionHandlerTests.ClientResult.cs (4)
143
await client.Connected.OrThrowIfOtherFails(connectionHandlerTask).
DefaultTimeout
();
176
await client.Connected.OrThrowIfOtherFails(connectionHandlerTask).
DefaultTimeout
();
368
await client.Connected.OrThrowIfOtherFails(connectionHandlerTask).
DefaultTimeout
();
413
await client.Connected.OrThrowIfOtherFails(connectionHandlerTask).
DefaultTimeout
();
HubConnectionHandlerTests.cs (160)
108
await connectionHandlerTask.
DefaultTimeout
();
132
await connectionHandlerTask.
DefaultTimeout
();
160
await connectionHandlerTask.
DefaultTimeout
();
210
await connectionHandlerTask.
DefaultTimeout
();
268
await connectionHandlerTask.
DefaultTimeout
();
294
await connectionHandlerTask.
DefaultTimeout
();
326
await connectionHandlerTask.
DefaultTimeout
();
371
await connectionHandlerTask.
DefaultTimeout
();
412
await connectionHandlerTask.
DefaultTimeout
();
450
await connectionHandlerTask.
DefaultTimeout
();
471
await connectionHandlerTask.
DefaultTimeout
();
495
await connectionHandlerTask.
DefaultTimeout
();
525
await connectionHandlerTask.
DefaultTimeout
();
576
await connectionHandlerTask.
DefaultTimeout
();
628
await connectionHandlerTask.
DefaultTimeout
();
653
await connectionHandlerTask.
DefaultTimeout
();
679
await connectionHandlerTask.
DefaultTimeout
();
713
await connectionHandlerTask.
DefaultTimeout
();
752
await connectionHandlerTask.
DefaultTimeout
();
814
await connectionHandlerTask.
DefaultTimeout
();
840
await connectionHandlerTask.
DefaultTimeout
();
865
await connectionHandlerTask.
DefaultTimeout
();
889
await connectionHandlerTask.
DefaultTimeout
();
942
await connectionHandlerTask.
DefaultTimeout
();
968
await connectionHandlerTask.
DefaultTimeout
();
1004
await connectionHandlerTask.
DefaultTimeout
();
1033
await connectionHandlerTask.
DefaultTimeout
();
1058
await connectionHandlerTask.
DefaultTimeout
();
1084
await connectionHandlerTask.
DefaultTimeout
();
1110
await connectionHandlerTask.
DefaultTimeout
();
1147
await connectionHandlerTask.
DefaultTimeout
();
1172
await connectionHandlerTask.
DefaultTimeout
();
1197
await connectionHandlerTask.
DefaultTimeout
();
1222
await connectionHandlerTask.
DefaultTimeout
();
1247
await connectionHandlerTask.
DefaultTimeout
();
1291
await connectionHandlerTask.
DefaultTimeout
();
1324
await connectionHandlerTask.
DefaultTimeout
();
1349
await connectionHandlerTask.
DefaultTimeout
();
1381
await Task.WhenAll(firstClient.Connected, secondClient.Connected).
DefaultTimeout
();
1399
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask).
DefaultTimeout
();
1419
await Task.WhenAll(firstClient.Connected, secondClient.Connected).
DefaultTimeout
();
1438
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask).
DefaultTimeout
();
1457
await Task.WhenAll(firstClient.Connected, secondClient.Connected).
DefaultTimeout
();
1479
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask).
DefaultTimeout
();
1498
await Task.WhenAll(firstClient.Connected, secondClient.Connected).
DefaultTimeout
();
1517
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask).
DefaultTimeout
();
1563
await Task.WhenAll(firstClient.Connected, secondClient.Connected, thirdClient.Connected).
DefaultTimeout
();
1588
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask, thirdConnectionHandlerTask).
DefaultTimeout
();
1609
await Task.WhenAll(firstClient.Connected, secondClient.Connected, thirdClient.Connected).
DefaultTimeout
();
1636
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask, thirdConnectionHandlerTask).
DefaultTimeout
();
1657
await Task.WhenAll(firstClient.Connected, secondClient.Connected, thirdClient.Connected).
DefaultTimeout
();
1681
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask, thirdConnectionHandlerTask).
DefaultTimeout
();
1700
await Task.WhenAll(firstClient.Connected, secondClient.Connected).
DefaultTimeout
();
1725
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask).
DefaultTimeout
();
1744
await Task.WhenAll(firstClient.Connected, secondClient.Connected).
DefaultTimeout
();
1778
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask).
DefaultTimeout
();
1797
await Task.WhenAll(firstClient.Connected, secondClient.Connected).
DefaultTimeout
();
1829
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask).
DefaultTimeout
();
1848
await Task.WhenAll(firstClient.Connected, secondClient.Connected).
DefaultTimeout
();
1872
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask).
DefaultTimeout
();
1895
await connectionHandlerTask.
DefaultTimeout
();
1914
await Task.WhenAll(firstClient.Connected, secondClient.Connected).
DefaultTimeout
();
1929
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask).
DefaultTimeout
();
1948
await Task.WhenAll(firstClient.Connected, secondClient.Connected).
DefaultTimeout
();
1963
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask).
DefaultTimeout
();
1981
await Task.WhenAll(firstClient.Connected, secondClient.Connected).
DefaultTimeout
();
1996
await Task.WhenAll(firstConnectionHandlerTask, secondConnectionHandlerTask).
DefaultTimeout
();
2021
await client.Connected.OrThrowIfOtherFails(connectionHandlerTask).
DefaultTimeout
();
2034
await connectionHandlerTask.
DefaultTimeout
();
2051
await client.Connected.
DefaultTimeout
();
2065
await connectionHandlerTask.
DefaultTimeout
();
2100
await client.Connected.
DefaultTimeout
();
2118
await connectionHandlerTask.
DefaultTimeout
();
2137
await client1.Connected.
DefaultTimeout
();
2138
await client2.Connected.
DefaultTimeout
();
2157
await firstConnectionHandlerTask.
DefaultTimeout
();
2158
await secondConnectionHandlerTask.
DefaultTimeout
();
2211
await client.Connected.
DefaultTimeout
();
2219
await connectionHandlerTask.
DefaultTimeout
();
2248
await client.Connected.
DefaultTimeout
();
2256
await connectionHandlerTask.
DefaultTimeout
();
2288
await client.Connected.
DefaultTimeout
();
2298
await connectionHandlerTask.
DefaultTimeout
();
2356
await client.Connected.
DefaultTimeout
();
2364
await connectionHandlerTask.
DefaultTimeout
();
2393
await client.Connected.
DefaultTimeout
();
2406
await connectionHandlerTask.
DefaultTimeout
();
2423
await client.Connected.
DefaultTimeout
();
2436
await connectionHandlerTask.
DefaultTimeout
();
2463
await client.Connected.
DefaultTimeout
();
2475
await connectionHandlerTask.
DefaultTimeout
();
2558
await client1.Connected.
DefaultTimeout
();
2559
await client2.Connected.
DefaultTimeout
();
2571
await connectionHandlerTask1.
DefaultTimeout
();
2572
await connectionHandlerTask2.
DefaultTimeout
();
2626
await client.Connected.
DefaultTimeout
();
2633
await connectionHandlerTask.
DefaultTimeout
();
2651
await client.Connected.
DefaultTimeout
();
2658
await connectionHandlerTask.
DefaultTimeout
();
2674
await client.Connected.
DefaultTimeout
();
2685
await connectionHandlerTask.
DefaultTimeout
();
2704
await client.Connected.
DefaultTimeout
();
2717
await connectionHandlerTask.
DefaultTimeout
();
2750
await client.Connected.
DefaultTimeout
();
2763
await connectionHandlerTask.
DefaultTimeout
();
2812
await client.Connected.
DefaultTimeout
();
2848
await client.Connected.
DefaultTimeout
();
2854
await connectionHandlerTask.
DefaultTimeout
();
2887
await connectionHandlerTask.
DefaultTimeout
();
2911
await client.Connected.
DefaultTimeout
();
3035
await customDuplex.WrappedPipeReader.WaitForReadStart().
DefaultTimeout
();
3052
await customDuplex.WrappedPipeReader.WaitForReadStart().
DefaultTimeout
();
3058
await connectionHandlerTask.
DefaultTimeout
();
3094
await connectionHandlerTask.
DefaultTimeout
();
3111
await client.Connected.
DefaultTimeout
();
3116
await connectionHandlerTask.
DefaultTimeout
();
3166
await connectionHandlerTask.
DefaultTimeout
();
3198
await connectionHandlerTask.
DefaultTimeout
();
3224
await client.Connected.
DefaultTimeout
();
3239
await connectionHandlerTask.
DefaultTimeout
();
3259
await client.Connected.
DefaultTimeout
();
3274
await connectionHandlerTask.
DefaultTimeout
();
3294
await client.Connected.
DefaultTimeout
();
3310
await connectionHandlerTask.
DefaultTimeout
();
3365
await connectionHandlerTask.
DefaultTimeout
();
3421
await connectionHandlerTask.
DefaultTimeout
();
3491
await connectionHandlerTask.
DefaultTimeout
();
3543
await connectionHandlerTask.
DefaultTimeout
();
3581
await connectionHandlerTask.
DefaultTimeout
();
3809
await connectionHandlerTask.
DefaultTimeout
();
3830
await connectionHandlerTask.
DefaultTimeout
();
3853
await connectionHandlerTask.
DefaultTimeout
();
3908
await connectionHandlerTask.
DefaultTimeout
();
4080
await connectionHandlerTask.
DefaultTimeout
();
4108
await createTask.
DefaultTimeout
();
4112
await tcs.Task.
DefaultTimeout
();
4120
await connectionHandlerTask.
DefaultTimeout
();
4154
await connectionHandlerTask.
DefaultTimeout
();
4191
await connectionHandlerTask.
DefaultTimeout
();
4238
await connectionHandlerTask.
DefaultTimeout
();
4285
await connectionHandlerTask.
DefaultTimeout
();
4316
await connectionHandlerTask.
DefaultTimeout
();
4398
await connectionHandlerTask.
DefaultTimeout
();
4418
await client.Connected.OrThrowIfOtherFails(connectionHandlerTask).
DefaultTimeout
();
4441
await connectionHandlerTask.
DefaultTimeout
();
4488
await client.Connected.OrThrowIfOtherFails(connectionHandlerTask).
DefaultTimeout
();
4498
await connectionHandlerTask.
DefaultTimeout
();
4520
await client.Connected.OrThrowIfOtherFails(connectionHandlerTask).
DefaultTimeout
();
4522
await callerService.Caller.SendAsync("Echo", "message").
DefaultTimeout
();
4545
await client.Connected.OrThrowIfOtherFails(connectionHandlerTask).
DefaultTimeout
();
4572
await client.Connected.OrThrowIfOtherFails(connectionHandlerTask).
DefaultTimeout
();
4580
await connectionHandlerTask.
DefaultTimeout
();
4614
await client.Connected.OrThrowIfOtherFails(connectionHandlerTask).
DefaultTimeout
();
4618
await connectionHandlerTask.
DefaultTimeout
();
4635
await client.Connected.OrThrowIfOtherFails(connectionHandlerTask).
DefaultTimeout
();
5128
await connectionHandlerTask.
DefaultTimeout
();
5154
await connectionHandlerTask.
DefaultTimeout
();
5265
await connectionHandlerTask.
DefaultTimeout
();
5321
await reconnectFeature.ReconnectDisabled.
DefaultTimeout
();
5326
await connectionHandlerTask.
DefaultTimeout
();
HubFilterTests.cs (47)
121
await client.Connected.
DefaultTimeout
();
133
await connectionHandlerTask.
DefaultTimeout
();
159
await client.Connected.
DefaultTimeout
();
167
await connectionHandlerTask.
DefaultTimeout
();
196
await client.Connected.
DefaultTimeout
();
212
await connectionHandlerTask.
DefaultTimeout
();
246
await client.Connected.
DefaultTimeout
();
262
await connectionHandlerTask.
DefaultTimeout
();
297
await client.Connected.
DefaultTimeout
();
313
await connectionHandlerTask.
DefaultTimeout
();
343
await syncPoints1[0].WaitForSyncPoint().
DefaultTimeout
();
348
await syncPoints2[0].WaitForSyncPoint().
DefaultTimeout
();
350
await client.Connected.
DefaultTimeout
();
354
await syncPoints1[1].WaitForSyncPoint().
DefaultTimeout
();
359
await syncPoints2[1].WaitForSyncPoint().
DefaultTimeout
();
367
await syncPoints1[2].WaitForSyncPoint().
DefaultTimeout
();
372
await syncPoints2[2].WaitForSyncPoint().
DefaultTimeout
();
375
await connectionHandlerTask.
DefaultTimeout
();
403
await syncPoints1[0].WaitForSyncPoint().
DefaultTimeout
();
408
await syncPoints2[0].WaitForSyncPoint().
DefaultTimeout
();
410
await client.Connected.
DefaultTimeout
();
414
await syncPoints1[1].WaitForSyncPoint().
DefaultTimeout
();
419
await syncPoints2[1].WaitForSyncPoint().
DefaultTimeout
();
427
await syncPoints1[2].WaitForSyncPoint().
DefaultTimeout
();
432
await syncPoints2[2].WaitForSyncPoint().
DefaultTimeout
();
435
await connectionHandlerTask.
DefaultTimeout
();
465
await syncPoints1[0].WaitForSyncPoint().
DefaultTimeout
();
470
await syncPoints2[0].WaitForSyncPoint().
DefaultTimeout
();
472
await client.Connected.
DefaultTimeout
();
476
await syncPoints1[1].WaitForSyncPoint().
DefaultTimeout
();
481
await syncPoints2[1].WaitForSyncPoint().
DefaultTimeout
();
489
await syncPoints1[2].WaitForSyncPoint().
DefaultTimeout
();
494
await syncPoints2[2].WaitForSyncPoint().
DefaultTimeout
();
497
await connectionHandlerTask.
DefaultTimeout
();
545
await client.Connected.
DefaultTimeout
();
561
await connectionHandlerTask.
DefaultTimeout
();
594
await client.Connected.
DefaultTimeout
();
608
await connectionHandlerTask.
DefaultTimeout
();
643
await connectionHandlerTask.
DefaultTimeout
();
674
await connectionHandlerTask.
DefaultTimeout
();
698
await client.Connected.
DefaultTimeout
();
707
await connectionHandlerTask.
DefaultTimeout
();
748
await connectionHandlerTask.
DefaultTimeout
();
781
await connectionHandlerTask.
DefaultTimeout
();
824
await connectionHandlerTask.
DefaultTimeout
();
857
await connectionHandlerTask.
DefaultTimeout
();
895
await connectionHandlerTask.
DefaultTimeout
();
NativeAotTests.cs (4)
36
await connection.StartAsync().
DefaultTimeout
();
38
await connection.InvokeAsync(nameof(AsyncMethodHub.TaskMethod)).
DefaultTimeout
();
41
await connection.InvokeAsync(nameof(AsyncMethodHub.ValueTaskMethod)).
DefaultTimeout
();
44
await connection.InvokeAsync(nameof(AsyncMethodHub.CustomTaskMethod)).
DefaultTimeout
();
WebSocketsTransportTests.cs (10)
48
TransferFormat.Binary).
DefaultTimeout
();
49
await webSocketsTransport.StopAsync().
DefaultTimeout
();
81
await webSocketsTransport.StartAsync(new Uri("http://FakeEndpot.com/echo"), TransferFormat.Binary).
DefaultTimeout
();
82
await webSocketsTransport.StopAsync().
DefaultTimeout
();
96
TransferFormat.Binary).
DefaultTimeout
();
97
await webSocketsTransport.StopAsync().
DefaultTimeout
();
110
TransferFormat.Binary).
DefaultTimeout
();
141
TransferFormat.Binary).
DefaultTimeout
();
203
transferFormat).
DefaultTimeout
();
205
await webSocketsTransport.StopAsync().
DefaultTimeout
();
Microsoft.AspNetCore.TestHost.Tests (25)
HttpContextBuilderTests.cs (1)
345
await requestAborted.Task.
DefaultTimeout
();
RequestLifetimeTests.cs (7)
24
await requestAborted.Task.
DefaultTimeout
();
30
await requestAborted.Task.
DefaultTimeout
();
40
await abortReceived.Task.
DefaultTimeout
();
57
await responseReceived.Task.
DefaultTimeout
();
59
await abortReceived.Task.
DefaultTimeout
();
80
await responseReceived.Task.
DefaultTimeout
();
82
await abortReceived.Task.
DefaultTimeout
();
ResponseResetTests.cs (7)
76
await requestAborted.Task.
DefaultTimeout
();
84
await requestAborted.Task.
DefaultTimeout
();
95
await resetReceived.Task.
DefaultTimeout
();
114
await responseReceived.Task.
DefaultTimeout
();
117
await resetReceived.Task.
DefaultTimeout
();
140
await responseReceived.Task.
DefaultTimeout
();
143
await resetReceived.Task.
DefaultTimeout
();
TestClientTests.cs (10)
207
await responseStartedSyncPoint.WaitForSyncPoint().
DefaultTimeout
();
222
await requestStream.WriteAsync(Encoding.UTF8.GetBytes("Hello world")).AsTask().
DefaultTimeout
();
223
await requestStream.FlushAsync().
DefaultTimeout
();
231
await requestEndingSyncPoint.WaitForSyncPoint().
DefaultTimeout
();
315
await responseStartedSyncPoint.WaitForSyncPoint().
DefaultTimeout
();
326
await requestStream.WriteAsync(Encoding.UTF8.GetBytes("SENT")).AsTask().
DefaultTimeout
();
327
await requestStream.FlushAsync().
DefaultTimeout
();
328
await responseReadSyncPoint.WaitForSyncPoint().
DefaultTimeout
();
334
await responseEndingSyncPoint.WaitForSyncPoint().
DefaultTimeout
();
386
await requestStream.WriteAsync(Encoding.UTF8.GetBytes(new string('!', 1024 * 1024 * 50))).AsTask().
DefaultTimeout
();
Sockets.FunctionalTests (62)
src\Servers\Kestrel\test\FunctionalTests\Http2\ShutdownTests.cs (10)
97
await readFin.Task.
DefaultTimeout
();
98
await writeFin.Task.
DefaultTimeout
();
99
await connectionClosed.Task.
DefaultTimeout
();
129
await requestUnblocked.Task.
DefaultTimeout
();
145
await requestStarted.Task.
DefaultTimeout
();
149
await requestStopping.Task.
DefaultTimeout
();
155
await stopTask.
DefaultTimeout
();
180
await requestUnblocked.Task.
DefaultTimeout
();
196
await requestStarted.Task.
DefaultTimeout
();
203
var stopServerTask = server.StopAsync(cts.Token).
DefaultTimeout
();
src\Servers\Kestrel\test\FunctionalTests\RequestTests.cs (13)
204
await ensureConcurrentRequestTcs.Task.
DefaultTimeout
();
605
await requestAborted.WaitAsync().
DefaultTimeout
();
621
await requestAborted.WaitAsync().
DefaultTimeout
();
666
await appDoneTcs.Task.
DefaultTimeout
();
756
await appStartedTcs.Task.
DefaultTimeout
();
760
await connectionClosedTcs.Task.
DefaultTimeout
();
789
await connectionClosedTcs.Task.
DefaultTimeout
();
826
await connectionClosedTcs.Task.
DefaultTimeout
();
995
await serverFinConnection.Task.
DefaultTimeout
();
999
await serverRstConnection.Task.
DefaultTimeout
();
1030
await readCallbackUnwired.Task.
DefaultTimeout
();
1035
await appFuncCompleted.Task.
DefaultTimeout
();
1080
await appStartedTcs.Task.
DefaultTimeout
();
src\Servers\Kestrel\test\FunctionalTests\ResponseTests.cs (32)
159
await connectionClosed.Task.
DefaultTimeout
();
178
await requestStarted.Task.
DefaultTimeout
();
185
await appCompleted.Task.
DefaultTimeout
();
217
await requestAbortedWh.Task.
DefaultTimeout
();
230
await requestAbortedWh.Task.
DefaultTimeout
();
245
await requestStartWh.Task.
DefaultTimeout
();
253
await requestAbortedWh.Task.
DefaultTimeout
();
320
await requestAborted.Task.
DefaultTimeout
();
338
await readCallbackUnwired.Task.
DefaultTimeout
();
376
await requestAborted.Task.
DefaultTimeout
();
395
await requestAborted.Task.
DefaultTimeout
();
408
await appCompletedTcs.Task.
DefaultTimeout
();
460
await connectionDuration.WaitForMeasurementsAsync(minCount: 1).
DefaultTimeout
();
553
await requestAborted.Task.
DefaultTimeout
();
582
await responseRateTimeoutMessageLogged.Task.
DefaultTimeout
();
583
await connectionStopMessageLogged.Task.
DefaultTimeout
();
586
await connectionWriteFinMessageLogged.Task.
DefaultTimeout
();
590
await connectionWriteRstMessageLogged.Task.
DefaultTimeout
();
592
await appFuncCompleted.Task.
DefaultTimeout
();
683
await aborted.Task.
DefaultTimeout
();
705
await responseRateTimeoutMessageLogged.Task.
DefaultTimeout
();
706
await connectionStopMessageLogged.Task.
DefaultTimeout
();
709
await connectionWriteFinMessageLogged.Task.
DefaultTimeout
();
713
await connectionWriteRstMessageLogged.Task.
DefaultTimeout
();
715
await appFuncCompleted.Task.
DefaultTimeout
();
795
await requestAborted.Task.
DefaultTimeout
();
831
await responseRateTimeoutMessageLogged.Task.
DefaultTimeout
();
832
await connectionStopMessageLogged.Task.
DefaultTimeout
();
835
await connectionWriteFinMessageLogged.Task.
DefaultTimeout
();
839
await connectionWriteRstMessageLogged.Task.
DefaultTimeout
();
915
await appFuncCompleted.Task.
DefaultTimeout
();
1081
await appFuncCompleted.Task.
DefaultTimeout
();
src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (7)
95
await host.StartAsync().
DefaultTimeout
();
99
await socket.ConnectAsync(new UnixDomainSocketEndPoint(path)).
DefaultTimeout
();
120
await serverConnectionCompletedTcs.Task.
DefaultTimeout
();
122
await host.StopAsync().
DefaultTimeout
();
161
await host.StartAsync().
DefaultTimeout
();
167
await socket.ConnectAsync(new UnixDomainSocketEndPoint(path)).
DefaultTimeout
();
194
await host.StopAsync().
DefaultTimeout
();