4.1.1

- Connection changes are no longer added to a pending queue but are now processed like other socket messages.

FishNet/Plugins/Bayou/Bayou.cs

@@ -13,13 +13,16 @@ public class Bayou : Transport
     {
 
         #region Serialized.
-        [Header("Security")]
+        //Security.
         /// <summary>
         /// True to connect using WSS.
         /// </summary>
         [Tooltip("True to connect using WSS.")]
         [SerializeField]
         private bool _useWss = false;
+
+        //[SerializeField]
+       // private bool _configureFor
 #if UNITY_SERVER || UNITY_EDITOR
         /// <summary>
         /// Configuration to use for SSL.
@@ -29,7 +32,7 @@ public class Bayou : Transport
         private SslConfiguration _sslConfiguration;
 #endif
 
-        [Header("Channels")]
+        //Channels.
         /// <summary>
         /// Maximum transmission unit for this transport.
         /// </summary>
@@ -38,7 +41,7 @@ public class Bayou : Transport
         [SerializeField]
         private int _mtu = 1023;
 
-        [Header("Server")]
+        //Server.
         /// <summary>
         /// Port to use.
         /// </summary>
@@ -53,7 +56,7 @@ public class Bayou : Transport
         [SerializeField]
         private int _maximumClients = 2000;
 
-        [Header("Client")]
+        //Client.
         /// <summary>
         /// Address to connect.
         /// </summary>

FishNet/Plugins/Bayou/CHANGELOG.txt

@@ -1,3 +1,6 @@
+4.1.1
+	- Connection changes are no longer added to a pending queue but are now processed like other socket messages.
+
 4.1.0
 	- Fish-Networking 4.1.0 support. Not compatible with V3.
 

FishNet/Plugins/Bayou/Core/ServerSocket.cs

@@ -48,10 +48,6 @@ internal RemoteConnectionState GetConnectionState(int connectionId)
         /// Ids to disconnect immediately.
         /// </summary>
         private List<int> _disconnectingNow = new List<int>();
-        /// <summary>
-        /// ConnectionEvents which need to be handled.
-        /// </summary>
-        private Queue<RemoteConnectionEvent> _remoteConnectionEvents = new Queue<RemoteConnectionEvent>();
         #endregion
         /// <summary>
         /// Currently connected clients.
@@ -140,9 +136,14 @@ private void _server_onConnect(int clientId)
                 return;
 
             if (_clients.Count >= _maximumClients)
+            {
                 _server.KickClient(clientId);
-            else
-                _remoteConnectionEvents.Enqueue(new RemoteConnectionEvent(true, clientId));
+                return;
+            }
+
+            _clients.Add(clientId);
+            RemoteConnectionState state = RemoteConnectionState.Started;
+            base.Transport.HandleRemoteConnectionState(new RemoteConnectionStateArgs(state, clientId, base.Transport.Index));
         }
 
         /// <summary>
@@ -234,7 +235,6 @@ private void ResetQueues()
             base.ClearPacketQueue(ref _outgoing);
             _disconnectingNext.Clear();
             _disconnectingNow.Clear();
-            _remoteConnectionEvents.Clear();
         }
 
         /// <summary>
@@ -320,17 +320,8 @@ internal void IterateIncoming()
             if (_server == null)
                 return;
 
-            //Handle connection and disconnection events.
-            while (_remoteConnectionEvents.Count > 0)
-            {
-                RemoteConnectionEvent connectionEvent = _remoteConnectionEvents.Dequeue();
-                if (connectionEvent.Connected)
-                    _clients.Add(connectionEvent.ConnectionId);
-                RemoteConnectionState state = (connectionEvent.Connected) ? RemoteConnectionState.Started : RemoteConnectionState.Stopped;
-                base.Transport.HandleRemoteConnectionState(new RemoteConnectionStateArgs(state, connectionEvent.ConnectionId, base.Transport.Index));
-            }
-
-            //Read data from clients.
+            /* Read socket messages. Can contain
+            * connect, data, disconnect, error messages. */
             _server.ProcessMessageQueue();
         }