文章/答案/技术大牛

发布

社区首页 >问答首页 >基于重叠IO的异步命名Windows管道通信

问基于重叠IO的异步命名Windows管道通信
EN

Stack Overflow用户

提问于 2017-03-24 13:12:47

回答 1查看 973关注 0票数 0

我使用重叠IO在C代码中同时读写单个Windows管道。我想要写一个同步函数来从分离的线程中读取和写入数据。如果使用同步IO，则不能同时读写管道。我的客户端和我的服务器正在使用相同的写/读功能。我的客户端不时地发送服务器从未接收到的数据。有人知道怎么会发生这种事吗？如果我在客户端中使用同步IO，一切都按预期的方式工作。

以下cmd打开服务器管道：

CreateNamedPipe(pipeName, PIPE_ACCESS_DUPLEX | FILE_FLAG_OVERLAPPED, PIPE_TYPE_BYTE | PIPE_READMODE_BYTE | PIPE_WAIT,
                                      instances, PIPE_BUF_SIZE, PIPE_BUF_SIZE, 0, NULL);

客户端管道是这样打开的：

CreateFile(pipeName, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_FLAG_OVERLAPPED, NULL);

我正在使用以下读取函数：

int readBytesPipeCommChannel(PipeCommChannelData* comm, uint32_t* amount)
    OVERLAPPED osRead;
    memset(&osRead, 0, sizeof(osRead));  
    osRead.hEvent = comm->readAsyncIOEvent;

    int err = 0;
    if(!ReadFile(comm->pipeH, comm->receiveBuffer, sizeof(comm->receiveBuffer), amount, &osRead))
    {   
        err = GetLastError();     
        if (err == ERROR_IO_PENDING)
        {
            if(WaitForSingleObject(osRead.hEvent, INFINITE))
            {
                GetOverlappedResult(comm->pipeH, &osRead, amount, TRUE);
            }
            else
            {
                CancelIo(comm->pipeH);
                return PIPE_EVENT_ERROR;
            }
        }
        else if(err != ERROR_BROKEN_PIPE)
        {
            return PIPE_READ_ERROR;
        }
    }
    if(err == ERROR_BROKEN_PIPE)
        return PIPE_BROKEN_ERR;

    return PIPE_OK;
}

最后但并非最不重要的是写函数：

int sendBytesPipeCommChannel(PipeCommChannelData* comm, const uint8_t* bytes, uint32_t amount)
{
    OVERLAPPED osWrite;
    memset(&osWrite, 0, sizeof(osWrite));  
    osWrite.hEvent = comm->writeAsyncIOEvent;

    uint32_t bytesWritten = 0; 
    for(uint32_t curPos = 0; curPos < amount; curPos += bytesWritten)
    {
        if(!WriteFile(comm->pipeH, &bytes[curPos], (amount - curPos), &bytesWritten, &osWrite))
        {
            if (GetLastError() != ERROR_IO_PENDING)
                return PIPE_WRITE_ERR; 

            if(!WaitForSingleObject(osWrite.hEvent, INFINITE))
            {
                CancelIo(comm->pipeH);
                return PIPE_EVENT_ERROR;
            }
        }
    }
    return PIPE_OK;
}

client-server

ipc

windows

pipe

回答 1

Stack Overflow用户

回答已采纳

发布于 2017-03-24 16:39:18

ReadFile的文档说：

如果hFile是用FILE_FLAG_OVERLAPPED打开的，则以下条件生效： lpNumberOfBytesRead参数应该设置为NULL。使用GetOverlappedResult函数获取实际读取的字节数。

即使操作同步完成，这也是适用的。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/43000424

复制

相似问题

问基于重叠IO的异步命名Windows管道通信
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问基于重叠IO的异步命名Windows管道通信EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问基于重叠IO的异步命名Windows管道通信
EN