Merge pull request #48 from jacqueskang/bugfix-namedpipes-cancellation

jacqueskang · web-flow · commit ce4cb5229c9a · 2018-12-11T13:21:27.000+01:00
fix issue that cancellation request not work after WaitForConnectionA…
diff --git a/src/JKang.IpcServiceFramework.Server/NamedPipe/NamedPipeIpcServiceEndpoint.cs b/src/JKang.IpcServiceFramework.Server/NamedPipe/NamedPipeIpcServiceEndpoint.cs
@@ -60,7 +60,8 @@ private void StartServerThread(object obj)
             var token = (CancellationToken)obj;
             try
             {
-                using (var server = new NamedPipeServerStream(PipeName, PipeDirection.InOut, _options.ThreadCount))
+                using (var server = new NamedPipeServerStream(PipeName, PipeDirection.InOut, _options.ThreadCount,
+                    PipeTransmissionMode.Byte, PipeOptions.Asynchronous))
                 {
                     server.WaitForConnectionAsync(token).Wait();
                     ProcessAsync(server, _logger, token).Wait();

Original file line number	Diff line number	Diff line change
`@@ -60,7 +60,8 @@ private void StartServerThread(object obj)`
`60`	`60`	`var token = (CancellationToken)obj;`
`61`	`61`	`try`
`62`	`62`	`{`
`63`		`- using (var server = new NamedPipeServerStream(PipeName, PipeDirection.InOut, _options.ThreadCount))`
	`63`	`+ using (var server = new NamedPipeServerStream(PipeName, PipeDirection.InOut, _options.ThreadCount,`
	`64`	`+ PipeTransmissionMode.Byte, PipeOptions.Asynchronous))`
`64`	`65`	`{`
`65`	`66`	`server.WaitForConnectionAsync(token).Wait();`
`66`	`67`	`ProcessAsync(server, _logger, token).Wait();`