Gittes-archive/quantum-space-buddies
2
0
Fork 0
mirror of https://github.com/misternebula/quantum-space-buddies.git synced 2025-12-11 20:15:10 +01:00
Code Issues Packages Projects Releases Wiki Activity

basic result checking. dont parse further than non-ok

Browse Source
This commit is contained in:
JohnCorby 2025-02-24 16:06:52 -08:00
parent d711202dae
commit bcf3f8e32d
2 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
SteamTransport/Client.cs
View File

@ -75,7 +75,10 @@ public class Client
fixed (byte* pData = segment.Array) fixed (byte* pData = segment.Array)
{ {
var result = SteamNetworkingSockets.SendMessageToConnection(_conn, (IntPtr)(pData + segment.Offset), (uint)segment.Count, Util.MirrorChannel2SendFlag(channelId), out _); var result = SteamNetworkingSockets.SendMessageToConnection(_conn, (IntPtr)(pData + segment.Offset), (uint)segment.Count, Util.MirrorChannel2SendFlag(channelId), out _);
_transport.OnClientDataSent?.Invoke(segment, channelId); if (result == EResult.k_EResultOK)
_transport.OnClientDataSent?.Invoke(segment, channelId);
else
_transport.OnClientError?.Invoke(TransportError.InvalidSend, $"send returned {result}");
} }
} }
} }
@ -100,6 +103,8 @@ public class Client
public void Flush() public void Flush()
{ {
var result = SteamNetworkingSockets.FlushMessagesOnConnection(_conn); var result = SteamNetworkingSockets.FlushMessagesOnConnection(_conn);
if (result != EResult.k_EResultOK)
_transport.OnClientError?.Invoke(TransportError.Unexpected, $"flush returned {result}");
} }
public void Close() public void Close()

7
SteamTransport/Server.cs
View File

@ -69,7 +69,10 @@ public class Server
fixed (byte* pData = segment.Array) fixed (byte* pData = segment.Array)
{ {
var result = SteamNetworkingSockets.SendMessageToConnection(conn, (IntPtr)(pData + segment.Offset), (uint)segment.Count, Util.MirrorChannel2SendFlag(channelId), out _); var result = SteamNetworkingSockets.SendMessageToConnection(conn, (IntPtr)(pData + segment.Offset), (uint)segment.Count, Util.MirrorChannel2SendFlag(channelId), out _);
_transport.OnServerDataSent?.Invoke(connectionId, segment, channelId); if (result == EResult.k_EResultOK)
_transport.OnServerDataSent?.Invoke(connectionId, segment, channelId);
else
_transport.OnServerError?.Invoke(connectionId, TransportError.InvalidSend, $"send returned {result}");
} }
} }
} }
@ -100,6 +103,8 @@ public class Server
foreach (var conn in _conns) foreach (var conn in _conns)
{ {
var result = SteamNetworkingSockets.FlushMessagesOnConnection(conn); var result = SteamNetworkingSockets.FlushMessagesOnConnection(conn);
if (result != EResult.k_EResultOK)
_transport.OnServerError?.Invoke((int)conn.m_HSteamNetConnection, TransportError.Unexpected, $"flush returned {result}");
} }
} }