improve debug logging

Author: Jacques Kang

src/IpcServiceSample.ConsoleServer/Program.cs

@@ -29,6 +29,8 @@ static void Main(string[] args)
                 Console.ReadKey();
                 source.Cancel();
             }));
+
+            Console.WriteLine("Server stopped.");
         }
 
         private static IServiceCollection ConfigureServices(IServiceCollection services)

src/JKang.IpcServiceFramework.Server/IpcServiceHost.cs

@@ -29,7 +29,20 @@ public void Run()
         public Task RunAsync(CancellationToken cancellationToken = default(CancellationToken))
         {
             Task[] tasks = _endpoints
-                .Select(endpoint => endpoint.ListenAsync(cancellationToken))
+                .Select(endpoint =>
+                {
+                    _logger.LogDebug($"Starting endpoint '{endpoint.Name}'...");
+
+                    cancellationToken.Register(() =>
+                    {
+                        _logger.LogDebug($"Stopping endpoint '{endpoint.Name}'...");
+                    });
+
+                    return endpoint.ListenAsync(cancellationToken).ContinueWith(_ =>
+                    {
+                        _logger.LogDebug($"Endpoint '{endpoint.Name}' stopped.");
+                    });
+                })
                 .ToArray();
             return Task.WhenAll(tasks);
         }

src/JKang.IpcServiceFramework.Server/NamedPipe/NamedPipeIpcServiceEndpoint.cs

@@ -37,7 +37,7 @@ public NamedPipeIpcServiceEndpoint(string name, IServiceProvider serviceProvider
 
             return Task.Factory.StartNew(() =>
             {
-                _logger.LogDebug($"Listening named pipe endpoint '{Name}'...");
+                _logger.LogDebug($"Endpoint '{Name}' listening on pipe '{PipeName}'...");
                 while (!cancellationToken.IsCancellationRequested)
                 {
                     Thread.Sleep(100);
@@ -52,7 +52,6 @@ public NamedPipeIpcServiceEndpoint(string name, IServiceProvider serviceProvider
                         }
                     }
                 }
-                _logger.LogDebug($"Shutting down named pipe endpoint '{Name}'...");
             });
         }
 

src/JKang.IpcServiceFramework.Server/Tcp/TcpIpcServiceEndpoint.cs

@@ -34,15 +34,14 @@ public TcpIpcServiceEndpoint(String name, IServiceProvider serviceProvider, IPAd
 
             cancellationToken.Register(() =>
             {
-                _logger.LogDebug($"Shutting down tcp endpoint '{Name}'...");
                 _listener.Stop();
             });
 
             return Task.Run(async () =>
             {
                 try
                 {
-                    _logger.LogDebug($"Listening tcp endpoint '{Name}' on port {Port}...");
+                    _logger.LogDebug($"Endpoint '{Name}' listening on port {Port}...");
                     while (true)
                     {
                         TcpClient client = await _listener.AcceptTcpClientAsync();