Function sys_event_queue_destroy

kernel/cellos/src/sys_event.cpp:228–345

}

error_code sys_event_queue_destroy(ppu_thread &ppu, u32 equeue_id, s32 mode) {
  ppu.state += cpu_flag::wait;

  sys_event.warning("sys_event_queue_destroy(equeue_id=0x%x, mode=%d)",
                    equeue_id, mode);

  if (mode && mode != SYS_EVENT_QUEUE_DESTROY_FORCE) {
    return CELL_EINVAL;
  }

  std::vector<lv2_event> events;

  std::unique_lock<shared_mutex> qlock;

  cpu_thread *head{};

  const auto queue = idm::withdraw<lv2_obj, lv2_event_queue>(
      equeue_id, [&](lv2_event_queue &queue) -> CellError {
        qlock = std::unique_lock{queue.mutex};

        head = queue.type == SYS_PPU_QUEUE
                   ? static_cast<cpu_thread *>(+queue.pq)
                   : +queue.sq;

        if (!mode && head) {
          return CELL_EBUSY;
        }

        if (!queue.events.empty()) {
          // Copy events for logging, does not empty
          events.insert(events.begin(), queue.events.begin(),
                        queue.events.end());
        }

        lv2_obj::on_id_destroy(queue, queue.key);

        if (!head) {
          qlock.unlock();
        } else {
          for (auto cpu = head; cpu; cpu = cpu->get_next_cpu()) {
            if (cpu->state & cpu_flag::again) {
              ppu.state += cpu_flag::again;
              return CELL_EAGAIN;
            }
          }
        }

        return {};
      });

  if (!queue) {
    return CELL_ESRCH;
  }

  if (ppu.state & cpu_flag::again) {
    return {};
  }