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

feat: implement log reopening on SIGUSR1 signal

Browse Source
This commit is contained in:
Joseph Doherty
2026-02-23 00:46:09 -05:00
parent cf75077bc4
commit 345e7ca15c
2 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/NATS.Server.Host/Program.cs
View File

@@ -139,6 +139,14 @@ using var server = new NatsServer(options, loggerFactory);
// Register signal handlers // Register signal handlers
server.HandleSignals(); server.HandleSignals();
server.ReOpenLogFile = () =>
{
Log.Information("Reopening log file");
Log.CloseAndFlush();
Log.Logger = logConfig.CreateLogger();
Log.Information("File log re-opened");
};
// Ctrl+C triggers graceful shutdown // Ctrl+C triggers graceful shutdown
Console.CancelKeyPress += (_, e) => Console.CancelKeyPress += (_, e) =>
{ {

6
src/NATS.Server/NatsServer.cs
View File

@@ -61,6 +61,7 @@ public sealed class NatsServer : IMessageRouter, ISubListAccess, IDisposable
public string ServerNKey { get; } public string ServerNKey { get; }
public bool IsShuttingDown => Volatile.Read(ref _shutdown) != 0; public bool IsShuttingDown => Volatile.Read(ref _shutdown) != 0;
public bool IsLameDuckMode => Volatile.Read(ref _lameDuck) != 0; public bool IsLameDuckMode => Volatile.Read(ref _lameDuck) != 0;
public Action? ReOpenLogFile { get; set; }
public IEnumerable<NatsClient> GetClients() => _clients.Values; public IEnumerable<NatsClient> GetClients() => _clients.Values;
public Task WaitForReadyAsync() => _listeningStarted.Task; public Task WaitForReadyAsync() => _listeningStarted.Task;
@@ -192,7 +193,7 @@ public sealed class NatsServer : IMessageRouter, ISubListAccess, IDisposable
/// <summary> /// <summary>
/// Registers Unix signal handlers. /// Registers Unix signal handlers.
/// SIGTERM → shutdown, SIGUSR2 → lame duck, SIGUSR1 → log reopen (stub), SIGHUP → reload (stub). /// SIGTERM → shutdown, SIGUSR2 → lame duck, SIGUSR1 → log reopen, SIGHUP → reload (stub).
/// </summary> /// </summary>
public void HandleSignals() public void HandleSignals()
{ {
@@ -222,7 +223,8 @@ public sealed class NatsServer : IMessageRouter, ISubListAccess, IDisposable
_signalRegistrations.Add(PosixSignalRegistration.Create((PosixSignal)10, ctx => _signalRegistrations.Add(PosixSignalRegistration.Create((PosixSignal)10, ctx =>
{ {
ctx.Cancel = true; ctx.Cancel = true;
_logger.LogWarning("Trapped SIGUSR1 signal — log reopen not yet supported"); _logger.LogInformation("Trapped SIGUSR1 signal — reopening log file");
ReOpenLogFile?.Invoke();
})); }));
_signalRegistrations.Add(PosixSignalRegistration.Create((PosixSignal)12, ctx => _signalRegistrations.Add(PosixSignalRegistration.Create((PosixSignal)12, ctx =>