WIP

Starting to get new network update loop registration into place.

Author: NoelStephensUnity

com.unity.multiplayer.mlapi/Runtime/Core/NetworkUpdateManager.cs

@@ -1,11 +1,31 @@
 using System;
 using System.Text;
+using System.Collections.Generic;
 using UnityEngine;
 using UnityEngine.PlayerLoop;
 using UnityEngine.LowLevel;
 
 namespace MLAPI
 {
+
+    public struct NetworkLoopUpdateRegistration
+    {
+        NetworkUpdateManager.NetworkUpdateLoopCallbackFunction updateCallback;
+
+    }
+
+    /// <summary>
+    /// Allows one to create their own network update engine
+    /// in the event they have specific processing needs etc.
+    /// </summary>
+    public  interface INetworkUpdateLoopSystem
+    {
+
+
+        NetworkUpdateManager.NetworkUpdateLoopCallbackFunction RegisterUpdate(NetworkUpdateManager.NetworkUpdateStages stage );
+
+    }
+
     /// <summary>
     /// Allows one to create their own network update engine
     /// in the event they have specific processing needs etc.
@@ -113,6 +133,9 @@ public enum NetworkUpdateStages
 
         static INetworkUpdateEngine CurrentNetworkUpdateEngine;
 
+
+        public delegate void NetworkUpdateLoopCallbackFunction();
+
         /// <summary>
         /// AssignNetworkUpdateEngine
         /// Provides the option of passing in a custom network update engine
@@ -123,6 +146,39 @@ public static void AssignNetworkUpdateEngine(INetworkUpdateEngine updateEngine)
             CurrentNetworkUpdateEngine = updateEngine;
         }
 
+        static void RegisterNetworkLoopSystems(Dictionary<NetworkUpdateStages,PlayerLoopSystem> systems)
+        {
+
+        }
+
+        public static void HandleNetworkLoopRegistrations(List<INetworkUpdateLoopSystem> networkLoopSystems)
+        {
+            foreach(INetworkUpdateLoopSystem loopSystem in networkLoopSystems)
+            {
+                Dictionary<NetworkUpdateStages,PlayerLoopSystem> RegisterPlayerLoopSystems = new Dictionary<NetworkUpdateStages, PlayerLoopSystem>();
+
+                foreach(NetworkUpdateStages stage in Enum.GetValues(typeof(NetworkUpdateStages)))
+                {
+                    NetworkUpdateLoopCallbackFunction updateFunction = loopSystem.RegisterUpdate(stage);
+                    if(updateFunction != null)
+                    {
+                        PlayerLoopSystem.UpdateFunction callback = new PlayerLoopSystem.UpdateFunction(updateFunction);
+                        PlayerLoopSystem stageLoop = new PlayerLoopSystem() { updateDelegate = callback, type = loopSystem.GetType() };
+                        if(stageLoop.updateDelegate != null)
+                        {
+                            RegisterPlayerLoopSystems.Add(stage, stageLoop);
+                        }
+                    }
+                }
+                if(RegisterPlayerLoopSystems.Count > 0)
+                {
+                    RegisterNetworkLoopSystems(RegisterPlayerLoopSystems);
+                }
+            }
+
+        }
+
+
         /// <summary>
         /// RegisterNetworkUpdateAction
         /// Registers an action to a specific update stage

com.unity.multiplayer.mlapi/Runtime/Core/NetworkingManager.cs

@@ -3,6 +3,7 @@
 using System.Collections.Generic;
 using System.ComponentModel;
 using UnityEngine;
+using UnityEngine.LowLevel;
 using System.Linq;
 using MLAPI.Logging;
 using UnityEngine.SceneManagement;
@@ -34,7 +35,7 @@ namespace MLAPI
     /// The main component of the library
     /// </summary>
     [AddComponentMenu("MLAPI/NetworkingManager", -100)]
-    public class NetworkingManager : MonoBehaviour
+    public class NetworkingManager : MonoBehaviour,INetworkUpdateLoopSystem
     {
         // RuntimeAccessModifiersILPP will make this `public`
         internal static readonly Dictionary<uint, Action<NetworkedBehaviour, BitReader, ulong>> __ntable = new Dictionary<uint, Action<NetworkedBehaviour, BitReader, ulong>>();
@@ -72,6 +73,10 @@ public class NetworkingManager : MonoBehaviour
 
         public RPCQueueManager RpcQueueManager { get; private set; }
 
+
+
+
+
         /// <summary>
         /// A synchronized time, represents the time in seconds since the server application started. Is replicated across all clients
         /// </summary>
@@ -697,13 +702,50 @@ private void Shutdown()
         }
 
 
+        public List<INetworkUpdateLoopSystem> NetworkLoopUpdateSystems;
+
+        public NetworkUpdateManager.NetworkUpdateLoopCallbackFunction RegisterUpdate(NetworkUpdateManager.NetworkUpdateStages stage )
+        {
+            NetworkUpdateManager.NetworkUpdateLoopCallbackFunction networkUpdateLoopCallback = null;
+            switch(stage)
+            {
+                case NetworkUpdateManager.NetworkUpdateStages.PREUPDATE:
+                    {
+                        networkUpdateLoopCallback = NetworkPreUpdate;
+                        break;
+                    }
+                case NetworkUpdateManager.NetworkUpdateStages.FIXEDUPDATE:
+                    {
+                        networkUpdateLoopCallback = NetworkFixedUpdate;
+                        break;
+                    }
+                case NetworkUpdateManager.NetworkUpdateStages.UPDATE:
+                    {
+                        networkUpdateLoopCallback = NetworkUpdate;
+                        break;
+                    }
+                case NetworkUpdateManager.NetworkUpdateStages.LATEUPDATE:
+                    {
+                        networkUpdateLoopCallback = NetworkLateUpdate;
+                        break;
+                    }
+            }
+            return networkUpdateLoopCallback;
+        }
+
+
         private void Awake()
         {
+            //We always add the networking manager as the first entry
+            NetworkLoopUpdateSystems.Insert(0, this);
+
             RpcQueueManager = new RPCQueueManager(LoopbackEnabled);
             //Note: Since frame history is not being used, this is set to 0
             //To test frame history, increase the number to (n) where n > 0
             RpcQueueManager?.Initialize(0);
 
+            NetworkUpdateManager.HandleNetworkLoopRegistrations(NetworkLoopUpdateSystems);
+
             NetworkUpdateManager.RegisterNetworkUpdateAction(NetworkPreUpdate, NetworkUpdateManager.NetworkUpdateStages.PREUPDATE);
             NetworkUpdateManager.RegisterNetworkUpdateAction(NetworkFixedUpdate, NetworkUpdateManager.NetworkUpdateStages.FIXEDUPDATE);
             NetworkUpdateManager.RegisterNetworkUpdateAction(NetworkUpdate, NetworkUpdateManager.NetworkUpdateStages.UPDATE);