using System.ComponentModel;
using System.DirectoryServices.ActiveDirectory;
using System.IO;
+using System.IO.Pipes;
using System.Linq;
using System.Net;
using System.Runtime.InteropServices;
using System.Security;
using System.Text;
using System.Threading;
+using System.Threading.Tasks;
using Microsoft.DotNet.RemoteExecutor;
using Microsoft.Win32.SafeHandles;
using Xunit;
}
}
+ [Fact]
+ public void Start_HasStandardInputEncodingNonRedirected_ThrowsInvalidOperationException()
+ {
+ var process = new Process
+ {
+ StartInfo = new ProcessStartInfo
+ {
+ FileName = "FileName",
+ RedirectStandardInput = false,
+ StandardInputEncoding = Encoding.UTF8
+ }
+ };
+
+ Assert.Throws<InvalidOperationException>(() => process.Start());
+ }
+
+ [Fact]
+ public void Start_StandardInputEncodingPropagatesToStreamWriter()
+ {
+ var process = CreateProcessPortable(RemotelyInvokable.Dummy);
+ process.StartInfo.RedirectStandardInput = true;
+ var encoding = new UTF32Encoding(bigEndian: false, byteOrderMark: true);
+ process.StartInfo.StandardInputEncoding = encoding;
+ process.Start();
+
+ Assert.Same(encoding, process.StandardInput.Encoding);
+ }
+
+ [Fact]
+ [PlatformSpecific(TestPlatforms.Windows)]
+ public void StartProcessWithArgumentList()
+ {
+ ProcessStartInfo psi = new ProcessStartInfo(GetCurrentProcessName());
+ psi.ArgumentList.Add("arg1");
+ psi.ArgumentList.Add("arg2");
+
+ Process testProcess = CreateProcess();
+ testProcess.StartInfo = psi;
+
+ try
+ {
+ testProcess.Start();
+ Assert.Equal(string.Empty, testProcess.StartInfo.Arguments);
+ }
+ finally
+ {
+ testProcess.Kill();
+
+ Assert.True(testProcess.WaitForExit(WaitInMS));
+ }
+ }
+
+ [Fact]
+ [PlatformSpecific(TestPlatforms.Windows)]
+ public void StartProcessWithSameArgumentList()
+ {
+ ProcessStartInfo psi = new ProcessStartInfo(GetCurrentProcessName());
+ psi.ArgumentList.Add("arg1");
+ psi.ArgumentList.Add("arg2");
+
+ Process testProcess = CreateProcess();
+ Process secondTestProcess = CreateProcess();
+ testProcess.StartInfo = psi;
+ try
+ {
+ testProcess.Start();
+ Assert.Equal(string.Empty, testProcess.StartInfo.Arguments);
+ secondTestProcess.StartInfo = psi;
+ secondTestProcess.Start();
+ Assert.Equal(string.Empty, secondTestProcess.StartInfo.Arguments);
+ }
+ finally
+ {
+ testProcess.Kill();
+
+ Assert.True(testProcess.WaitForExit(WaitInMS));
+
+ secondTestProcess.Kill();
+
+ Assert.True(testProcess.WaitForExit(WaitInMS));
+ }
+ }
+
+ [Fact]
+ public void BothArgumentCtorAndArgumentListSet()
+ {
+ ProcessStartInfo psi = new ProcessStartInfo(GetCurrentProcessName(), "arg3");
+ psi.ArgumentList.Add("arg1");
+ psi.ArgumentList.Add("arg2");
+
+ Process testProcess = CreateProcess();
+ testProcess.StartInfo = psi;
+ Assert.Throws<InvalidOperationException>(() => testProcess.Start());
+ }
+
+ [Fact]
+ public void BothArgumentSetAndArgumentListSet()
+ {
+ ProcessStartInfo psi = new ProcessStartInfo(GetCurrentProcessName());
+ psi.Arguments = "arg3";
+ psi.ArgumentList.Add("arg1");
+ psi.ArgumentList.Add("arg2");
+
+ Process testProcess = CreateProcess();
+ testProcess.StartInfo = psi;
+ Assert.Throws<InvalidOperationException>(() => testProcess.Start());
+ }
+
+ [Fact]
+ public void Kill_EntireProcessTree_True_ProcessNotStarted_ThrowsInvalidOperationException()
+ {
+ var process = new Process();
+ Assert.Throws<InvalidOperationException>(() => process.Kill(entireProcessTree: true));
+ }
+
+ [Fact]
+ [PlatformSpecific(TestPlatforms.Windows)] // Currently, remote processes are only supported on Windows. If that changes, adjust accordingly.
+ public void Kill_EntireProcessTree_True_CalledByNonLocalProcess_ThrowsInvalidOperationException()
+ {
+ Process currentProcess = Process.GetCurrentProcess();
+ Process process;
+
+ try
+ {
+ process = Process.GetProcessById(currentProcess.Id, "127.0.0.1");
+ }
+ catch (InvalidOperationException)
+ {
+ // As we can't detect reliably if performance counters are enabled,
+ // we silently abort on InvalidOperationExceptions since this test
+ // can only run if the attempt to get the process succeeded.
+ return;
+ }
+
+ Assert.Throws<NotSupportedException>(() => process.Kill(entireProcessTree: true));
+ }
+
+ [Fact]
+ public void Kill_EntireProcessTree_True_CalledOnCallingProcess_ThrowsInvalidOperationException()
+ {
+ var process = Process.GetCurrentProcess();
+ Assert.Throws<InvalidOperationException>(() => process.Kill(entireProcessTree: true));
+ }
+
+ [Fact]
+ public void Kill_EntireProcessTree_True_CalledOnTreeContainingCallingProcess_ThrowsInvalidOperationException()
+ {
+ Process containingProcess = CreateProcess(() =>
+ {
+ Process parentProcess = CreateProcess(() => RunProcessAttemptingToKillEntireTreeOnParent());
+
+ parentProcess.Start();
+ parentProcess.WaitForExit();
+
+ return parentProcess.ExitCode;
+
+ });
+
+ containingProcess.Start();
+ containingProcess.WaitForExit();
+
+ if (containingProcess.ExitCode != 10)
+ Assert.True(false, "attempt to terminate a process tree containing the calling process did not throw the expected exception");
+
+ int RunProcessAttemptingToKillEntireTreeOnParent()
+ {
+ Process process = CreateProcess(parentProcessIdString =>
+ {
+ Process parentProcess = Process.GetProcessById(int.Parse(parentProcessIdString));
+
+ bool caught = false;
+ try
+ {
+ parentProcess.Kill(entireProcessTree: true);
+ }
+ catch (InvalidOperationException)
+ {
+ caught = true;
+ }
+ return caught ? 10 : 20;
+ }, Process.GetCurrentProcess().Id.ToString());
+
+ process.Start();
+ process.WaitForExit();
+ return process.ExitCode;
+ }
+ }
+
+ [Theory]
+ [InlineData(true)]
+ [InlineData(false)]
+ public void Kill_ExitedChildProcess_DoesNotThrow(bool killTree)
+ {
+ Process process = CreateProcess();
+ process.Start();
+
+ process.WaitForExit();
+
+ process.Kill(killTree);
+ }
+
+ [Fact]
+ public async Task Kill_EntireProcessTree_False_OnlyRootProcessTerminated()
+ {
+ IReadOnlyList<Process> tree = CreateProcessTree();
+
+ try
+ {
+ Process parentProcess = tree.First();
+
+ parentProcess.Kill(entireProcessTree: false);
+
+ await Helpers.RetryWithBackoff(() =>
+ {
+ var actual = tree.Select(p => p.HasExited).ToList();
+ Assert.Equal(new[] { true, false, false }, actual);
+ });
+ }
+ finally
+ {
+ foreach (Process process in tree)
+ {
+ try
+ {
+ process.Kill();
+ }
+ catch
+ {
+ // Test cleanup code, so ignore any exceptions.
+ }
+ }
+ }
+ }
+
+ [Fact]
+ public async Task Kill_EntireProcessTree_True_EntireTreeTerminated()
+ {
+ IReadOnlyList<Process> tree = CreateProcessTree();
+
+ try
+ {
+ Process parentProcess = tree.First();
+
+ parentProcess.Kill(entireProcessTree: true);
+
+ await Helpers.RetryWithBackoff(() =>
+ {
+ var actual = tree.Select(p => p.HasExited).ToList();
+ Assert.Equal(new[] { true, true, true }, actual);
+ });
+ }
+ finally
+ {
+ foreach (Process process in tree)
+ {
+ try
+ {
+ process.Kill();
+ }
+ catch
+ {
+ // Test cleanup code, so ignore any exceptions.
+ }
+ }
+ }
+ }
+
+ private IReadOnlyList<Process> CreateProcessTree()
+ {
+ (Process Value, string Message) rootResult = ListenForAnonymousPipeMessage(rootPipeHandleString =>
+ {
+ Process root = CreateProcess(rhs =>
+ {
+ (Process Value, string Message) child1Result = ListenForAnonymousPipeMessage(child1PipeHandleString =>
+ {
+ Process child1 = CreateProcess(c1hs =>
+ {
+ Process child2 = CreateProcess(() => WaitForever());
+ child2.Start();
+
+ SendMessage(child2.Id.ToString(), c1hs);
+
+ return WaitForever();
+ }, child1PipeHandleString, autoDispose: false);
+
+ child1.Start();
+
+ return child1;
+ });
+
+ var child1ProcessId = child1Result.Value.Id;
+ var child2ProcessId = child1Result.Message;
+ SendMessage($"{child1ProcessId};{child2ProcessId}", rhs);
+
+ return WaitForever();
+ }, rootPipeHandleString, autoDispose: false);
+
+ root.Start();
+
+ return root;
+ });
+
+ IEnumerable<Process> childProcesses = rootResult.Message
+ .Split(';')
+ .Select(x => int.Parse(x))
+ .Select(pid => Process.GetProcessById(pid));
+
+ return new[] { rootResult.Value }
+ .Concat(childProcesses)
+ .ToList();
+
+ int WaitForever()
+ {
+ Thread.Sleep(Timeout.Infinite);
+
+ // never reaches here -- but necessary to satisfy method's signature
+ return RemoteExecutor.SuccessExitCode;
+ }
+
+ void SendMessage(string message, string handleAsString)
+ {
+ using (var client = new AnonymousPipeClientStream(PipeDirection.Out, handleAsString))
+ {
+ using (var sw = new StreamWriter(client))
+ {
+ sw.WriteLine(message);
+ }
+ }
+ }
+
+ (T Value, string Message) ListenForAnonymousPipeMessage<T>(Func<string, T> action)
+ {
+ using (var pipeServer = new AnonymousPipeServerStream(PipeDirection.In, HandleInheritability.Inheritable))
+ {
+ string handleAsString = pipeServer.GetClientHandleAsString();
+
+ T result = action(handleAsString);
+
+ pipeServer.DisposeLocalCopyOfClientHandle();
+
+ using (var sr = new StreamReader(pipeServer))
+ {
+ return (result, sr.ReadLine());
+ }
+ }
+ }
+ }
+
private string GetCurrentProcessName()
{
return $"{Process.GetCurrentProcess().ProcessName}.exe";
+++ /dev/null
-// Licensed to the .NET Foundation under one or more agreements.
-// The .NET Foundation licenses this file to you under the MIT license.
-// See the LICENSE file in the project root for more information.
-
-using System.Collections.Generic;
-using System.IO;
-using System.IO.Pipes;
-using System.Linq;
-using System.Text;
-using System.Threading;
-using System.Threading.Tasks;
-using Microsoft.DotNet.RemoteExecutor;
-using Xunit;
-
-namespace System.Diagnostics.Tests
-{
- public partial class ProcessTests : ProcessTestBase
- {
- [Fact]
- public void Start_HasStandardInputEncodingNonRedirected_ThrowsInvalidOperationException()
- {
- var process = new Process
- {
- StartInfo = new ProcessStartInfo
- {
- FileName = "FileName",
- RedirectStandardInput = false,
- StandardInputEncoding = Encoding.UTF8
- }
- };
-
- Assert.Throws<InvalidOperationException>(() => process.Start());
- }
-
- [Fact]
- public void Start_StandardInputEncodingPropagatesToStreamWriter()
- {
- var process = CreateProcessPortable(RemotelyInvokable.Dummy);
- process.StartInfo.RedirectStandardInput = true;
- var encoding = new UTF32Encoding(bigEndian: false, byteOrderMark: true);
- process.StartInfo.StandardInputEncoding = encoding;
- process.Start();
-
- Assert.Same(encoding, process.StandardInput.Encoding);
- }
-
- [Fact]
- [PlatformSpecific(TestPlatforms.Windows)]
- public void StartProcessWithArgumentList()
- {
- ProcessStartInfo psi = new ProcessStartInfo(GetCurrentProcessName());
- psi.ArgumentList.Add("arg1");
- psi.ArgumentList.Add("arg2");
-
- Process testProcess = CreateProcess();
- testProcess.StartInfo = psi;
-
- try
- {
- testProcess.Start();
- Assert.Equal(string.Empty, testProcess.StartInfo.Arguments);
- }
- finally
- {
- testProcess.Kill();
-
- Assert.True(testProcess.WaitForExit(WaitInMS));
- }
- }
-
- [Fact]
- [PlatformSpecific(TestPlatforms.Windows)]
- public void StartProcessWithSameArgumentList()
- {
- ProcessStartInfo psi = new ProcessStartInfo(GetCurrentProcessName());
- psi.ArgumentList.Add("arg1");
- psi.ArgumentList.Add("arg2");
-
- Process testProcess = CreateProcess();
- Process secondTestProcess = CreateProcess();
- testProcess.StartInfo = psi;
- try
- {
- testProcess.Start();
- Assert.Equal(string.Empty, testProcess.StartInfo.Arguments);
- secondTestProcess.StartInfo = psi;
- secondTestProcess.Start();
- Assert.Equal(string.Empty, secondTestProcess.StartInfo.Arguments);
- }
- finally
- {
- testProcess.Kill();
-
- Assert.True(testProcess.WaitForExit(WaitInMS));
-
- secondTestProcess.Kill();
-
- Assert.True(testProcess.WaitForExit(WaitInMS));
- }
- }
-
- [Fact]
- public void BothArgumentCtorAndArgumentListSet()
- {
- ProcessStartInfo psi = new ProcessStartInfo(GetCurrentProcessName(), "arg3");
- psi.ArgumentList.Add("arg1");
- psi.ArgumentList.Add("arg2");
-
- Process testProcess = CreateProcess();
- testProcess.StartInfo = psi;
- Assert.Throws<InvalidOperationException>(() => testProcess.Start());
- }
-
- [Fact]
- public void BothArgumentSetAndArgumentListSet()
- {
- ProcessStartInfo psi = new ProcessStartInfo(GetCurrentProcessName());
- psi.Arguments = "arg3";
- psi.ArgumentList.Add("arg1");
- psi.ArgumentList.Add("arg2");
-
- Process testProcess = CreateProcess();
- testProcess.StartInfo = psi;
- Assert.Throws<InvalidOperationException>(() => testProcess.Start());
- }
-
- [Fact]
- public void Kill_EntireProcessTree_True_ProcessNotStarted_ThrowsInvalidOperationException()
- {
- var process = new Process();
- Assert.Throws<InvalidOperationException>(() => process.Kill(entireProcessTree: true));
- }
-
- [Fact]
- [PlatformSpecific(TestPlatforms.Windows)] // Currently, remote processes are only supported on Windows. If that changes, adjust accordingly.
- public void Kill_EntireProcessTree_True_CalledByNonLocalProcess_ThrowsInvalidOperationException()
- {
- Process currentProcess = Process.GetCurrentProcess();
- Process process;
-
- try
- {
- process = Process.GetProcessById(currentProcess.Id, "127.0.0.1");
- }
- catch (InvalidOperationException)
- {
- // As we can't detect reliably if performance counters are enabled,
- // we silently abort on InvalidOperationExceptions since this test
- // can only run if the attempt to get the process succeeded.
- return;
- }
-
- Assert.Throws<NotSupportedException>(() => process.Kill(entireProcessTree: true));
- }
-
- [Fact]
- public void Kill_EntireProcessTree_True_CalledOnCallingProcess_ThrowsInvalidOperationException()
- {
- var process = Process.GetCurrentProcess();
- Assert.Throws<InvalidOperationException>(() => process.Kill(entireProcessTree: true));
- }
-
- [Fact]
- public void Kill_EntireProcessTree_True_CalledOnTreeContainingCallingProcess_ThrowsInvalidOperationException()
- {
- Process containingProcess = CreateProcess(() =>
- {
- Process parentProcess = CreateProcess(() => RunProcessAttemptingToKillEntireTreeOnParent());
-
- parentProcess.Start();
- parentProcess.WaitForExit();
-
- return parentProcess.ExitCode;
-
- });
-
- containingProcess.Start();
- containingProcess.WaitForExit();
-
- if (containingProcess.ExitCode != 10)
- Assert.True(false, "attempt to terminate a process tree containing the calling process did not throw the expected exception");
-
- int RunProcessAttemptingToKillEntireTreeOnParent()
- {
- Process process = CreateProcess(parentProcessIdString =>
- {
- Process parentProcess = Process.GetProcessById(int.Parse(parentProcessIdString));
-
- bool caught = false;
- try
- {
- parentProcess.Kill(entireProcessTree: true);
- }
- catch (InvalidOperationException)
- {
- caught = true;
- }
- return caught ? 10 : 20;
- }, Process.GetCurrentProcess().Id.ToString());
-
- process.Start();
- process.WaitForExit();
- return process.ExitCode;
- }
- }
-
- [Theory]
- [InlineData(true)]
- [InlineData(false)]
- public void Kill_ExitedChildProcess_DoesNotThrow(bool killTree)
- {
- Process process = CreateProcess();
- process.Start();
-
- process.WaitForExit();
-
- process.Kill(killTree);
- }
-
- [Fact]
- public async Task Kill_EntireProcessTree_False_OnlyRootProcessTerminated()
- {
- IReadOnlyList<Process> tree = CreateProcessTree();
-
- try
- {
- Process parentProcess = tree.First();
-
- parentProcess.Kill(entireProcessTree: false);
-
- await Helpers.RetryWithBackoff(() =>
- {
- var actual = tree.Select(p => p.HasExited).ToList();
- Assert.Equal(new[] { true, false, false }, actual);
- });
- }
- finally
- {
- foreach (Process process in tree)
- {
- try
- {
- process.Kill();
- }
- catch
- {
- // Test cleanup code, so ignore any exceptions.
- }
- }
- }
- }
-
- [Fact]
- public async Task Kill_EntireProcessTree_True_EntireTreeTerminated()
- {
- IReadOnlyList<Process> tree = CreateProcessTree();
-
- try
- {
- Process parentProcess = tree.First();
-
- parentProcess.Kill(entireProcessTree: true);
-
- await Helpers.RetryWithBackoff(() =>
- {
- var actual = tree.Select(p => p.HasExited).ToList();
- Assert.Equal(new[] { true, true, true }, actual);
- });
- }
- finally
- {
- foreach (Process process in tree)
- {
- try
- {
- process.Kill();
- }
- catch
- {
- // Test cleanup code, so ignore any exceptions.
- }
- }
- }
- }
-
- private IReadOnlyList<Process> CreateProcessTree()
- {
- (Process Value, string Message) rootResult = ListenForAnonymousPipeMessage(rootPipeHandleString =>
- {
- Process root = CreateProcess(rhs =>
- {
- (Process Value, string Message) child1Result = ListenForAnonymousPipeMessage(child1PipeHandleString =>
- {
- Process child1 = CreateProcess(c1hs =>
- {
- Process child2 = CreateProcess(() => WaitForever());
- child2.Start();
-
- SendMessage(child2.Id.ToString(), c1hs);
-
- return WaitForever();
- }, child1PipeHandleString, autoDispose: false);
-
- child1.Start();
-
- return child1;
- });
-
- var child1ProcessId = child1Result.Value.Id;
- var child2ProcessId = child1Result.Message;
- SendMessage($"{child1ProcessId};{child2ProcessId}", rhs);
-
- return WaitForever();
- }, rootPipeHandleString, autoDispose: false);
-
- root.Start();
-
- return root;
- });
-
- IEnumerable<Process> childProcesses = rootResult.Message
- .Split(';')
- .Select(x => int.Parse(x))
- .Select(pid => Process.GetProcessById(pid));
-
- return new[] { rootResult.Value }
- .Concat(childProcesses)
- .ToList();
-
- int WaitForever()
- {
- Thread.Sleep(Timeout.Infinite);
-
- // never reaches here -- but necessary to satisfy method's signature
- return RemoteExecutor.SuccessExitCode;
- }
-
- void SendMessage(string message, string handleAsString)
- {
- using (var client = new AnonymousPipeClientStream(PipeDirection.Out, handleAsString))
- {
- using (var sw = new StreamWriter(client))
- {
- sw.WriteLine(message);
- }
- }
- }
-
- (T Value, string Message) ListenForAnonymousPipeMessage<T>(Func<string, T> action)
- {
- using (var pipeServer = new AnonymousPipeServerStream(PipeDirection.In, HandleInheritability.Inheritable))
- {
- string handleAsString = pipeServer.GetClientHandleAsString();
-
- T result = action(handleAsString);
-
- pipeServer.DisposeLocalCopyOfClientHandle();
-
- using (var sr = new StreamReader(pipeServer))
- {
- return (result, sr.ReadLine());
- }
- }
- }
- }
- }
-}
<Compile Include="XunitAssemblyAttributes.cs" />
<Compile Include="ProcessStartInfoTests.netcoreapp.cs" />
<Compile Include="ProcessStreamReadTests.netcoreapp.cs" />
- <Compile Include="ProcessTests.netcoreapp.cs" />
</ItemGroup>
<ItemGroup Condition="'$(TargetsWindows)' == 'true'">
<Compile Include="ProcessTests.Windows.cs" />
projects / platform / upstream / dotnet / runtime.git / commitdiff