ydeng/gameservicewarden
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added proper disposing to ServiceDescriptor.

Browse Source 
Fixed ServiceDescriptor tests where cancellation didn't work.

Disposing currently awaited pipe terminates the task.
This commit is contained in:
Harrison Deng 2021-04-10 15:25:29 -05:00
parent a6f4d918cb
commit 911724627e
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/GameServiceWarden.Core/Games/ServiceDescriptor.cs
View File

@ -12,6 +12,7 @@ using System.Threading.Tasks;
using GameServiceWarden.Core.Games.Modules.Exceptions;
using GameServiceWarden.Core.Logging;
using GameServiceWarden.API.Module;
using System.Net.Sockets;
//TODO Update UML
namespace GameServiceWarden.Core.Games
@ -40,6 +41,7 @@ namespace GameServiceWarden.Core.Games
private Task logUpdateTask;
private Task acceptingTask;
private volatile CancellationTokenSource stopToken;
private NamedPipeServerStream acceptingPipe;
/// <summary>
/// Name of module this service uses.
@ -110,9 +112,11 @@ namespace GameServiceWarden.Core.Games
if (!running) throw new InvalidOperationException("Service instance not running.");
Logger.Log($"\"{ServiceName}\" is stopping.");
service.ElegantShutdown();
stopToken.Cancel();
logSender.Close();
logReceiver.Close();
stopToken.Cancel(); // Doesn't work on Linux(?)
acceptingPipe.Close();
acceptingPipe.Dispose(); //Handles Linux case
logSender.Dispose(); //Makes sure logging client is disposed
logReceiver.Dispose(); //Closes receiver (Linux doesn't respond to cancellations, needed to dispose either way).
try
{
if (!acceptingTask.Wait(TIMEOUT)) {
@ -121,7 +125,7 @@ namespace GameServiceWarden.Core.Games
}
catch (AggregateException e)
{
e.Handle((exception) => exception is TaskCanceledException);
e.Handle((exception) => exception is TaskCanceledException || exception is SocketException); //Task cancel for Windows, Socket for operation cancellation.
}
try
{
@ -131,10 +135,12 @@ namespace GameServiceWarden.Core.Games
}
catch (AggregateException e)
{
e.Handle((exception) => exception is TaskCanceledException);
e.Handle((exception) => exception is TaskCanceledException || exception is SocketException); //Same as above.
}
foreach (NamedPipeServerStream pipe in logStreamListeners)
{
pipe.Dispose();
}
logSender.Dispose();
logReceiver.Dispose();
logStreamListeners.Clear();
stopToken.Dispose();
}
@ -206,6 +212,7 @@ namespace GameServiceWarden.Core.Games
while (running)
{
NamedPipeServerStream pipe = new NamedPipeServerStream(ServiceLogPipeName, PipeDirection.Out, NamedPipeServerStream.MaxAllowedServerInstances, PipeTransmissionMode.Byte, PipeOptions.Asynchronous);
acceptingPipe = pipe;
await pipe.WaitForConnectionAsync(stopToken.Token);
Logger.Log($"A log listener has connected. Currently broadcasting to {logStreamListeners.Count + 1} listener(s).", LogLevel.DEBUG);
logStreamListeners.Push(pipe);