ToxicMushroom/Dalamud
1
0
Fork 0
mirror of https://github.com/goatcorp/Dalamud.git synced 2025-12-12 18:27:23 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Fix Framework Stat Tracking (#1506)

Browse source
This commit is contained in:
MidoriKami 2023-10-29 06:01:48 -07:00 • committed by GitHub
parent f60e7b7a86
commit 28804b905e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 71 additions and 39 deletions
Download patch file Download diff file Expand all files Collapse all files

110
Dalamud/Game/Framework.cs
View file

@ -98,6 +98,11 @@ internal sealed class Framework : IDisposable, IServiceType, IFramework
/// <inheritdoc/>
public bool IsFrameworkUnloading { get; internal set; }
/// <summary>
/// Gets the list of update sub-delegates that didn't get updated this frame.
/// </summary>
internal List<string> NonUpdatedSubDelegates { get; private set; } = new();
/// <summary>
/// Gets or sets a value indicating whether to dispatch update events.
/// </summary>
@ -273,6 +278,58 @@ internal sealed class Framework : IDisposable, IServiceType, IFramework
StatsStopwatch.Reset();
}
/// <summary>
/// Adds a update time to the stats history.
/// </summary>
/// <param name="key">Delegate Name.</param>
/// <param name="ms">Runtime.</param>
internal static void AddToStats(string key, double ms)
{
if (!StatsHistory.ContainsKey(key))
StatsHistory.Add(key, new List<double>());
StatsHistory[key].Add(ms);
if (StatsHistory[key].Count > 1000)
{
StatsHistory[key].RemoveRange(0, StatsHistory[key].Count - 1000);
}
}
/// <summary>
/// Profiles each sub-delegate in the eventDelegate and logs to StatsHistory.
/// </summary>
/// <param name="eventDelegate">The Delegate to Profile.</param>
/// <param name="frameworkInstance">The Framework Instance to pass to delegate.</param>
internal void ProfileAndInvoke(IFramework.OnUpdateDelegate? eventDelegate, IFramework frameworkInstance)
{
if (eventDelegate is null) return;
var invokeList = eventDelegate.GetInvocationList();
// Individually invoke OnUpdate handlers and time them.
foreach (var d in invokeList)
{
var stopwatch = Stopwatch.StartNew();
try
{
d.Method.Invoke(d.Target, new object[] { frameworkInstance });
}
catch (Exception ex)
{
Log.Error(ex, "Exception while dispatching Framework::Update event.");
}
stopwatch.Stop();
var key = $"{d.Target}::{d.Method.Name}";
if (this.NonUpdatedSubDelegates.Contains(key))
this.NonUpdatedSubDelegates.Remove(key);
AddToStats(key, stopwatch.Elapsed.TotalMilliseconds);
}
}
[ServiceManager.CallWhenServicesReady]
private void ContinueConstruction()
{
@ -329,19 +386,6 @@ internal sealed class Framework : IDisposable, IServiceType, IFramework
this.LastUpdate = DateTime.Now;
this.LastUpdateUTC = DateTime.UtcNow;
void AddToStats(string key, double ms)
{
if (!StatsHistory.ContainsKey(key))
StatsHistory.Add(key, new List<double>());
StatsHistory[key].Add(ms);
if (StatsHistory[key].Count > 1000)
{
StatsHistory[key].RemoveRange(0, StatsHistory[key].Count - 1000);
}
}
if (StatsEnabled)
{
StatsStopwatch.Restart();
@ -358,33 +402,11 @@ internal sealed class Framework : IDisposable, IServiceType, IFramework
if (StatsEnabled && this.Update != null)
{
// Stat Tracking for Framework Updates
var invokeList = this.Update.GetInvocationList();
var notUpdated = StatsHistory.Keys.ToList();
// Individually invoke OnUpdate handlers and time them.
foreach (var d in invokeList)
{
StatsStopwatch.Restart();
try
{
d.Method.Invoke(d.Target, new object[] { this });
}
catch (Exception ex)
{
Log.Error(ex, "Exception while dispatching Framework::Update event.");
}
StatsStopwatch.Stop();
var key = $"{d.Target}::{d.Method.Name}";
if (notUpdated.Contains(key))
notUpdated.Remove(key);
AddToStats(key, StatsStopwatch.Elapsed.TotalMilliseconds);
}
this.NonUpdatedSubDelegates = StatsHistory.Keys.ToList();
this.ProfileAndInvoke(this.Update, this);
// Cleanup handlers that are no longer being called
foreach (var key in notUpdated)
foreach (var key in this.NonUpdatedSubDelegates)
{
if (key == nameof(this.RunPendingTickTasks))
continue;
@ -593,5 +615,15 @@ internal class FrameworkPluginScoped : IDisposable, IServiceType, IFramework
public Task RunOnTick(Func<Task> func, TimeSpan delay = default, int delayTicks = default, CancellationToken cancellationToken = default)
=> this.frameworkService.RunOnTick(func, delay, delayTicks, cancellationToken);
private void OnUpdateForward(IFramework framework) => this.Update?.Invoke(framework);
private void OnUpdateForward(IFramework framework)
{
if (Framework.StatsEnabled && this.Update != null)
{
this.frameworkService.ProfileAndInvoke(this.Update, framework);
}
else
{
this.Update?.Invoke(framework);
}
}
}