mirror/quantum-space-buddies
1
0
Fork 0
mirror of https://github.com/misternebula/quantum-space-buddies.git synced 2025-03-10 07:14:27 +00:00
Code Issues Projects Releases Wiki Activity

not working for unknown reasons

Browse Source
This commit is contained in:
JohnCorby 2025-02-25 02:06:57 -08:00
parent 3e57bf093a
commit 639bd56a12
2 changed files with 36 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
SteamTransport/Client.cs
View File

@ -5,6 +5,7 @@ using System.Runtime.InteropServices;
namespace SteamTransport;
// could check more Result stuff for functions. idc rn
public class Client
{
private SteamTransport _transport;
@ -87,6 +88,20 @@ public class Client
public void Send(ArraySegment<byte> segment, int channelId)
{
// from fizzy
var data = new byte[segment.Count];
Array.Copy(segment.Array, segment.Offset, data, 0, data.Length);
var pinnedArray = GCHandle.Alloc(data, GCHandleType.Pinned);
var pData = pinnedArray.AddrOfPinnedObject();
var result = SteamNetworkingSockets.SendMessageToConnection(_conn, pData, (uint)data.Length, Util.MirrorChannel2SendFlag(channelId), out _);
if (result == EResult.k_EResultOK)
_transport.OnClientDataSent?.Invoke(segment, channelId);
else
_transport.OnClientError?.Invoke(TransportError.InvalidSend, $"send returned {result}");
// i dont think we have to check for disconnect result here since the status change handles that
/*
// use pointer to managed array instead of making copy. is this okay?
unsafe
{
@ -100,6 +115,7 @@ public class Client
// i dont think we have to check for disconnect result here since the status change handles that
}
}
*/
}
public void Receive()
@ -111,7 +127,7 @@ public class Client
var ppOutMessage = ppOutMessages[i];
var msg = SteamNetworkingMessage_t.FromIntPtr(ppOutMessage);
var data = new byte[msg.m_cbSize];
Marshal.Copy(msg.m_pData, data, 0, data.Length);
Marshal.Copy(msg.m_pData, data, 0, msg.m_cbSize);
var channel = Util.SendFlag2MirrorChannel(msg.m_nFlags);
_transport.OnClientDataReceived?.Invoke(new ArraySegment<byte>(data), channel);
SteamNetworkingMessage_t.Release(ppOutMessage);

22
SteamTransport/Server.cs
View File

@ -6,6 +6,7 @@ using System.Runtime.InteropServices;
namespace SteamTransport;
// could check more Result stuff for functions. idc rn
public class Server
{
private SteamTransport _transport;
@ -47,7 +48,7 @@ public class Server
public bool IsListening;
private HSteamListenSocket _listenSocket;
// mirror connection id is derived from uint to int cast here. seems to be okay for now
// mirror connection id is derived from uint to int cast here. seems to do unchecked cast and be fine
private readonly List<HSteamNetConnection> _conns = new();
public void StartListening()
@ -77,6 +78,20 @@ public class Server
{
var conn = new HSteamNetConnection((uint)connectionId);
// from fizzy
var data = new byte[segment.Count];
Array.Copy(segment.Array, segment.Offset, data, 0, data.Length);
var pinnedArray = GCHandle.Alloc(data, GCHandleType.Pinned);
var pData = pinnedArray.AddrOfPinnedObject();
var result = SteamNetworkingSockets.SendMessageToConnection(conn, pData, (uint)data.Length, Util.MirrorChannel2SendFlag(channelId), out _);
if (result == EResult.k_EResultOK)
_transport.OnServerDataSent?.Invoke(connectionId, segment, channelId);
else
_transport.OnServerError?.Invoke(connectionId, TransportError.InvalidSend, $"send returned {result}");
// i dont think we have to check for disconnect result here since the status change handles that
/*
// use pointer to managed array instead of making copy. is this okay?
unsafe
{
@ -90,6 +105,7 @@ public class Server
// i dont think we have to check for disconnect result here since the status change handles that
}
}
*/
}
public void Receive()
@ -104,9 +120,9 @@ public class Server
var ppOutMessage = ppOutMessages[i];
var msg = SteamNetworkingMessage_t.FromIntPtr(ppOutMessage);
var data = new byte[msg.m_cbSize];
Marshal.Copy(msg.m_pData, data, 0, data.Length);
Marshal.Copy(msg.m_pData, data, 0, msg.m_cbSize);
var channel = Util.SendFlag2MirrorChannel(msg.m_nFlags);
_transport.OnServerDataReceived((int)conn.m_HSteamNetConnection, new ArraySegment<byte>(data), channel);
_transport.OnServerDataReceived?.Invoke((int)conn.m_HSteamNetConnection, new ArraySegment<byte>(data), channel);
SteamNetworkingMessage_t.Release(ppOutMessage);
}
}