Skip to content

Commit a4c6051

Browse files
authored
Merge pull request Corona-Studio#13 from natsurainko/main
2 parents 85c5f92 + 5b3c7f5 commit a4c6051

File tree

2 files changed

+6
-12
lines changed

2 files changed

+6
-12
lines changed

ConnectX.Server/InterconnectServerLinkHolder.cs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -125,6 +125,9 @@ private async Task EstablishLinkAsync(CancellationToken stoppingToken)
125125
{
126126
_logger.LogFailedToConnectToRemoteServer(endPoint);
127127
_pendingEstablishInterconnectServerLinks.Enqueue(endPoint);
128+
129+
await Task.Delay(5000, stoppingToken);
130+
128131
continue;
129132
}
130133

ConnectX.Server/JsonConverters/IPEndPointJsonConverter.cs

Lines changed: 3 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -13,18 +13,9 @@ public class IPEndPointJsonConverter : JsonConverter<IPEndPoint>
1313
return null;
1414

1515
// Try parse IP:Port format
16-
var parts = endpointString.Split(':');
17-
if (parts.Length < 2)
18-
throw new JsonException($"Invalid IPEndPoint format: {endpointString}");
19-
20-
if (!int.TryParse(parts[^1], out var port))
21-
throw new JsonException($"Invalid port number: {parts[^1]}");
22-
23-
var ipPart = string.Join(":", parts[..^1]);
24-
if (!IPAddress.TryParse(ipPart, out var ip))
25-
throw new JsonException($"Invalid IP address: {ipPart}");
26-
27-
return new IPEndPoint(ip, port);
16+
if (IPEndPoint.TryParse(endpointString, out var endpoint))
17+
return endpoint;
18+
else throw new JsonException($"Invalid IPEndPoint format: {endpointString}");
2819
}
2920

3021
public override void Write(Utf8JsonWriter writer, IPEndPoint value, JsonSerializerOptions options)

0 commit comments

Comments
 (0)