Rediredting stdout for createprocessasuser to pipe 挂起读取
本文关键字:pipe 挂起 读取 to createprocessasuser stdout for Rediredting | 更新日期: 2023-09-27 18:35:18
我正在使用CreateProcessAsUser从服务运行进程,并将标准输出重定向到命名管道。 但是当我尝试从命名管道读取时,它会挂在读取上并且永远不会返回。我在单独的任务中尝试了这个(如下所述),只是在主进程中阅读它。 我也尝试使用C# AnonymousPipeServerStream类(请参阅下面注释掉的代码),但有相同的挂起。
知道我错过了什么吗? 谢谢!
Native.SECURITY_ATTRIBUTES sa = new Native.SECURITY_ATTRIBUTES();
processAttributes.nLength = Marshal.SizeOf(sa);
processAttributes.lpSecurityDescriptor = IntPtr.Zero;
processAttributes.bInheritHandle = 0;
//AnonymousPipeServerStream pipeServer = new AnonymousPipeServerStream(PipeDirection.In, HandleInheritability.Inheritable);
IntPtr readPipe = IntPtr.Zero;
IntPtr subProcessPipe = IntPtr.Zero;
if(!Native.CreatePipe(out readPipe, out subProcessPipe,ref sa, 0x0001))
{
throw new Exception("createpipe gave error: " + Marshal.GetLastWin32Error());
}
log.InfoFormat("pipe created");
Task readPipeTask = Task.Factory.StartNew(() =>
{
log.InfoFormat("startingtask");
var readBuff = new byte[BufferSize];
uint bytesRead = 0;
bool retval;
while (true)
{
retval = Native.ReadFile(readPipe, readBuff, BufferSize, out bytesRead, IntPtr.Zero);
if (!retval || bytesRead == 0)
{
log.InfoFormat("finalread {0} {1}", retval, bytesRead);
break;
}
log.InfoFormat("after read {0} {1}", retval, bytesRead);
}
log.InfoFormat("endingtask");
});
var processInfo = new Native.ProcessInformation();
var startInfo = new Native.StartupInfo();
startInfo.Size = Marshal.SizeOf(startInfo);
//startInfo.StdOutput = pipeServer.SafePipeHandle.DangerousGetHandle();
startInfo.StdOutput = subProcessPipe;
log.InfoFormat("calling createprocess");
if (!Native.CreateProcessAsUser(
UserTokenHandle,
null,
command,
IntPtr.Zero,
IntPtr.Zero,
false,
0x00000020 | 0x00000010 | 0x00000400,
IntPtr.Zero,
null,
ref startInfo,
out processInfo))
{
throw new Exception("Create process didn't work : " + Marshal.GetLastWin32Error());
}
log.InfoFormat("process id = {0}", processInfo.ProcessId);
int processId = processInfo.ProcessId;
using (var process = Process.GetProcessById(processId))
{
var pid = process.Id;
log.Info("process started : " + pid);
process.WaitForExit(ProcessTimeoutIteration);
log.Info("process Completed");
readPipeTask.Wait();
log.Info("process Completedafter wait");
}
////log.Info("reading pipe canread = " + pipeServer.CanRead);
////log.Info("reading pipe isconnected = " + pipeServer.IsConnected);
var standardOutput = new StringBuilder(InitialBufferSize);
//////var readBuff = new byte[BufferSize];
//var ac = new AsyncCallback(CallBackMethod);
////var bytesRead = pipeServer.Read(readBuff, 0, BufferSize);
log.Info("before first read");
////while (bytesRead > 0)
////{
//// //fileStream.Write(readBuff, 0, bytesRead);
//// standardOutput.Append(Encoding.Unicode.GetString(readBuff));
//// bytesRead = pipeServer.Read(readBuff, 0, BufferSize);
////}
原因很明显:
if (!Native.CreateProcessAsUser(
UserTokenHandle,
null,
command,
IntPtr.Zero,
IntPtr.Zero,
false,
0x00000020 | 0x00000010 | 0x00000400,
不是通过将bInheritHandles
设置为 false 来继承句柄。