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);
            ////}

Rediredting stdout for createprocessasuser to pipe 挂起读取

原因很明显:

if (!Native.CreateProcessAsUser(
                UserTokenHandle,
                null,
                command,
                IntPtr.Zero,
                IntPtr.Zero,
                false,
                0x00000020 | 0x00000010 | 0x00000400,

不是通过将bInheritHandles设置为 false 来继承句柄。