pcsx2/pcsx2/MTVU.h

124 lines
3.2 KiB
C++

// SPDX-FileCopyrightText: 2002-2024 PCSX2 Dev Team
// SPDX-License-Identifier: GPL-3.0+
#pragma once
#include "common/Threading.h"
#include "Vif.h"
#include "Vif_Dma.h"
#include "VUmicro.h"
#include <thread>
#define MTVU_LOG(...) do{} while(0)
//#define MTVU_LOG DevCon.WriteLn
// Notes:
// - This class should only be accessed from the EE thread...
// - buffer_size must be power of 2
// - ring-buffer has no complete pending packets when read_pos==write_pos
class VU_Thread final {
static const s32 buffer_size = (_1mb * 16) / sizeof(s32);
u32 buffer[buffer_size];
// Note: keep atomic on separate cache line to avoid CPU conflict
alignas(__cachelinesize) std::atomic<int> m_ato_read_pos; // Only modified by VU thread
alignas(__cachelinesize) std::atomic<int> m_ato_write_pos; // Only modified by EE thread
alignas(__cachelinesize) int m_read_pos; // temporary read pos (local to the VU thread)
int m_write_pos; // temporary write pos (local to the EE thread)
Threading::WorkSema semaEvent;
std::atomic_bool m_shutdown_flag{false};
Threading::Thread m_thread;
public:
alignas(16) vifStruct vif;
alignas(16) VIFregisters vifRegs;
Threading::UserspaceSemaphore semaXGkick;
std::atomic<unsigned int> vuCycles[4]; // Used for VU cycle stealing hack
u32 vuCycleIdx; // Used for VU cycle stealing hack
u32 vuFBRST;
enum InterruptFlag {
InterruptFlagFinish = 1 << 0,
InterruptFlagSignal = 1 << 1,
InterruptFlagLabel = 1 << 2,
InterruptFlagVUEBit = 1 << 3,
InterruptFlagVUTBit = 1 << 4,
};
std::atomic<u32> mtvuInterrupts; // Used for GS Signal, Finish etc, plus VU End/T-Bit
std::atomic<u64> gsLabel; // Used for GS Label command
std::atomic<u64> gsSignal; // Used for GS Signal command
VU_Thread();
~VU_Thread();
__fi const Threading::ThreadHandle& GetThreadHandle() const { return m_thread; }
/// Returns true if the VU thread has been started.
__fi bool IsOpen() const { return m_thread.Joinable(); }
/// Ensures the VU thread is started.
void Open();
/// Shuts down the VU thread if it is currently running.
void Close();
void Reset();
// Get MTVU to start processing its packets if it isn't already
void KickStart();
// Used for assertions...
bool IsDone();
// Waits till MTVU is done processing
void WaitVU();
void Get_MTVUChanges();
void ExecuteVU(u32 vu_addr, u32 vif_top, u32 vif_itop, u32 fbrst);
void VifUnpack(vifStruct& _vif, VIFregisters& _vifRegs, const u8* data, u32 size);
// Writes to VU's Micro Memory (size in bytes)
void WriteMicroMem(u32 vu_micro_addr, const void* data, u32 size);
// Writes to VU's Data Memory (size in bytes)
void WriteDataMem(u32 vu_data_addr, const void* data, u32 size);
void WriteVIRegs(REG_VI* viRegs);
void WriteVFRegs(VECTOR* vfRegs);
void WriteCol(vifStruct& _vif);
void WriteRow(vifStruct& _vif);
private:
void ExecuteRingBuffer();
void WaitOnSize(s32 size);
void ReserveSpace(s32 size);
s32 GetReadPos();
s32 GetWritePos();
u32* GetWritePtr();
void CommitWritePos();
void CommitReadPos();
u32 Read();
void Read(void* dest, u32 size);
void ReadRegs(VIFregisters* dest);
void Write(u32 val);
void Write(const void* src, u32 size);
void WriteRegs(VIFregisters* src);
u32 Get_vuCycles();
};
extern VU_Thread vu1Thread;