Lightless-Sync/LightlessClient
8
1
Fork 2
Code Issues 2 Pull Requests 1 Actions Packages Projects Releases 56 Wiki Activity

Removel warm reload start

Browse Source
This commit is contained in:
cake
2026-01-14 01:09:08 +01:00
parent 73dee6d9a5
commit 9fcbd68ca2
1 changed files with 0 additions and 66 deletions
Download Patch File Download Diff File Expand all files Collapse all files

66
LightlessSync/Services/ActorTracking/ActorObjectService.cs
View File

@@ -77,21 +77,6 @@ public sealed class ActorObjectService : IHostedService, IDisposable, IMediatorS
_clientState = clientState; _clientState = clientState;
_condition = condition; _condition = condition;
_mediator = mediator; _mediator = mediator;
_mediator.Subscribe<PenumbraInitializedMessage>(this, _ =>
{
QueueWarmStart("PenumbraInitialized");
});
_mediator.Subscribe<ConnectedMessage>(this, _ =>
{
QueueWarmStart("Connected");
});
// Optional: helps after zoning
_mediator.Subscribe<ZoneSwitchEndMessage>(this, _ =>
{
QueueWarmStart("ZoneSwitchEnd");
});
_mediator.Subscribe<GameObjectHandlerCreatedMessage>(this, (msg) => _mediator.Subscribe<GameObjectHandlerCreatedMessage>(this, (msg) =>
{ {
if (!msg.OwnedObject) return; if (!msg.OwnedObject) return;
@@ -1165,57 +1150,6 @@ public sealed class ActorObjectService : IHostedService, IDisposable, IMediatorS
PublishGposeSnapshot(); PublishGposeSnapshot();
} }
private void QueueWarmStart(string reason)
{
if (Interlocked.Exchange(ref _warmStartQueued, 1) == 1)
return;
_ = Task.Run(async () =>
{
try
{
if (Interlocked.Exchange(ref _warmStartRan, 1) == 1)
return;
await Task.Delay(500).ConfigureAwait(false);
if (IsZoning)
return;
await _framework.RunOnFrameworkThread(() =>
{
RefreshTrackedActorsInternal();
var snapshot = Snapshot;
var published = new HashSet<nint>();
foreach (var d in snapshot.PlayerDescriptors)
{
if (d.Address != nint.Zero && published.Add(d.Address))
_mediator.Publish(new ActorTrackedMessage(d));
}
foreach (var d in snapshot.OwnedDescriptors)
{
if (d.Address != nint.Zero && published.Add(d.Address))
_mediator.Publish(new ActorTrackedMessage(d));
}
_logger.LogDebug("WarmStart republished {count} actors ({reason})", published.Count, reason);
}).ConfigureAwait(false);
}
catch (Exception ex)
{
_logger.LogDebug(ex, "WarmStart failed ({reason})", reason);
}
finally
{
Interlocked.Exchange(ref _warmStartQueued, 0);
}
});
}
private unsafe void TrackGposeObject(GameObject* gameObject) private unsafe void TrackGposeObject(GameObject* gameObject)
{ {
if (gameObject == null) if (gameObject == null)