windows - 如何判断 ReadFileEx() 重叠 I/O 何时完成？

Question

HasOverlappedIoCompleted()不适用于以 ReadFileEx() 开头的异步 I/O和 WriteFileEx() .底部的代码片段演示了这一点。在此示例中，ReadFileEx() 从没有输入的管道中读取数据，因此读取不会完成。但是 HasOverlappedIoCompleted() 返回 TRUE。如果我将调用更改为重叠的 ReadFile()，则 HasOverlappedIoCompleted() 会按预期返回 FALSE。

我的问题是:如何在不依赖回调本身的情况下，找出带有回调的重叠 I/O 请求是否已完成？在我的应用程序中，APC 可能已经排队，但不一定已经运行，因为应用程序可能尚未处于可警报状态。

谢谢。

(注意 GetOverlappedResult() 没有帮助 - 它也返回 TRUE。)

更多背景知识:在示例中，我使用了 ReadFileEx()，因为它很容易演示问题。在我的应用程序中，我在管道实例上重复调用 WriteFileEx()。如果之前的 WriteFileEx() 尚未完成，我必须丢弃消息而不是发送消息(我不能在同一个管道实例上有多个待处理的写入)，但是如果前一个 WriteFileEx() 已经 完成，那么我必须开始下一个，即使完成回调还没有运行.

编辑:问题场景的描述

1. 线程进入可警报状态(有一个读取 APC 排队)。
2. 读取 APC 开始:它对 WriteFileEx() 进行排队并设置“写入挂起”标志。然后它将 ReadFileEx() 排队。
3. 主线程开始工作(不可警报)。
4. 排队的读取完成。
5. 排队的写入完成(在读取之后)。
6. 主线程进入警报状态。
7. 读取的 APC 在队列中排在第一位，因此首先运行:它查看“写入挂起”标志，因为它仍处于设置状态，所以它会丢弃写入。事实上，虽然 WriteFileEx() 已经 完成，但它还没有调用它的 APC，因为 ReadFileEx() 先完成了。

我不想测试我自定义的“写入挂起”标志，而是想从操作系统中找出 WriteFileEx() 是否已实际完成，即使 APC 尚未运行也是如此。

---

#include <Windows.h>
#include <stdio.h>
#include <assert.h>

VOID CALLBACK readComplete(DWORD err, DWORD bytes, LPOVERLAPPED ovlp)
{
}

int main(int argc, char *argv[])
{
  HANDLE     hServer;
  OVERLAPPED serverOvlp = { 0 };
  HANDLE     hClient;
  DWORD      bytes;
  BYTE       buffer[16];
  BOOL       result;

  hServer = CreateNamedPipe("\\\\.\\pipe\\testpipe", PIPE_ACCESS_DUPLEX | FILE_FLAG_OVERLAPPED,
                            PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT, 
                            PIPE_UNLIMITED_INSTANCES, 0, 0, 5000, NULL);

  serverOvlp.hEvent = CreateEvent(NULL, FALSE, FALSE, NULL);

  ConnectNamedPipe(hServer, &serverOvlp);
  assert(GetLastError() == ERROR_IO_PENDING);

  hClient = CreateFile("\\\\.\\pipe\\testpipe", GENERIC_READ | GENERIC_WRITE,
                       0, NULL, OPEN_EXISTING, 0, NULL);

  GetOverlappedResult(hServer, &serverOvlp, &bytes, TRUE);

  /* Server starts an overlapped read */
//  result = ReadFile(hServer, buffer, sizeof(buffer), &bytes, &serverOvlp);
  result = ReadFileEx(hServer, buffer, sizeof(buffer), &serverOvlp, readComplete);

  if (HasOverlappedIoCompleted(&serverOvlp))
  {
    puts("Completed");
  }
  else
  {
    puts("Not completed");
  }


  return EXIT_SUCCESS;
}

Answer 1

你要求的行为对我来说似乎是错误的，因为它涉及竞争条件。仅当您仍在发送消息 B 时收到消息 A 时才会出现此问题。目前，A 始终被忽略，即不发送其他消息。当且仅当服务器在 A 到达和 B 完成之间的时间间隔内忙于处理工作时，您尝试获得的行为才会导致发送额外的消息。我认为您应该始终忽略 A，或者始终在 B 完成后发送响应。

但是，如果您确定这是您想要的，则可以实现此行为。一种解决方案是从 ReadFileEx 完成例程调用 QueueUserAPC，将对发送回复的函数的调用排队。由于APC是按照先进先出的顺序运行的，新的APC肯定会在WriteFileEx已经排队的APC之后运行。

根据细节，设置标志或将项目添加到队列并让您的主循环执行实际工作的两个完成例程可能更清晰。

如果您需要轮询 APC(例如，因为您的主循环没有任何自然发生的等待操作)，您可以在超时为 0 的虚拟事件上使用 WaitForSingleObjectEx。事件是否发生并不重要无论是否发出信号，所有排队的 APC 仍将被调用。