mirrors/Cemu
0
0
Fork 0
mirror of https://github.com/cemu-project/Cemu.git synced 2025-12-29 07:37:03 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

TCL: make tclRingBufferA_writeIndex atomic & refactor

Browse source
This commit is contained in:
SSimco 2025-12-19 04:17:48 +02:00
parent a87bded17d
commit 3746f018c3
1 changed files with 19 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

30
src/Cafe/OS/libs/TCL/TCL.cpp
View file

@ -66,26 +66,30 @@ namespace TCL
std::atomic<uint32> tclRingBufferA[TCL_RING_BUFFER_SIZE];
std::atomic<uint32> tclRingBufferA_readIndex{0};
uint32 tclRingBufferA_writeIndex{0};
std::atomic<uint32> tclRingBufferA_writeIndex{0};
// GPU code calls this to grab the next command word
bool TCLGPUReadRBWord(uint32& cmdWord)
{
if (tclRingBufferA_readIndex == tclRingBufferA_writeIndex)
uint32 readIndex = tclRingBufferA_readIndex.load(std::memory_order::relaxed);
uint32 writeIndex = tclRingBufferA_writeIndex.load(std::memory_order::acquire);
if (readIndex == writeIndex)
return false;
cmdWord = tclRingBufferA[tclRingBufferA_readIndex];
tclRingBufferA_readIndex = (tclRingBufferA_readIndex+1) % TCL_RING_BUFFER_SIZE;
cmdWord = tclRingBufferA[readIndex].load(std::memory_order::relaxed);
tclRingBufferA_readIndex.store((readIndex + 1) % TCL_RING_BUFFER_SIZE, std::memory_order::release);
return true;
}
void TCLWaitForRBSpace(uint32be numU32s)
{
while ( true )
uint32 writeIndex = tclRingBufferA_writeIndex.load(std::memory_order::relaxed);
while (true)
{
uint32 distance = (tclRingBufferA_readIndex + TCL_RING_BUFFER_SIZE - tclRingBufferA_writeIndex) & (TCL_RING_BUFFER_SIZE - 1);
if (tclRingBufferA_writeIndex == tclRingBufferA_readIndex) // buffer completely empty
uint32 readIndex = tclRingBufferA_readIndex.load(std::memory_order::acquire);
uint32 distance = (readIndex + TCL_RING_BUFFER_SIZE - writeIndex) & (TCL_RING_BUFFER_SIZE - 1);
if (writeIndex == readIndex) // buffer completely empty
distance = TCL_RING_BUFFER_SIZE;
if (distance >= numU32s+1) // assume distance minus one, because we are never allowed to completely wrap around
if (distance >= numU32s + 1) // assume distance minus one, because we are never allowed to completely wrap around
break;
_mm_pause();
}
@ -94,14 +98,18 @@ namespace TCL
// this function assumes that TCLWaitForRBSpace was called and that there is enough space
void TCLWriteCmd(uint32be* cmd, uint32 cmdLen)
{
uint32 writeIndex = tclRingBufferA_writeIndex.load(std::memory_order::relaxed);
while (cmdLen > 0)
{
tclRingBufferA[tclRingBufferA_writeIndex] = *cmd;
tclRingBufferA_writeIndex++;
tclRingBufferA_writeIndex &= (TCL_RING_BUFFER_SIZE - 1);
tclRingBufferA[writeIndex].store(*cmd, std::memory_order::relaxed);
writeIndex++;
writeIndex &= (TCL_RING_BUFFER_SIZE - 1);
cmd++;
cmdLen--;
}
tclRingBufferA_writeIndex.store(writeIndex, std::memory_order::release);
}
#define EVENT_TYPE_TS 5