archive/rpcs3
1
0
Fork 0
mirror of https://github.com/RPCS3/rpcs3.git synced 2025-07-15 19:28:43 +12:00
Code Issues Projects Releases Packages Wiki Activity Actions

cellVdec: fix minor race

Browse source
This commit is contained in:
Nekotekina 2019-01-14 00:03:43 +03:00
parent a419e98acb
commit c5026f7109
1 changed files with 11 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

13
rpcs3/Emu/Cell/Modules/cellVdec.cpp
View file

@ -378,7 +378,7 @@ struct vdec_context final
while (!Emu.IsStopped() && out_max && (std::lock_guard{mutex}, out.size() > out_max)) while (!Emu.IsStopped() && out_max && (std::lock_guard{mutex}, out.size() > out_max))
{ {
in_cv.wait(cv_lock, 1000); thread_ctrl::wait_for(1000);
} }
} }
else if (auto* frc = std::get_if<CellVdecFrameRate>(&*cmds)) else if (auto* frc = std::get_if<CellVdecFrameRate>(&*cmds))
@ -487,6 +487,12 @@ s32 cellVdecClose(ppu_thread& ppu, u32 handle)
vdec->out_max = 0; vdec->out_max = 0;
vdec->in_cmd.push(vdec_close); vdec->in_cmd.push(vdec_close);
vdec->in_cv.notify(); vdec->in_cv.notify();
while (!atomic_storage<u64>::load(vdec->ppu_tid))
{
thread_ctrl::wait_for(1000);
}
ppu_execute<&sys_interrupt_thread_disestablish>(ppu, vdec->ppu_tid); ppu_execute<&sys_interrupt_thread_disestablish>(ppu, vdec->ppu_tid);
return CELL_OK; return CELL_OK;
} }
@ -574,7 +580,10 @@ s32 cellVdecGetPicture(u32 handle, vm::cptr<CellVdecPicFormat> format, vm::ptr<u
} }
if (notify) if (notify)
vdec->in_cv.notify(); {
auto vdec_ppu = idm::get<named_thread<ppu_thread>>(vdec->ppu_tid);
thread_ctrl::notify(*vdec_ppu);
}
if (outBuff) if (outBuff)
{ {