Function sys_mutex_lock

kernel/cellos/src/sys_mutex.cpp:135–275

}

error_code sys_mutex_lock(ppu_thread &ppu, u32 mutex_id, u64 timeout) {
  ppu.state += cpu_flag::wait;

  sys_mutex.trace("sys_mutex_lock(mutex_id=0x%x, timeout=0x%llx)", mutex_id,
                  timeout);

  const auto mutex = idm::get<lv2_obj, lv2_mutex>(
      mutex_id, [&, notify = lv2_obj::notify_all_t()](lv2_mutex &mutex) {
        CellError result = mutex.try_lock(ppu);

        if (result == CELL_EBUSY &&
            !atomic_storage<ppu_thread *>::load(mutex.control.raw().sq)) {
          // Try busy waiting a bit if advantageous
          for (u32 i = 0, end = lv2_obj::has_ppus_in_running_state() ? 3 : 10;
               id_manager::g_mutex.is_lockable() && i < end; i++) {
            rx::busy_wait(300);
            result = mutex.try_lock(ppu);

            if (!result ||
                atomic_storage<ppu_thread *>::load(mutex.control.raw().sq)) {
              break;
            }
          }
        }

        if (result == CELL_EBUSY) {
          lv2_obj::prepare_for_sleep(ppu);

          ppu.cancel_sleep = 1;

          if (mutex.try_own(ppu) || !mutex.sleep(ppu, timeout)) {
            result = {};
          }

          if (ppu.cancel_sleep != 1) {
            notify.cleanup();
          }

          ppu.cancel_sleep = 0;
        }

        return result;
      });

  if (!mutex) {
    return CELL_ESRCH;
  }

  if (mutex.ret) {
    if (mutex.ret != CELL_EBUSY) {
      return mutex.ret;
    }
  } else {
    return CELL_OK;
  }

  ppu.gpr[3] = CELL_OK;