Method exec

ps3fw/cellAdec.cpp:304–787

vm::gvar<CellAdecCoreOps> g_cell_adec_core_ops_lpcm;

void LpcmDecContext::exec(ppu_thread& ppu)
{
	perf_meter<"LPCMDEC"_u64> perf0;

	switch (savestate)
	{
	case lpcm_dec_state::waiting_for_cmd_mutex_lock: break;
	case lpcm_dec_state::waiting_for_cmd_cond_wait: break;
	case lpcm_dec_state::waiting_for_output_mutex_lock: goto output_mutex_lock;
	case lpcm_dec_state::waiting_for_output_cond_wait: goto output_cond_wait;
	case lpcm_dec_state::queue_mutex_lock: goto queue_mutex_lock;
	case lpcm_dec_state::executing_cmd: goto execute_cmd;
	}

	for (; run_thread; cmd_counter++)
	{
		cellAdec.trace("Command counter: %llu, waiting for next command...", cmd_counter);

		// Wait for a command to become available
		error_occurred |= static_cast<u32>(cmd_available.acquire(ppu, savestate) != CELL_OK);

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

		cellAdec.trace("Command available, waiting for output to be consumed...");

		// Wait for the output to be consumed.
		// The output has to be consumed even if the next command is not a decode command
		savestate = lpcm_dec_state::waiting_for_output_mutex_lock;
	output_mutex_lock:

		error_occurred |= static_cast<u32>(sys_mutex_lock(ppu, output_mutex, 0) != CELL_OK);

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

		while (output_locked)
		{
			savestate = lpcm_dec_state::waiting_for_output_cond_wait;
		output_cond_wait:

			ensure(sys_cond_wait(ppu, output_consumed, 0) == CELL_OK); // Error code isn't checked on LLE

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

		cellAdec.trace("Output consumed");

		// Pop command from queue
		savestate = lpcm_dec_state::queue_mutex_lock;
	queue_mutex_lock: