- Removed GC (Full Credits to Punfish - Thank you)

- Removed obsolete method

FishNet/Plugins/FishyFacepunch/CHANGELOG.txt

@@ -5,4 +5,7 @@
 	- Organized folder structure
 	- Removed ChannelData
 1.1.1
-	- FishNetworking 0.1.5.Nightly.10 Support
+	- FishNetworking 0.1.5.Nightly.10 Support
+1.2.0
+	- Removed GC (Full Credits to Punfish - Thank you)
+	- Removed obsolete method

FishNet/Plugins/FishyFacepunch/Core/ClientHostSocket.cs

@@ -1,9 +1,9 @@
 #if !FishyFacepunch
 using FishNet.Transporting;
-using FishNet.Utility.Performance;
 using FishyFacepunch.Server;
 using System;
 using System.Collections.Concurrent;
+using System.Collections.Generic;
 
 namespace FishyFacepunch.Client
 {
@@ -20,7 +20,7 @@ public class ClientHostSocket : CommonSocket
         /// <summary>
         /// Incomimg data.
         /// </summary>
-        private ConcurrentQueue<LocalPacket> _incoming = new ConcurrentQueue<LocalPacket>();
+        private Queue<LocalPacket> _incoming = new Queue<LocalPacket>();
         #endregion
 
         /// <summary>
@@ -36,7 +36,6 @@ internal void CheckSetStarted()
             }
         }
 
-
         /// <summary>
         /// Starts the client connection.
         /// </summary>
@@ -75,7 +74,7 @@ internal bool StopConnection()
             if (base.GetLocalConnectionState() == LocalConnectionStates.Stopped || base.GetLocalConnectionState() == LocalConnectionStates.Stopping)
                 return false;
 
-            while (_incoming.TryDequeue(out _)) ;
+            base.ClearQueue(_incoming);
             //Immediately set stopped since no real connection exists.
             SetLocalConnectionState(LocalConnectionStates.Stopping, false);
             SetLocalConnectionState(LocalConnectionStates.Stopped, false);
@@ -92,11 +91,12 @@ internal void IterateIncoming()
             if (base.GetLocalConnectionState() != LocalConnectionStates.Started)
                 return;
 
-            while (_incoming.TryDequeue(out LocalPacket packet))
+            while (_incoming.Count > 0)
             {
+                LocalPacket packet = _incoming.Dequeue();
                 ArraySegment<byte> segment = new ArraySegment<byte>(packet.Data, 0, packet.Length);
                 base.Transport.HandleClientReceivedDataArgs(new ClientReceivedDataArgs(segment, (Channel)packet.Channel));
-                ByteArrayPool.Store(packet.Data);
+                packet.Dispose();
             }
         }
 

FishNet/Plugins/FishyFacepunch/Core/ClientSocket.cs

@@ -1,5 +1,4 @@
 #if !FishyFacepunch
-using FishNet.Managing;
 using FishNet.Managing.Logging;
 using FishNet.Transporting;
 using Steamworks;
@@ -217,7 +216,6 @@ internal void SendToServer(byte channelId, ArraySegment<byte> segment)
             }
         }
 
-
         /// <summary>
         /// Sends queued data to server.
         /// </summary>
@@ -228,7 +226,6 @@ internal void IterateOutgoing()
 
             HostConnection.Flush();
         }
-
     }
 }
 #endif // !DISABLESTEAMWORKS

FishNet/Plugins/FishyFacepunch/Core/CommonSocket.cs

@@ -4,6 +4,7 @@
 using Steamworks;
 using Steamworks.Data;
 using System;
+using System.Collections.Generic;
 using System.Net;
 using System.Runtime.InteropServices;
 using UnityEngine;
@@ -67,6 +68,14 @@ protected virtual void SetLocalConnectionState(LocalConnectionStates connectionS
         protected const int MAX_MESSAGES = 256;
         #endregion
 
+        internal void ClearQueue(Queue<LocalPacket> lpq)
+        {
+            while (lpq.Count > 0)
+            {
+                LocalPacket lp = lpq.Dequeue();
+                lp.Dispose();
+            }
+        }
         /// <summary>
         /// Initializes this for use.
         /// </summary>
@@ -164,6 +173,5 @@ protected Result Send(Connection conn, ArraySegment<byte> segment, byte channelI
             return (managedArray, channel);
         }
     }
-
 }
 #endif

FishNet/Plugins/FishyFacepunch/Core/LocalPacket.cs

@@ -15,5 +15,11 @@ public LocalPacket(ArraySegment<byte> data, byte channel)
             Buffer.BlockCopy(data.Array, data.Offset, Data, 0, Length);
             Channel = channel;
         }
+
+        public void Dispose()
+        {
+            if (Data != null)
+                ByteArrayPool.Store(Data);
+        }
     }
 }

FishNet/Plugins/FishyFacepunch/Core/ServerSocket.cs

@@ -4,7 +4,6 @@
 using Steamworks;
 using Steamworks.Data;
 using System;
-using System.Collections.Concurrent;
 using System.Collections.Generic;
 using UnityEngine;
 
@@ -59,7 +58,7 @@ internal RemoteConnectionStates GetConnectionState(int connectionId)
         /// <summary>
         /// Packets received from local client.
         /// </summary>
-        private ConcurrentQueue<LocalPacket> _clientHostIncoming = new ConcurrentQueue<LocalPacket>();
+        private Queue<LocalPacket> _clientHostIncoming = new Queue<LocalPacket>();
         /// <summary>
         /// Socket for client host. Will be null if not being used.
         /// </summary>
@@ -262,10 +261,12 @@ internal void IterateIncoming()
                 return;
 
             //Iterate local client packets first.
-            while (_clientHostIncoming.TryDequeue(out LocalPacket packet))
+            while (_clientHostIncoming.Count > 0)
             {
+                LocalPacket packet = _clientHostIncoming.Dequeue();
                 ArraySegment<byte> segment = new ArraySegment<byte>(packet.Data, 0, packet.Length);
                 base.Transport.HandleServerReceivedDataArgs(new ServerReceivedDataArgs(segment, (Channel)packet.Channel, FishyFacepunch.CLIENT_HOST_ID));
+                packet.Dispose();
             }
 
             _socket.Receive(MAX_MESSAGES);
@@ -370,7 +371,7 @@ internal void OnClientHostState(bool started)
             //If not started flush incoming from local client.
             if (!started)
             {
-                while (_clientHostIncoming.TryDequeue(out _)) ;
+                base.ClearQueue(_clientHostIncoming);
                 base.Transport.HandleRemoteConnectionState(new RemoteConnectionStateArgs(RemoteConnectionStates.Stopped, FishyFacepunch.CLIENT_HOST_ID));
             }
             else
@@ -386,7 +387,10 @@ internal void OnClientHostState(bool started)
         internal void ReceivedFromClientHost(LocalPacket packet)
         {
             if (!_clientHostStarted)
+            {
+                packet.Dispose();
                 return;
+            }
 
             _clientHostIncoming.Enqueue(packet);
         }

FishNet/Plugins/FishyFacepunch/FishyFacepunch.cs

@@ -9,15 +9,6 @@ namespace FishyFacepunch
 {
     public class FishyFacepunch : Transport
     {
-        #region Public.
-        /// <summary>
-        /// The SteamId for the local user after connecting to or starting the server. This is populated automatically.
-        /// </summary>
-        [Header("Info")]
-        //[System.NonSerialized]
-        public ulong LocalUserSteamID = 0;
-        #endregion
-
         #region Serialized.
         /// <summary>
         /// Steam application Id.
@@ -133,7 +124,6 @@ private void InitializeRelayNetworkAccess()
         {
 #if !UNITY_SERVER
             SteamNetworkingUtils.InitRelayNetworkAccess();
-            LocalUserSteamID = SteamClient.SteamId;
 #endif
         }
         #endregion
@@ -498,14 +488,6 @@ private bool StopClient(int connectionId, bool immediately)
 
         #region Channels.
         /// <summary>
-        /// Returns how many channels the transport is using.
-        /// </summary>
-        /// <returns></returns>
-        public override byte GetChannelCount()
-        {
-            return (byte)_mtus.Length;
-        }
-        /// <summary>
         /// Returns which channel to use by default for reliable.
         /// </summary>
         public override byte GetDefaultReliableChannel()

FishNet/Plugins/FishyFacepunch/VERSION.txt

@@ -1 +1 @@
-1.1.1
+1.2.0