Skip to content

Make LocalEndPointTest and some Connect tests non-parallel #56399

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 4 commits into from
Jul 30, 2021
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
135 changes: 85 additions & 50 deletions src/libraries/System.Net.Sockets/tests/FunctionalTests/Connect.cs
Original file line number Diff line number Diff line change
Expand Up @@ -83,56 +83,6 @@ public async Task Connect_MultipleIPAddresses_Success(IPAddress listenAt)
}
}

[Fact]
public async Task Connect_DualMode_MultiAddressFamilyConnect_RetrievedEndPoints_Success()
{
if (!SupportsMultiConnect)
return;

int port;
using (SocketTestServer.SocketTestServerFactory(SocketImplementationType.Async, IPAddress.Loopback, out port))
using (Socket client = new Socket(SocketType.Stream, ProtocolType.Tcp))
{
Assert.True(client.DualMode);

await MultiConnectAsync(client, new IPAddress[] { IPAddress.IPv6Loopback, IPAddress.Loopback }, port);

CheckIsIpv6LoopbackEndPoint(client.LocalEndPoint);
CheckIsIpv6LoopbackEndPoint(client.RemoteEndPoint);
}
}

[Fact]
[ActiveIssue("https://github.com/dotnet/runtime/issues/55709", TestPlatforms.Linux)]
public async Task Connect_DualMode_DnsConnect_RetrievedEndPoints_Success()
{
var localhostAddresses = Dns.GetHostAddresses("localhost");
if (Array.IndexOf(localhostAddresses, IPAddress.Loopback) == -1 ||
Array.IndexOf(localhostAddresses, IPAddress.IPv6Loopback) == -1)
{
return;
}

int port;
using (SocketTestServer.SocketTestServerFactory(SocketImplementationType.Async, IPAddress.Loopback, out port))
using (Socket client = new Socket(SocketType.Stream, ProtocolType.Tcp))
{
Assert.True(client.DualMode);

await ConnectAsync(client, new DnsEndPoint("localhost", port));

CheckIsIpv6LoopbackEndPoint(client.LocalEndPoint);
CheckIsIpv6LoopbackEndPoint(client.RemoteEndPoint);
}
}

private static void CheckIsIpv6LoopbackEndPoint(EndPoint endPoint)
{
IPEndPoint ep = endPoint as IPEndPoint;
Assert.NotNull(ep);
Assert.True(ep.Address.Equals(IPAddress.IPv6Loopback) || ep.Address.Equals(IPAddress.Loopback.MapToIPv6()));
}

[Fact]
public async Task Connect_OnConnectedSocket_Fails()
{
Expand Down Expand Up @@ -391,4 +341,89 @@ public async Task ConnectHostNameAndPort_CancelDuringConnect_Throws()
}
}
}

// The test class is declared non-parallel because of possible IPv4/IPv6 port-collision on Unix:
// When running these tests in parallel with other tests, there is some chance that the DualMode client
// will connect to an IPv4 server of a parallel test case.
[Collection(nameof(NoParallelTests))]
public abstract class Connect_NonParallel<T> : SocketTestHelperBase<T> where T : SocketHelperBase, new()
{
protected Connect_NonParallel(ITestOutputHelper output) : base(output)
{
}

[Fact]
public async Task Connect_DualMode_MultiAddressFamilyConnect_RetrievedEndPoints_Success()
{
if (!SupportsMultiConnect)
return;

int port;
using (SocketTestServer.SocketTestServerFactory(SocketImplementationType.Async, IPAddress.Loopback, out port))
using (Socket client = new Socket(SocketType.Stream, ProtocolType.Tcp))
{
Assert.True(client.DualMode);

await MultiConnectAsync(client, new IPAddress[] { IPAddress.IPv6Loopback, IPAddress.Loopback }, port);

CheckIsIpv6LoopbackEndPoint(client.LocalEndPoint);
CheckIsIpv6LoopbackEndPoint(client.RemoteEndPoint);
}
}

[Fact]
public async Task Connect_DualMode_DnsConnect_RetrievedEndPoints_Success()
{
var localhostAddresses = Dns.GetHostAddresses("localhost");
if (Array.IndexOf(localhostAddresses, IPAddress.Loopback) == -1 ||
Array.IndexOf(localhostAddresses, IPAddress.IPv6Loopback) == -1)
{
return;
}

int port;
using (SocketTestServer.SocketTestServerFactory(SocketImplementationType.Async, IPAddress.Loopback, out port))
using (Socket client = new Socket(SocketType.Stream, ProtocolType.Tcp))
{
Assert.True(client.DualMode);

await ConnectAsync(client, new DnsEndPoint("localhost", port));

CheckIsIpv6LoopbackEndPoint(client.LocalEndPoint);
CheckIsIpv6LoopbackEndPoint(client.RemoteEndPoint);
}
}

private static void CheckIsIpv6LoopbackEndPoint(EndPoint endPoint)
{
IPEndPoint ep = endPoint as IPEndPoint;
Assert.NotNull(ep);
Assert.True(ep.Address.Equals(IPAddress.IPv6Loopback) || ep.Address.Equals(IPAddress.Loopback.MapToIPv6()));
}
}

public sealed class ConnectSync_NonParallel : Connect_NonParallel<SocketHelperArraySync>
{
public ConnectSync_NonParallel(ITestOutputHelper output) : base(output) { }
}

public sealed class ConnectSyncForceNonBlocking_NonParallel : Connect_NonParallel<SocketHelperSyncForceNonBlocking>
{
public ConnectSyncForceNonBlocking_NonParallel(ITestOutputHelper output) : base(output) { }
}

public sealed class ConnectApm_NonParallel : Connect_NonParallel<SocketHelperApm>
{
public ConnectApm_NonParallel(ITestOutputHelper output) : base(output) { }
}

public sealed class ConnectTask_NonParallel : Connect_NonParallel<SocketHelperTask>
{
public ConnectTask_NonParallel(ITestOutputHelper output) : base(output) { }
}

public sealed class ConnectEap_NonParallel : Connect_NonParallel<SocketHelperEap>
{
public ConnectEap_NonParallel(ITestOutputHelper output) : base(output) { }
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,11 @@

namespace System.Net.Sockets.Tests
{
// The test class is declared non-parallel because of possible IPv4/IPv6 port-collision on Unix:
// When running in parallel with other tests, there is some chance that Accept() calls in LocalEndPointTest will
// accept a connection request from another, DualMode client living in a parallel test
// that is intended to connect to a server of opposite AddressFamily in the parallel test.
[Collection(nameof(NoParallelTests))]
public abstract class LocalEndPointTest<T> : SocketTestHelperBase<T> where T : SocketHelperBase, new()
{
protected abstract bool IPv6 { get; }
Expand Down