Function check_and_handle_completion

src/windows/libwinio.cpp:230–268

Function to handle all IOCP notifications. Returns true if the IOCP loop should continue and false if it should stop.

// Function to handle all IOCP notifications. Returns true if the IOCP loop
// should continue and false if it should stop.
static bool check_and_handle_completion(const OVERLAPPED_ENTRY& entry)
{
  switch (entry.lpCompletionKey) {
    case KEY_QUIT: {
      return false;
    }
    case KEY_TIMER: {
      // In the IOCP, we just set the timer. When the timer completes, it will
      // queue up an APC that will interrupt the IOCP loop in order to execute
      // the APC callback.
      TimerOverlapped* timer =
        reinterpret_cast<TimerOverlapped*>(entry.lpOverlapped);

      const BOOL success = ::SetWaitableTimer(
          timer->timer, &timer->time, 0, &timer_apc, timer, TRUE);

      if (!success) {
        // Nothing we can really do here aside from log the event.
        std::string errorMsg = WindowsError().message;
        LOG(FATAL)
          << "process::windows::handle_completion failed to set timer: "
          << errorMsg;
      }
      return true;
    }
    case KEY_IO: {
      if (entry.lpOverlapped == nullptr) {
        // Don't know if this is possible, but just log it in case.
        LOG(FATAL) << "process::windows::handle_completion returned with a null"
                   << "overlapped object";
      } else {
        handle_io(entry.lpOverlapped, entry.dwNumberOfBytesTransferred);
      }
      return true;
    }
  }

  UNREACHABLE();
}


// Windows Event loop implementation.