Method notify

kernel/orbis/src/evf.cpp:121–156

}

std::size_t orbis::EventFlag::notify(NotifyType type, std::uint64_t bits) {
  rx::writer_lock lock(queueMtx);
  auto patValue = value.load(std::memory_order::relaxed);

  if (type == NotifyType::Destroy) {
    isDeleted = true;
  } else if (type == NotifyType::Set) {
    patValue |= bits;
  }

  auto testThread = [&](WaitingThread *thread) {
    if (type == NotifyType::Set && !thread->test(patValue)) {
      return false;
    }

    auto resultValue = thread->applyClear(patValue);
    thread->thread->evfResultPattern = patValue;
    thread->thread->evfIsCancelled = type == NotifyType::Cancel;
    patValue = resultValue;

    // TODO: update thread state
    // release wait on waiter thread
    thread->thread->sync_cv.notify_all(queueMtx);
    return true;
  };

  std::size_t result = std::erase_if(
      waitingThreads, [&](auto &thread) { return testThread(&thread); });

  if (type == NotifyType::Cancel) {
    value.store(bits, std::memory_order::relaxed);
  } else {
    value.store(patValue, std::memory_order::relaxed);
  }
  return result;
}