mirror/quantum-space-buddies
1
0
Fork 0
mirror of https://github.com/misternebula/quantum-space-buddies.git synced 2025-02-20 15:41:01 +00:00
Code Issues Projects Releases Wiki Activity

rename AuthQueue functions

Browse Source
This commit is contained in:
JohnCorby 2022-02-12 21:40:04 -08:00
parent 10471ee6c7
commit 0dea2b85c2
6 changed files with 15 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
QSB/Anglerfish/TransformSync/AnglerTransformSync.cs
View File

@ -53,7 +53,7 @@ namespace QSB.Anglerfish.TransformSync
AttachedRigidbody.OnUnsuspendOWRigidbody += OnUnsuspend;
AttachedRigidbody.OnSuspendOWRigidbody += OnSuspend;
netIdentity.SendAuthQueueMessage(AttachedRigidbody.IsSuspended() ? AuthQueueAction.Remove : AuthQueueAction.Add);
netIdentity.UpdateAuthQueue(AttachedRigidbody.IsSuspended() ? AuthQueueAction.Remove : AuthQueueAction.Add);
}
protected override void Uninit()
@ -64,8 +64,8 @@ namespace QSB.Anglerfish.TransformSync
AttachedRigidbody.OnSuspendOWRigidbody -= OnSuspend;
}
private void OnUnsuspend(OWRigidbody suspendedBody) => netIdentity.SendAuthQueueMessage(AuthQueueAction.Add);
private void OnSuspend(OWRigidbody suspendedBody) => netIdentity.SendAuthQueueMessage(AuthQueueAction.Remove);
private void OnUnsuspend(OWRigidbody suspendedBody) => netIdentity.UpdateAuthQueue(AuthQueueAction.Add);
private void OnSuspend(OWRigidbody suspendedBody) => netIdentity.UpdateAuthQueue(AuthQueueAction.Remove);
protected override void OnRenderObject()
{

2
QSB/AuthoritySync/AuthQueueMessage.cs
View File

@ -32,7 +32,7 @@ namespace QSB.AuthoritySync
public override bool ShouldReceive => QSBWorldSync.AllObjectsReady;
public override void OnReceiveLocal() => OnReceiveRemote();
public override void OnReceiveRemote() => NetworkServer.spawned[NetId].UpdateAuthQueue(From, Value);
public override void OnReceiveRemote() => NetworkServer.spawned[NetId].ServerUpdateAuthQueue(From, Value);
}
public enum AuthQueueAction

6
QSB/AuthoritySync/AuthorityManager.cs
View File

@ -17,7 +17,7 @@ namespace QSB.AuthoritySync
public static void RegisterAuthQueue(this NetworkIdentity identity) => _authQueue.Add(identity, new List<uint>());
public static void UnregisterAuthQueue(this NetworkIdentity identity) => _authQueue.Remove(identity);
public static void UpdateAuthQueue(this NetworkIdentity identity, uint id, AuthQueueAction action)
public static void ServerUpdateAuthQueue(this NetworkIdentity identity, uint id, AuthQueueAction action)
{
var authQueue = _authQueue[identity];
var oldOwner = authQueue.Count != 0 ? authQueue[0] : uint.MaxValue;
@ -53,7 +53,7 @@ namespace QSB.AuthoritySync
var id = conn.GetPlayerId();
foreach (var identity in _authQueue.Keys)
{
identity.UpdateAuthQueue(id, AuthQueueAction.Remove);
identity.ServerUpdateAuthQueue(id, AuthQueueAction.Remove);
}
}
@ -82,7 +82,7 @@ namespace QSB.AuthoritySync
#region any client
public static void SendAuthQueueMessage(this NetworkIdentity identity, AuthQueueAction action) =>
public static void UpdateAuthQueue(this NetworkIdentity identity, AuthQueueAction action) =>
new AuthQueueMessage(identity.netId, action).Send();
#endregion

6
QSB/JellyfishSync/TransformSync/JellyfishTransformSync.cs
View File

@ -56,7 +56,7 @@ namespace QSB.JellyfishSync.TransformSync
AttachedRigidbody.OnUnsuspendOWRigidbody += OnUnsuspend;
AttachedRigidbody.OnSuspendOWRigidbody += OnSuspend;
netIdentity.SendAuthQueueMessage(AttachedRigidbody.IsSuspended() ? AuthQueueAction.Remove : AuthQueueAction.Add);
netIdentity.UpdateAuthQueue(AttachedRigidbody.IsSuspended() ? AuthQueueAction.Remove : AuthQueueAction.Add);
}
protected override void Uninit()
@ -67,8 +67,8 @@ namespace QSB.JellyfishSync.TransformSync
AttachedRigidbody.OnSuspendOWRigidbody -= OnSuspend;
}
private void OnUnsuspend(OWRigidbody suspendedBody) => netIdentity.SendAuthQueueMessage(AuthQueueAction.Add);
private void OnSuspend(OWRigidbody suspendedBody) => netIdentity.SendAuthQueueMessage(AuthQueueAction.Remove);
private void OnUnsuspend(OWRigidbody suspendedBody) => netIdentity.UpdateAuthQueue(AuthQueueAction.Add);
private void OnSuspend(OWRigidbody suspendedBody) => netIdentity.UpdateAuthQueue(AuthQueueAction.Remove);
protected override void Serialize(NetworkWriter writer)
{

2
QSB/OrbSync/Messages/OrbDragMessage.cs
View File

@ -12,7 +12,7 @@ namespace QSB.OrbSync.Messages
{
if (QSBCore.IsHost && Value)
{
WorldObject.TransformSync.netIdentity.UpdateAuthQueue(From, AuthQueueAction.Force);
WorldObject.TransformSync.netIdentity.ServerUpdateAuthQueue(From, AuthQueueAction.Force);
}
}

8
QSB/OrbSync/TransformSync/NomaiOrbTransformSync.cs
View File

@ -31,7 +31,7 @@ namespace QSB.OrbSync.TransformSync
if (QSBCore.IsHost)
{
netIdentity.RegisterAuthQueue();
netIdentity.UpdateAuthQueue(QSBPlayerManager.LocalPlayerId, AuthQueueAction.Add);
netIdentity.ServerUpdateAuthQueue(QSBPlayerManager.LocalPlayerId, AuthQueueAction.Add);
}
base.OnStartClient();
@ -61,7 +61,7 @@ namespace QSB.OrbSync.TransformSync
body.OnSuspendOWRigidbody += OnSuspend;
if (!QSBCore.IsHost)
{
netIdentity.SendAuthQueueMessage(body.IsSuspended() ? AuthQueueAction.Remove : AuthQueueAction.Add);
netIdentity.UpdateAuthQueue(body.IsSuspended() ? AuthQueueAction.Remove : AuthQueueAction.Add);
}
}
@ -82,7 +82,7 @@ namespace QSB.OrbSync.TransformSync
}
}
private void OnUnsuspend(OWRigidbody suspendedBody) => netIdentity.SendAuthQueueMessage(AuthQueueAction.Add);
private void OnSuspend(OWRigidbody suspendedBody) => netIdentity.SendAuthQueueMessage(AuthQueueAction.Remove);
private void OnUnsuspend(OWRigidbody suspendedBody) => netIdentity.UpdateAuthQueue(AuthQueueAction.Add);
private void OnSuspend(OWRigidbody suspendedBody) => netIdentity.UpdateAuthQueue(AuthQueueAction.Remove);
}
}