Function sys_ppu_thread_join

kernel/cellos/src/sys_ppu_thread.cpp:173–252

}

error_code sys_ppu_thread_join(ppu_thread &ppu, u32 thread_id,
                               vm::ptr<u64> vptr) {
  lv2_obj::prepare_for_sleep(ppu);

  sys_ppu_thread.trace("sys_ppu_thread_join(thread_id=0x%x, vptr=*0x%x)",
                       thread_id, vptr);

  if (thread_id == ppu.id) {
    return CELL_EDEADLK;
  }

  auto thread = idm::get<named_thread<ppu_thread>>(
      thread_id,
      [&, notify = lv2_obj::notify_all_t()](ppu_thread &thread) -> CellError {
        CellError result =
            thread.joiner.atomic_op([&](ppu_join_status &value) -> CellError {
              switch (value) {
              case ppu_join_status::joinable:
                value = ppu_join_status{ppu.id};
                return {};
              case ppu_join_status::zombie:
                value = ppu_join_status::exited;
                return CELL_EAGAIN;
              case ppu_join_status::exited:
                return CELL_ESRCH;
              case ppu_join_status::detached:
              default:
                return CELL_EINVAL;
              }
            });

        if (!result) {
          lv2_obj::prepare_for_sleep(ppu);
          lv2_obj::sleep(ppu);
        }

        notify.cleanup();
        return result;
      });

  if (!thread) {
    return CELL_ESRCH;
  }

  if (thread.ret && thread.ret != CELL_EAGAIN) {
    return thread.ret;
  }

  if (thread.ret == CELL_EAGAIN) {
    // Notify thread if waiting for a joiner
    thread->joiner.notify_one();
  }

  // Wait for cleanup
  (*thread.ptr)();

  if (thread->joiner != ppu_join_status::exited) {
    // Thread aborted, log it later