Message Size fix

Chykary · Jun 3, 2021 · 3e53022 · 3e53022
1 parent a40c24c
commit 3e53022
Showing 1 changed file with 21 additions and 14 deletions.
diff --git a/FizzySteamworks.cs b/FizzySteamworks.cs
@@ -133,7 +133,7 @@ public override void ClientConnect(Uri uri)
       ClientConnect(uri.Host);
     }
 
-    public override void ClientSend(int channelId, ArraySegment<byte> segment)
+    public override void ClientSend(ArraySegment<byte> segment, int channelId)
     {
       byte[] data = new byte[segment.Count];
       Array.Copy(segment.Array, segment.Offset, data, 0, segment.Count);
@@ -198,7 +198,7 @@ public override Uri ServerUri()
       return steamBuilder.Uri;
     }
 
-    public override void ServerSend(int connectionId, int channelId, ArraySegment<byte> segment)
+    public override void ServerSend(int connectionId, ArraySegment<byte> segment, int channelId)
     {
       if (ServerActive())
       {
@@ -242,22 +242,29 @@ public override void Shutdown()
 
     public override int GetMaxPacketSize(int channelId)
     {
-      if (channelId >= Channels.Length)
+      if (UseNextGenSteamNetworking)
       {
-        Debug.LogError("Channel Id exceeded configured channels! Please configure more channels.");
-        return 1200;
+        return Constants.k_cbMaxSteamNetworkingSocketsMessageSizeSend;
       }
-
-      switch (Channels[channelId])
+      else
       {
-        case EP2PSend.k_EP2PSendUnreliable:
-        case EP2PSend.k_EP2PSendUnreliableNoDelay:
+        if (channelId >= Channels.Length)
+        {
+          Debug.LogError("Channel Id exceeded configured channels! Please configure more channels.");
           return 1200;
-        case EP2PSend.k_EP2PSendReliable:
-        case EP2PSend.k_EP2PSendReliableWithBuffering:
-          return 1048576;
-        default:
-          throw new NotSupportedException();
+        }
+
+        switch (Channels[channelId])
+        {
+          case EP2PSend.k_EP2PSendUnreliable:
+          case EP2PSend.k_EP2PSendUnreliableNoDelay:
+            return 1200;
+          case EP2PSend.k_EP2PSendReliable:
+          case EP2PSend.k_EP2PSendReliableWithBuffering:
+            return 1048576;
+          default:
+            throw new NotSupportedException();
+        }
       }
     }