0

我正在尝试读取stderr子进程。数据是使用创建的文本行sprintf(stderr, "some debug info\n")。我将ReadFileEx 与完成例程一起使用。我不知道有多少行文本或每行有多长。那么，我应该把什么作为nNumberOfBytesToRead参数？

我的猜测是我将缓冲区的最大大小设置为 4k；虽然我不知道这是否是最佳尺寸。我猜如果写入的行stderr短于 4k，完成例程将不会触发。我猜当达到 4k 但仍有更多数据时，我必须ReadFileEx在完成例程中启动另一个。我会知道是这种情况，因为GetLastError会返回ERROR_MORE_DATA。我希望在缓冲区未满时接到电话，但子进程已退出。我不确定子进程退出时是否会收到完成回调，因为我在stderr创建子进程时将写句柄传递给了子进程；也许当我关闭该句柄时我会收到回调。wrtstderr?

这是如何创建进程和句柄的伪代码：

Attr.bInheritHandle = true
CreatePipe(&hr, &hw, &Attr, 0) and SetHandleInformation(hX, HANDLE_FLAG_INHERIT) on hX the child uses.
Si.hStdXXX = handles from CreatePipe that child uses
CreateProcess(inherit=true, &Si)

详细信息（Tx 扩展是一个抛出错误的包装器）：

HANDLE Create() {
    STARTUPINFO SI, *pSI = NULL;
    bool fInherit = m_fInherit;
    if (m_fStdOut || m_fStdIn || m_fStdErr) {
        fInherit = true;
        SECURITY_ATTRIBUTES Attr;
        Attr.nLength = sizeof(SECURITY_ATTRIBUTES); 
        Attr.bInheritHandle = TRUE; 
        Attr.lpSecurityDescriptor = NULL;
        if (m_fStdOut) // Create a pipe for the child process's STDOUT. The child will use the write.
            CHandle::CreatePipe(m_hStdOutR, m_hStdOutW, &Attr, CP_INHERIT_WRITE);
        if (m_fStdErr) // Create a pipe for the child process's STDERR. The child will use the write.
            CHandle::CreatePipe(m_hStdErrR, m_hStdErrW, &Attr, CP_INHERIT_WRITE);
        if (m_fStdIn) // Create a pipe for the child process's STDIN. The child will use the read.
            CHandle::CreatePipe(m_hStdInR, m_hStdInW, &Attr, CP_INHERIT_READ);
        // Set up members of the STARTUPINFO structure. 
        // This structure specifies the STDIN and STDOUT handles for redirection.
        ZeroStruct(SI);
        SI.cb = sizeof(STARTUPINFO); 
        SI.hStdError = m_hStdErrW, SI.hStdOutput = m_hStdOutW, SI.hStdInput = m_hStdInR;
        SI.dwFlags |= STARTF_USESTDHANDLES;
        pSI = &SI;
    }
    //  m_fCpu, m_fNuma are masks to set affinity to cpus or numas
    CreateProcessTx(NULL, m_szCmdLine, fInherit, m_fFlags, pSI, &m_pi, m_fCpu, m_fNuma, 5);
    m_hProc = m_pi.hProcess;
    m_hThread = m_pi.hThread;
    if (!m_fThread)
        m_hThread.Close();
    return m_hProc;
}

static void CreatePipe(CHandle &hRead, CHandle &hWrite, SECURITY_ATTRIBUTES* pAttr, BYTE fInheritMask) {
    HANDLE hReadTmp = NULL, hWriteTmp = NULL;
    CreatePipeTx(hReadTmp, hWriteTmp, pAttr);
    SetHandleInformation(hReadTmp, HANDLE_FLAG_INHERIT, (fInheritMask&CP_INHERIT_READ) ? HANDLE_FLAG_INHERIT : 0); 
    SetHandleInformation(hWriteTmp, HANDLE_FLAG_INHERIT, (fInheritMask&CP_INHERIT_WRITE) ? HANDLE_FLAG_INHERIT : 0);
    hRead = hReadTmp;
    hWrite = hWriteTmp;
}
4

1 回答 1

2

创建的匿名管道CreatePipe无法异步使用从 Windows SDK 文档：

匿名管道不支持异步（重叠）读写操作。这意味着您不能将 ReadFileEx 和 WriteFileEx 函数用于匿名管道。>此外，当这些函数与匿名管道一起使用时，会忽略 ReadFile 和 WriteFile 的 lpOverlapped 参数。

基本上CreatePipe不接受FILE_FLAG_OVERLAPPED标志，并且异步 I/O 要求您在创建文件句柄时使用标志。

您必须使用CreateNamedPipe来创建命名管道。匿名管道上的 Overlapped I/O问题的答案带有指向MyCreatePipeEx您可以使用的替换函数的链接。

在尝试从另一端已关闭的管道中读取数据后，您的完成端口应收到零长度读取事件。

要从客户端进程读取可变数量的数据，只需发出您认为方便的任何大小的读取请求，并准备处理比您请求的时间短的读取事件。不要将短但非零的长度解释为 EOF。继续发出读取请求，直到您获得零长度读取或错误。

WaitForMultipleObjects也不适用于完成例程，因为它们仅在线程处于可更改状态时调用。WaitForMultipleObjectEx与bAlertable设置为 true 的参数一起使用。此函数将WAIT_IO_COMPLETION在运行一个或多个完成例程后返回。在这种情况下，您可能想立即WaitForMultipleObjectEx再次致电。

于 2014-07-23T19:01:05.907 回答