using System; using UnityEngine; using Stopwatch = System.Diagnostics.Stopwatch; namespace Mirror { /// Synchronizes server time to clients. public static class NetworkTime { /// Ping message frequency, used to calculate network time and RTT public static float PingFrequency = 2.0f; /// Average out the last few results from Ping public static int PingWindowSize = 10; static double lastPingTime; // Date and time when the application started // TODO Unity 2020 / 2021 supposedly has double Time.time now? static readonly Stopwatch stopwatch = new Stopwatch(); static NetworkTime() { stopwatch.Start(); } static ExponentialMovingAverage _rtt = new ExponentialMovingAverage(10); static ExponentialMovingAverage _offset = new ExponentialMovingAverage(10); // the true offset guaranteed to be in this range static double offsetMin = double.MinValue; static double offsetMax = double.MaxValue; // returns the clock time _in this system_ static double LocalTime() => stopwatch.Elapsed.TotalSeconds; public static void Reset() { stopwatch.Restart(); _rtt = new ExponentialMovingAverage(PingWindowSize); _offset = new ExponentialMovingAverage(PingWindowSize); offsetMin = double.MinValue; offsetMax = double.MaxValue; } internal static void UpdateClient() { if (Time.time - lastPingTime >= PingFrequency) { NetworkPingMessage pingMessage = new NetworkPingMessage(LocalTime()); NetworkClient.Send(pingMessage, Channels.Unreliable); lastPingTime = Time.time; } } // executed at the server when we receive a ping message // reply with a pong containing the time from the client // and time from the server internal static void OnServerPing(NetworkConnection conn, NetworkPingMessage message) { // Debug.Log("OnPingServerMessage conn=" + conn); NetworkPongMessage pongMessage = new NetworkPongMessage { clientTime = message.clientTime, serverTime = LocalTime() }; conn.Send(pongMessage, Channels.Unreliable); } // Executed at the client when we receive a Pong message // find out how long it took since we sent the Ping // and update time offset internal static void OnClientPong(NetworkPongMessage message) { double now = LocalTime(); // how long did this message take to come back double newRtt = now - message.clientTime; _rtt.Add(newRtt); // the difference in time between the client and the server // but subtract half of the rtt to compensate for latency // half of rtt is the best approximation we have double newOffset = now - newRtt * 0.5f - message.serverTime; double newOffsetMin = now - newRtt - message.serverTime; double newOffsetMax = now - message.serverTime; offsetMin = Math.Max(offsetMin, newOffsetMin); offsetMax = Math.Min(offsetMax, newOffsetMax); if (_offset.Value < offsetMin || _offset.Value > offsetMax) { // the old offset was offrange, throw it away and use new one _offset = new ExponentialMovingAverage(PingWindowSize); _offset.Add(newOffset); } else if (newOffset >= offsetMin || newOffset <= offsetMax) { // new offset looks reasonable, add to the average _offset.Add(newOffset); } } /// The time in seconds since the server started. // // I measured the accuracy of float and I got this: // for the same day, accuracy is better than 1 ms // after 1 day, accuracy goes down to 7 ms // after 10 days, accuracy is 61 ms // after 30 days , accuracy is 238 ms // after 60 days, accuracy is 454 ms // in other words, if the server is running for 2 months, // and you cast down to float, then the time will jump in 0.4s intervals. public static double time => LocalTime() - _offset.Value; /// Time measurement variance. The higher, the less accurate the time is. // TODO does this need to be public? user should only need NetworkTime.time public static double timeVariance => _offset.Var; [Obsolete("NetworkTime.timeVar was renamed to timeVariance")] public static double timeVar => timeVariance; /// Time standard deviation. The highe, the less accurate the time is. // TODO does this need to be public? user should only need NetworkTime.time public static double timeStandardDeviation => Math.Sqrt(timeVariance); [Obsolete("NetworkTime.timeSd was renamed to timeStandardDeviation")] public static double timeSd => timeStandardDeviation; /// Clock difference in seconds between the client and the server. Always 0 on server. public static double offset => _offset.Value; /// Round trip time (in seconds) that it takes a message to go client->server->client. public static double rtt => _rtt.Value; /// Round trip time variance. The higher, the less accurate the rtt is. // TODO does this need to be public? user should only need NetworkTime.time public static double rttVariance => _rtt.Var; [Obsolete("NetworkTime.rttVar was renamed to rttVariance")] public static double rttVar => rttVariance; /// Round trip time standard deviation. The higher, the less accurate the rtt is. // TODO does this need to be public? user should only need NetworkTime.time public static double rttStandardDeviation => Math.Sqrt(rttVariance); [Obsolete("NetworkTime.rttSd was renamed to rttStandardDeviation")] public static double rttSd => rttStandardDeviation; } }