diff --git a/SteamTransport/Client.cs b/SteamTransport/Client.cs index 21d27e36..5144fac3 100644 --- a/SteamTransport/Client.cs +++ b/SteamTransport/Client.cs @@ -58,19 +58,7 @@ public class Client } _transport.Log($"connecting to {address}"); - var options = new SteamNetworkingConfigValue_t[] - { - new SteamNetworkingConfigValue_t - { - m_eValue = ESteamNetworkingConfigValue.k_ESteamNetworkingConfig_IP_AllowWithoutAuth, - m_eDataType = ESteamNetworkingConfigDataType.k_ESteamNetworkingConfig_Int32, - m_val = new SteamNetworkingConfigValue_t.OptionValue - { - m_int32 = 1, - } - } - }; - _conn = SteamNetworkingSockets.ConnectByIPAddress(ref steamAddr, options.Length, options); + _conn = SteamNetworkingSockets.ConnectByIPAddress(ref steamAddr, 0, new SteamNetworkingConfigValue_t[0]); } public void Send(ArraySegment segment, int channelId) diff --git a/SteamTransport/Program.cs b/SteamTransport/Program.cs index 3054055c..f9f66315 100644 --- a/SteamTransport/Program.cs +++ b/SteamTransport/Program.cs @@ -1,8 +1,6 @@ using HarmonyLib; using Steamworks; using System; -using System.Diagnostics; -using System.Runtime.InteropServices; using System.Threading; namespace SteamTransport; @@ -77,7 +75,13 @@ public static class Program try { - while (true) + var running = true; + Console.CancelKeyPress += (sender, args) => + { + args.Cancel = true; + running = false; + }; + while (running) { transport.ServerEarlyUpdate(); SteamAPI.RunCallbacks(); @@ -103,15 +107,18 @@ public static class Program try { - var stopwatch = Stopwatch.StartNew(); - while (true) + var running = true; + Console.CancelKeyPress += (sender, args) => + { + args.Cancel = true; + running = false; + }; + while (running) { transport.ClientEarlyUpdate(); SteamAPI.RunCallbacks(); transport.ClientLateUpdate(); Thread.Sleep(10); - - if (stopwatch.ElapsedMilliseconds > 10 * 1000) break; } } finally diff --git a/SteamTransport/Server.cs b/SteamTransport/Server.cs index d49dd156..6c8ba3d8 100644 --- a/SteamTransport/Server.cs +++ b/SteamTransport/Server.cs @@ -52,17 +52,11 @@ public class Server public void Send(int connectionId, ArraySegment segment, int channelId) { } - public void RecieveData() - { - } + public void RecieveData() { } - public void Flush() - { - } + public void Flush() { } - public void Disconnect(int connectionId) - { - } + public void Disconnect(int connectionId) { } public void Close() {