chore: add .worktrees/ to .gitignore for isolated development
This commit is contained in:
3
.gitignore
vendored
3
.gitignore
vendored
@@ -161,6 +161,9 @@ FodyWeavers.xsd
|
|||||||
## Go reference implementation
|
## Go reference implementation
|
||||||
golang/
|
golang/
|
||||||
|
|
||||||
|
## Git worktrees
|
||||||
|
.worktrees/
|
||||||
|
|
||||||
## OS
|
## OS
|
||||||
.DS_Store
|
.DS_Store
|
||||||
Thumbs.db
|
Thumbs.db
|
||||||
|
|||||||
@@ -356,14 +356,14 @@ public sealed class NatsClient : IDisposable
|
|||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
var currentPingsOut = Interlocked.Increment(ref _pingsOut);
|
if (Volatile.Read(ref _pingsOut) + 1 > _options.MaxPingsOut)
|
||||||
if (currentPingsOut > _options.MaxPingsOut)
|
|
||||||
{
|
{
|
||||||
_logger.LogDebug("Client {ClientId} stale connection — closing", Id);
|
_logger.LogDebug("Client {ClientId} stale connection — closing", Id);
|
||||||
await SendErrAndCloseAsync(NatsProtocol.ErrStaleConnection);
|
await SendErrAndCloseAsync(NatsProtocol.ErrStaleConnection);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var currentPingsOut = Interlocked.Increment(ref _pingsOut);
|
||||||
_logger.LogDebug("Client {ClientId} sending PING ({PingsOut}/{MaxPingsOut})",
|
_logger.LogDebug("Client {ClientId} sending PING ({PingsOut}/{MaxPingsOut})",
|
||||||
Id, currentPingsOut, _options.MaxPingsOut);
|
Id, currentPingsOut, _options.MaxPingsOut);
|
||||||
try
|
try
|
||||||
|
|||||||
Reference in New Issue
Block a user