Skip to content

Commit

Permalink
Add timeouts to AcceptConnectionAsync_ThrowingCallbackOde_KeepRunning (
Browse files Browse the repository at this point in the history
  • Loading branch information
ManickaP committed Nov 6, 2023
1 parent f1871f3 commit 6d76479
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -124,14 +124,14 @@ public async Task AcceptConnectionAsync_ThrowingCallbackOde_KeepRunning()

ValueTask<QuicConnection> connectTask = CreateQuicConnection(listener.LocalEndPoint);

Exception exception = await AssertThrowsQuicExceptionAsync(QuicError.CallbackError, async () => await listener.AcceptConnectionAsync());
Assert.True(exception.InnerException is ObjectDisposedException);
await Assert.ThrowsAsync<AuthenticationException>(() => connectTask.AsTask());
Exception exception = await AssertThrowsQuicExceptionAsync(QuicError.CallbackError, async () => await listener.AcceptConnectionAsync().AsTask().WaitAsync(PassingTestTimeout));
Assert.IsType<ObjectDisposedException>(exception.InnerException);
await Assert.ThrowsAsync<AuthenticationException>(() => connectTask.AsTask().WaitAsync(PassingTestTimeout));

// Throwing ODE in callback should keep Listener running
connectTask = CreateQuicConnection(listener.LocalEndPoint);
await using QuicConnection serverConnection = await listener.AcceptConnectionAsync();
await using QuicConnection clientConnection = await connectTask;
await using QuicConnection serverConnection = await listener.AcceptConnectionAsync().AsTask().WaitAsync(PassingTestTimeout);
await using QuicConnection clientConnection = await connectTask.AsTask().WaitAsync(PassingTestTimeout);
}

[Theory]
Expand Down

0 comments on commit 6d76479

Please sign in to comment.