dohertj2/natsnet
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore(batch23): start routes batch

Browse Source
This commit is contained in:
Joseph Doherty
2026-02-28 20:59:47 -05:00
parent 0fd5dc71fc
commit f2bc957229
3 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
dotnet/src/ZB.MOM.NatsNet.Server/Accounts/Account.cs
View File

@@ -2279,7 +2279,7 @@ public sealed class Account : INatsAccount
} }
if (sid is { Length: > 0 } && InternalClient != null) if (sid is { Length: > 0 } && InternalClient != null)
InternalClient.ProcessUnsub(sid); InternalClient.RemoveSubBySid(sid);
if (tracking && requestor != null && !delivered) if (tracking && requestor != null && !delivered)
SendBackendErrorTrackingLatency(serviceImport, reason); SendBackendErrorTrackingLatency(serviceImport, reason);
@@ -2355,7 +2355,7 @@ public sealed class Account : INatsAccount
} }
if (sid != null && InternalClient != null) if (sid != null && InternalClient != null)
InternalClient.ProcessUnsub(sid); InternalClient.RemoveSubBySid(sid);
} }
/// <summary> /// <summary>
@@ -2548,7 +2548,7 @@ public sealed class Account : INatsAccount
if (InternalClient == null && Server is NatsServer server) if (InternalClient == null && Server is NatsServer server)
{ {
InternalClient = server.CreateInternalAccountClient(); InternalClient = server.CreateInternalAccountClient();
InternalClient.Account = this; InternalClient.SetAccount(this);
} }
return InternalClient; return InternalClient;
@@ -2573,7 +2573,7 @@ public sealed class Account : INatsAccount
_mu.EnterReadLock(); _mu.EnterReadLock();
var internalClient = InternalClient; var internalClient = InternalClient;
_mu.ExitReadLock(); _mu.ExitReadLock();
internalClient?.ProcessUnsub(sub.Sid); internalClient?.RemoveSubBySid(sub.Sid);
} }
/// <summary> /// <summary>
@@ -2685,7 +2685,7 @@ public sealed class Account : INatsAccount
return; return;
foreach (var sid in subscriptionIds) foreach (var sid in subscriptionIds)
internalClient.ProcessUnsub(sid); internalClient.RemoveSubBySid(sid);
internalClient.CloseConnection(ClosedState.InternalClient); internalClient.CloseConnection(ClosedState.InternalClient);
} }
@@ -4170,7 +4170,7 @@ public sealed class Account : INatsAccount
return new ClientInfo return new ClientInfo
{ {
Id = client.Cid, Id = client.Cid,
Account = client.Account?.Name ?? string.Empty, Account = client.Account()?.Name ?? string.Empty,
Name = client.Opts.Name ?? string.Empty, Name = client.Opts.Name ?? string.Empty,
Rtt = client.GetRttValue(), Rtt = client.GetRttValue(),
Start = client.Start == default ? string.Empty : client.Start.ToUniversalTime().ToString("O"), Start = client.Start == default ? string.Empty : client.Start.ToUniversalTime().ToString("O"),

2
dotnet/src/ZB.MOM.NatsNet.Server/ClientConnection.cs
View File

@@ -1686,7 +1686,7 @@ public sealed partial class ClientConnection
} }
} }
internal void ProcessUnsub(byte[] sid) internal void RemoveSubBySid(byte[] sid)
{ {
lock (_mu) lock (_mu)
{ {

BIN
porting.db
View File

Binary file not shown.