Skip to content

Commit 39cb2a5

Browse files
fix async issue
1 parent 2299d98 commit 39cb2a5

File tree

1 file changed

+12
-6
lines changed

1 file changed

+12
-6
lines changed

src/Microstack.Daemon.WindowsService/MicroStackListner.cs

Lines changed: 12 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -25,25 +25,31 @@ public override Task StartAsync(CancellationToken cancellationToken)
2525
}
2626
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
2727
{
28-
while(!stoppingToken.IsCancellationRequested)
28+
while (!stoppingToken.IsCancellationRequested)
2929
{
3030
var p = Process.GetProcessesByName("microstack");
31-
using (var pipe = new NamedPipeServerStream("microstack_pipe", PipeDirection.InOut, 5))
31+
using (var pipe = new NamedPipeServerStream("microstack_pipe", PipeDirection.InOut, 5,
32+
PipeTransmissionMode.Byte, PipeOptions.Asynchronous))
3233
{
3334
var managedThread = Thread.CurrentThread.ManagedThreadId;
34-
try {
35+
try
36+
{
3537
await pipe.WaitForConnectionAsync(stoppingToken);
36-
} catch(Exception ex)
38+
}
39+
catch (Exception ex)
3740
{
38-
41+
3942
}
43+
4044
Console.WriteLine("Connected");
4145
var processContract = Serializer.Deserialize<ProcessContract>(pipe);
4246
lock (_spawnManagerLock)
4347
{
4448
_processStateManager.AddProcess(processContract.ProcessId, processContract.MicroStackPID);
4549
}
46-
Console.WriteLine($"Registered {processContract.ProcessId} with MicroStack PID {processContract.MicroStackPID}");
50+
51+
Console.WriteLine(
52+
$"Registered {processContract.ProcessId} with MicroStack PID {processContract.MicroStackPID}");
4753
pipe.Disconnect();
4854
}
4955
}

0 commit comments

Comments
 (0)