1594 lines
45 KiB
C++
1594 lines
45 KiB
C++
// Copyright 2009 Dolphin Emulator Project
|
|
// Licensed under GPLv2+
|
|
// Refer to the license.txt file included.
|
|
|
|
#include "Core/Movie.h"
|
|
|
|
#include <algorithm>
|
|
#include <array>
|
|
#include <cctype>
|
|
#include <iterator>
|
|
#include <mbedtls/config.h>
|
|
#include <mbedtls/md.h>
|
|
#include <mutex>
|
|
#include <thread>
|
|
#include <utility>
|
|
#include <vector>
|
|
|
|
#include "Common/Assert.h"
|
|
#include "Common/ChunkFile.h"
|
|
#include "Common/CommonPaths.h"
|
|
#include "Common/FileUtil.h"
|
|
#include "Common/Hash.h"
|
|
#include "Common/NandPaths.h"
|
|
#include "Common/StringUtil.h"
|
|
#include "Common/Timer.h"
|
|
#include "Core/ConfigManager.h"
|
|
#include "Core/Core.h"
|
|
#include "Core/CoreTiming.h"
|
|
#include "Core/DSP/DSPCore.h"
|
|
#include "Core/HW/CPU.h"
|
|
#include "Core/HW/DVD/DVDInterface.h"
|
|
#include "Core/HW/EXI/EXI_DeviceIPL.h"
|
|
#include "Core/HW/ProcessorInterface.h"
|
|
#include "Core/HW/SI/SI.h"
|
|
#include "Core/HW/Wiimote.h"
|
|
#include "Core/HW/WiimoteCommon/WiimoteHid.h"
|
|
#include "Core/HW/WiimoteCommon/WiimoteReport.h"
|
|
#include "Core/HW/WiimoteEmu/WiimoteEmu.h"
|
|
#include "Core/IOS/USB/Bluetooth/BTEmu.h"
|
|
#include "Core/IOS/USB/Bluetooth/WiimoteDevice.h"
|
|
#include "Core/NetPlayProto.h"
|
|
#include "Core/PowerPC/PowerPC.h"
|
|
#include "Core/State.h"
|
|
#include "DiscIO/Enums.h"
|
|
#include "InputCommon/GCPadStatus.h"
|
|
#include "VideoCommon/Fifo.h"
|
|
#include "VideoCommon/VideoBackendBase.h"
|
|
#include "VideoCommon/VideoConfig.h"
|
|
|
|
// The chunk to allocate movie data in multiples of.
|
|
#define DTM_BASE_LENGTH (1024)
|
|
|
|
namespace Movie
|
|
{
|
|
static bool s_bFrameStep = false;
|
|
static bool s_bReadOnly = true;
|
|
static u32 s_rerecords = 0;
|
|
static PlayMode s_playMode = MODE_NONE;
|
|
|
|
static u8 s_controllers = 0;
|
|
static ControllerState s_padState;
|
|
static DTMHeader tmpHeader;
|
|
static u8* tmpInput = nullptr;
|
|
static size_t tmpInputAllocated = 0;
|
|
static u64 s_currentByte = 0, s_totalBytes = 0;
|
|
static u64 s_currentFrame = 0, s_totalFrames = 0; // VI
|
|
static u64 s_currentLagCount = 0;
|
|
static u64 s_totalLagCount = 0; // just stats
|
|
static u64 s_currentInputCount = 0, s_totalInputCount = 0; // just stats
|
|
static u64 s_totalTickCount = 0, s_tickCountAtLastInput = 0; // just stats
|
|
static u64 s_recordingStartTime; // seconds since 1970 that recording started
|
|
static bool s_bSaveConfig = false, s_bDualCore = false;
|
|
static bool s_bProgressive = false, s_bPAL60 = false;
|
|
static bool s_bDSPHLE = false, s_bFastDiscSpeed = false;
|
|
static bool s_bSyncGPU = false, s_bNetPlay = false;
|
|
static std::string s_videoBackend = "unknown";
|
|
static int s_iCPUCore = 1;
|
|
static bool s_bClearSave = false;
|
|
static bool s_bDiscChange = false;
|
|
static bool s_bReset = false;
|
|
static std::string s_author = "";
|
|
static std::string s_discChange = "";
|
|
static u8 s_MD5[16];
|
|
static u8 s_bongos, s_memcards;
|
|
static u8 s_revision[20];
|
|
static u32 s_DSPiromHash = 0;
|
|
static u32 s_DSPcoefHash = 0;
|
|
static u8 s_language = static_cast<u8>(DiscIO::Language::LANGUAGE_UNKNOWN);
|
|
|
|
static bool s_bRecordingFromSaveState = false;
|
|
static bool s_bPolled = false;
|
|
|
|
// s_InputDisplay is used by both CPU and GPU (is mutable).
|
|
static std::mutex s_input_display_lock;
|
|
static std::string s_InputDisplay[8];
|
|
|
|
static GCManipFunction s_gc_manip_func;
|
|
static WiiManipFunction s_wii_manip_func;
|
|
|
|
// NOTE: Host / CPU Thread
|
|
static void EnsureTmpInputSize(size_t bound)
|
|
{
|
|
if (tmpInputAllocated >= bound)
|
|
return;
|
|
// The buffer expands in powers of two of DTM_BASE_LENGTH
|
|
// (standard exponential buffer growth).
|
|
size_t newAlloc = DTM_BASE_LENGTH;
|
|
while (newAlloc < bound)
|
|
newAlloc *= 2;
|
|
|
|
u8* newTmpInput = new u8[newAlloc];
|
|
tmpInputAllocated = newAlloc;
|
|
if (tmpInput != nullptr)
|
|
{
|
|
if (s_totalBytes > 0)
|
|
memcpy(newTmpInput, tmpInput, (size_t)s_totalBytes);
|
|
delete[] tmpInput;
|
|
}
|
|
tmpInput = newTmpInput;
|
|
}
|
|
|
|
static bool IsMovieHeader(u8 magic[4])
|
|
{
|
|
return magic[0] == 'D' && magic[1] == 'T' && magic[2] == 'M' && magic[3] == 0x1A;
|
|
}
|
|
|
|
static std::array<u8, 20> ConvertGitRevisionToBytes(const std::string& revision)
|
|
{
|
|
std::array<u8, 20> revision_bytes{};
|
|
|
|
if (revision.size() % 2 == 0 && std::all_of(revision.begin(), revision.end(), ::isxdigit))
|
|
{
|
|
// The revision string normally contains a git commit hash,
|
|
// which is 40 hexadecimal digits long. In DTM files, each pair of
|
|
// hexadecimal digits is stored as one byte, for a total of 20 bytes.
|
|
size_t bytes_to_write = std::min(revision.size() / 2, revision_bytes.size());
|
|
unsigned int temp;
|
|
for (size_t i = 0; i < bytes_to_write; ++i)
|
|
{
|
|
sscanf(&revision[2 * i], "%02x", &temp);
|
|
revision_bytes[i] = temp;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
// If the revision string for some reason doesn't only contain hexadecimal digit
|
|
// pairs, we instead copy the string with no conversion. This probably doesn't match
|
|
// the intended design of the DTM format, but it's the most sensible fallback.
|
|
size_t bytes_to_write = std::min(revision.size(), revision_bytes.size());
|
|
std::copy_n(std::begin(revision), bytes_to_write, std::begin(revision_bytes));
|
|
}
|
|
|
|
return revision_bytes;
|
|
}
|
|
|
|
// NOTE: GPU Thread
|
|
std::string GetInputDisplay()
|
|
{
|
|
if (!IsMovieActive())
|
|
{
|
|
s_controllers = 0;
|
|
for (int i = 0; i < 4; ++i)
|
|
{
|
|
if (SerialInterface::GetDeviceType(i) != SerialInterface::SIDEVICE_NONE)
|
|
s_controllers |= (1 << i);
|
|
if (g_wiimote_sources[i] != WIIMOTE_SRC_NONE)
|
|
s_controllers |= (1 << (i + 4));
|
|
}
|
|
}
|
|
|
|
std::string input_display;
|
|
{
|
|
std::lock_guard<std::mutex> guard(s_input_display_lock);
|
|
for (int i = 0; i < 8; ++i)
|
|
{
|
|
if ((s_controllers & (1 << i)) != 0)
|
|
input_display += s_InputDisplay[i] + '\n';
|
|
}
|
|
}
|
|
return input_display;
|
|
}
|
|
|
|
// NOTE: GPU Thread
|
|
std::string GetRTCDisplay()
|
|
{
|
|
time_t current_time =
|
|
ExpansionInterface::CEXIIPL::GetEmulatedTime(ExpansionInterface::CEXIIPL::UNIX_EPOCH);
|
|
tm* gm_time = gmtime(¤t_time);
|
|
char buffer[256];
|
|
strftime(buffer, sizeof(buffer), "Date/Time: %c\n", gm_time);
|
|
std::stringstream format_time;
|
|
format_time << buffer;
|
|
return format_time.str();
|
|
}
|
|
|
|
// NOTE: GPU Thread
|
|
void FrameUpdate()
|
|
{
|
|
// TODO[comex]: This runs on the GPU thread, yet it messes with the CPU
|
|
// state directly. That's super sketchy.
|
|
s_currentFrame++;
|
|
if (!s_bPolled)
|
|
s_currentLagCount++;
|
|
|
|
if (IsRecordingInput())
|
|
{
|
|
s_totalFrames = s_currentFrame;
|
|
s_totalLagCount = s_currentLagCount;
|
|
}
|
|
if (s_bFrameStep)
|
|
{
|
|
s_bFrameStep = false;
|
|
CPU::Break();
|
|
}
|
|
|
|
s_bPolled = false;
|
|
}
|
|
|
|
// called when game is booting up, even if no movie is active,
|
|
// but potentially after BeginRecordingInput or PlayInput has been called.
|
|
// NOTE: EmuThread
|
|
void Init()
|
|
{
|
|
s_bPolled = false;
|
|
s_bFrameStep = false;
|
|
s_bSaveConfig = false;
|
|
s_iCPUCore = SConfig::GetInstance().iCPUCore;
|
|
if (IsPlayingInput())
|
|
{
|
|
ReadHeader();
|
|
std::thread md5thread(CheckMD5);
|
|
md5thread.detach();
|
|
if (strncmp(tmpHeader.gameID, SConfig::GetInstance().GetGameID().c_str(), 6))
|
|
{
|
|
PanicAlertT("The recorded game (%s) is not the same as the selected game (%s)",
|
|
tmpHeader.gameID, SConfig::GetInstance().GetGameID().c_str());
|
|
EndPlayInput(false);
|
|
}
|
|
}
|
|
|
|
if (IsRecordingInput())
|
|
{
|
|
GetSettings();
|
|
std::thread md5thread(GetMD5);
|
|
md5thread.detach();
|
|
s_tickCountAtLastInput = 0;
|
|
}
|
|
|
|
memset(&s_padState, 0, sizeof(s_padState));
|
|
if (!tmpHeader.bFromSaveState || !IsPlayingInput())
|
|
Core::SetStateFileName("");
|
|
|
|
for (auto& disp : s_InputDisplay)
|
|
disp.clear();
|
|
|
|
if (!IsMovieActive())
|
|
{
|
|
s_bRecordingFromSaveState = false;
|
|
s_rerecords = 0;
|
|
s_currentByte = 0;
|
|
s_currentFrame = 0;
|
|
s_currentLagCount = 0;
|
|
s_currentInputCount = 0;
|
|
}
|
|
}
|
|
|
|
// NOTE: CPU Thread
|
|
void InputUpdate()
|
|
{
|
|
s_currentInputCount++;
|
|
if (IsRecordingInput())
|
|
{
|
|
s_totalInputCount = s_currentInputCount;
|
|
s_totalTickCount += CoreTiming::GetTicks() - s_tickCountAtLastInput;
|
|
s_tickCountAtLastInput = CoreTiming::GetTicks();
|
|
}
|
|
}
|
|
|
|
// NOTE: CPU Thread
|
|
void SetPolledDevice()
|
|
{
|
|
s_bPolled = true;
|
|
}
|
|
|
|
// NOTE: Host Thread
|
|
void DoFrameStep()
|
|
{
|
|
if (Core::GetState() == Core::State::Paused)
|
|
{
|
|
// if already paused, frame advance for 1 frame
|
|
s_bFrameStep = true;
|
|
Core::RequestRefreshInfo();
|
|
Core::SetState(Core::State::Running);
|
|
}
|
|
else if (!s_bFrameStep)
|
|
{
|
|
// if not paused yet, pause immediately instead
|
|
Core::SetState(Core::State::Paused);
|
|
}
|
|
}
|
|
|
|
// NOTE: Host Thread
|
|
void SetReadOnly(bool bEnabled)
|
|
{
|
|
if (s_bReadOnly != bEnabled)
|
|
Core::DisplayMessage(bEnabled ? "Read-only mode." : "Read+Write mode.", 1000);
|
|
|
|
s_bReadOnly = bEnabled;
|
|
}
|
|
|
|
bool IsRecordingInput()
|
|
{
|
|
return (s_playMode == MODE_RECORDING);
|
|
}
|
|
|
|
bool IsRecordingInputFromSaveState()
|
|
{
|
|
return s_bRecordingFromSaveState;
|
|
}
|
|
|
|
bool IsJustStartingRecordingInputFromSaveState()
|
|
{
|
|
return IsRecordingInputFromSaveState() && s_currentFrame == 0;
|
|
}
|
|
|
|
bool IsJustStartingPlayingInputFromSaveState()
|
|
{
|
|
return IsRecordingInputFromSaveState() && s_currentFrame == 1 && IsPlayingInput();
|
|
}
|
|
|
|
bool IsPlayingInput()
|
|
{
|
|
return (s_playMode == MODE_PLAYING);
|
|
}
|
|
|
|
bool IsMovieActive()
|
|
{
|
|
return s_playMode != MODE_NONE;
|
|
}
|
|
|
|
bool IsReadOnly()
|
|
{
|
|
return s_bReadOnly;
|
|
}
|
|
|
|
u64 GetRecordingStartTime()
|
|
{
|
|
return s_recordingStartTime;
|
|
}
|
|
|
|
u64 GetCurrentFrame()
|
|
{
|
|
return s_currentFrame;
|
|
}
|
|
|
|
u64 GetTotalFrames()
|
|
{
|
|
return s_totalFrames;
|
|
}
|
|
|
|
u64 GetCurrentInputCount()
|
|
{
|
|
return s_currentInputCount;
|
|
}
|
|
|
|
u64 GetTotalInputCount()
|
|
{
|
|
return s_totalInputCount;
|
|
}
|
|
|
|
u64 GetCurrentLagCount()
|
|
{
|
|
return s_currentLagCount;
|
|
}
|
|
|
|
u64 GetTotalLagCount()
|
|
{
|
|
return s_totalLagCount;
|
|
}
|
|
|
|
void SetClearSave(bool enabled)
|
|
{
|
|
s_bClearSave = enabled;
|
|
}
|
|
|
|
void SignalDiscChange(const std::string& new_path)
|
|
{
|
|
if (Movie::IsRecordingInput())
|
|
{
|
|
size_t size_of_path_without_filename = new_path.find_last_of("/\\") + 1;
|
|
std::string filename = new_path.substr(size_of_path_without_filename);
|
|
constexpr size_t maximum_length = sizeof(DTMHeader::discChange);
|
|
if (filename.length() > maximum_length)
|
|
{
|
|
PanicAlertT("The disc change to \"%s\" could not be saved in the .dtm file.\n"
|
|
"The filename of the disc image must not be longer than 40 characters.",
|
|
filename.c_str());
|
|
}
|
|
s_discChange = filename;
|
|
s_bDiscChange = true;
|
|
}
|
|
}
|
|
|
|
void SetReset(bool reset)
|
|
{
|
|
s_bReset = reset;
|
|
}
|
|
|
|
bool IsUsingPad(int controller)
|
|
{
|
|
return ((s_controllers & (1 << controller)) != 0);
|
|
}
|
|
|
|
bool IsUsingBongo(int controller)
|
|
{
|
|
return ((s_bongos & (1 << controller)) != 0);
|
|
}
|
|
|
|
bool IsUsingWiimote(int wiimote)
|
|
{
|
|
return ((s_controllers & (1 << (wiimote + 4))) != 0);
|
|
}
|
|
|
|
bool IsConfigSaved()
|
|
{
|
|
return s_bSaveConfig;
|
|
}
|
|
bool IsDualCore()
|
|
{
|
|
return s_bDualCore;
|
|
}
|
|
|
|
bool IsProgressive()
|
|
{
|
|
return s_bProgressive;
|
|
}
|
|
|
|
bool IsPAL60()
|
|
{
|
|
return s_bPAL60;
|
|
}
|
|
|
|
bool IsDSPHLE()
|
|
{
|
|
return s_bDSPHLE;
|
|
}
|
|
|
|
bool IsFastDiscSpeed()
|
|
{
|
|
return s_bFastDiscSpeed;
|
|
}
|
|
|
|
int GetCPUMode()
|
|
{
|
|
return s_iCPUCore;
|
|
}
|
|
|
|
u8 GetLanguage()
|
|
{
|
|
return s_language;
|
|
}
|
|
|
|
bool IsStartingFromClearSave()
|
|
{
|
|
return s_bClearSave;
|
|
}
|
|
|
|
bool IsUsingMemcard(int memcard)
|
|
{
|
|
return (s_memcards & (1 << memcard)) != 0;
|
|
}
|
|
|
|
bool IsSyncGPU()
|
|
{
|
|
return s_bSyncGPU;
|
|
}
|
|
|
|
bool IsNetPlayRecording()
|
|
{
|
|
return s_bNetPlay;
|
|
}
|
|
|
|
// NOTE: Host Thread
|
|
void ChangePads(bool instantly)
|
|
{
|
|
if (!Core::IsRunning())
|
|
return;
|
|
|
|
int controllers = 0;
|
|
|
|
for (int i = 0; i < SerialInterface::MAX_SI_CHANNELS; ++i)
|
|
{
|
|
if (SerialInterface::SIDevice_IsGCController(SConfig::GetInstance().m_SIDevice[i]))
|
|
controllers |= (1 << i);
|
|
}
|
|
|
|
if (instantly && (s_controllers & 0x0F) == controllers)
|
|
return;
|
|
|
|
for (int i = 0; i < SerialInterface::MAX_SI_CHANNELS; ++i)
|
|
{
|
|
SerialInterface::SIDevices device = SerialInterface::SIDEVICE_NONE;
|
|
if (IsUsingPad(i))
|
|
{
|
|
if (SerialInterface::SIDevice_IsGCController(SConfig::GetInstance().m_SIDevice[i]))
|
|
{
|
|
device = SConfig::GetInstance().m_SIDevice[i];
|
|
}
|
|
else
|
|
{
|
|
device = IsUsingBongo(i) ? SerialInterface::SIDEVICE_GC_TARUKONGA :
|
|
SerialInterface::SIDEVICE_GC_CONTROLLER;
|
|
}
|
|
}
|
|
|
|
if (instantly) // Changes from savestates need to be instantaneous
|
|
SerialInterface::AddDevice(device, i);
|
|
else
|
|
SerialInterface::ChangeDevice(device, i);
|
|
}
|
|
}
|
|
|
|
// NOTE: Host / Emu Threads
|
|
void ChangeWiiPads(bool instantly)
|
|
{
|
|
int controllers = 0;
|
|
|
|
for (int i = 0; i < MAX_WIIMOTES; ++i)
|
|
if (g_wiimote_sources[i] != WIIMOTE_SRC_NONE)
|
|
controllers |= (1 << i);
|
|
|
|
// This is important for Wiimotes, because they can desync easily if they get re-activated
|
|
if (instantly && (s_controllers >> 4) == controllers)
|
|
return;
|
|
|
|
const auto ios = IOS::HLE::GetIOS();
|
|
const auto bt = ios ? std::static_pointer_cast<IOS::HLE::Device::BluetoothEmu>(
|
|
ios->GetDeviceByName("/dev/usb/oh1/57e/305")) :
|
|
nullptr;
|
|
for (int i = 0; i < MAX_WIIMOTES; ++i)
|
|
{
|
|
g_wiimote_sources[i] = IsUsingWiimote(i) ? WIIMOTE_SRC_EMU : WIIMOTE_SRC_NONE;
|
|
if (!SConfig::GetInstance().m_bt_passthrough_enabled && bt)
|
|
bt->AccessWiiMote(i | 0x100)->Activate(IsUsingWiimote(i));
|
|
}
|
|
}
|
|
|
|
// NOTE: Host Thread
|
|
bool BeginRecordingInput(int controllers)
|
|
{
|
|
if (s_playMode != MODE_NONE || controllers == 0)
|
|
return false;
|
|
|
|
bool was_unpaused = Core::PauseAndLock(true);
|
|
|
|
s_controllers = controllers;
|
|
s_currentFrame = s_totalFrames = 0;
|
|
s_currentLagCount = s_totalLagCount = 0;
|
|
s_currentInputCount = s_totalInputCount = 0;
|
|
s_totalTickCount = s_tickCountAtLastInput = 0;
|
|
s_bongos = 0;
|
|
s_memcards = 0;
|
|
if (NetPlay::IsNetPlayRunning())
|
|
{
|
|
s_bNetPlay = true;
|
|
s_recordingStartTime = ExpansionInterface::CEXIIPL::NetPlay_GetEmulatedTime();
|
|
}
|
|
else if (SConfig::GetInstance().bEnableCustomRTC)
|
|
{
|
|
s_recordingStartTime = SConfig::GetInstance().m_customRTCValue;
|
|
}
|
|
else
|
|
{
|
|
s_recordingStartTime = Common::Timer::GetLocalTimeSinceJan1970();
|
|
}
|
|
|
|
s_rerecords = 0;
|
|
|
|
for (int i = 0; i < SerialInterface::MAX_SI_CHANNELS; ++i)
|
|
{
|
|
if (SConfig::GetInstance().m_SIDevice[i] == SerialInterface::SIDEVICE_GC_TARUKONGA)
|
|
s_bongos |= (1 << i);
|
|
}
|
|
|
|
if (Core::IsRunningAndStarted())
|
|
{
|
|
const std::string save_path = File::GetUserPath(D_STATESAVES_IDX) + "dtm.sav";
|
|
if (File::Exists(save_path))
|
|
File::Delete(save_path);
|
|
|
|
State::SaveAs(save_path);
|
|
s_bRecordingFromSaveState = true;
|
|
|
|
std::thread md5thread(GetMD5);
|
|
md5thread.detach();
|
|
GetSettings();
|
|
}
|
|
|
|
// Wiimotes cause desync issues if they're not reset before launching the game
|
|
if (!Core::IsRunningAndStarted())
|
|
{
|
|
// This will also reset the wiimotes for gamecube games, but that shouldn't do anything
|
|
Wiimote::ResetAllWiimotes();
|
|
}
|
|
|
|
s_playMode = MODE_RECORDING;
|
|
s_author = SConfig::GetInstance().m_strMovieAuthor;
|
|
EnsureTmpInputSize(1);
|
|
|
|
s_currentByte = s_totalBytes = 0;
|
|
|
|
Core::UpdateWantDeterminism();
|
|
|
|
Core::PauseAndLock(false, was_unpaused);
|
|
|
|
Core::DisplayMessage("Starting movie recording", 2000);
|
|
return true;
|
|
}
|
|
|
|
static std::string Analog2DToString(u8 x, u8 y, const std::string& prefix, u8 range = 255)
|
|
{
|
|
u8 center = range / 2 + 1;
|
|
if ((x <= 1 || x == center || x >= range) && (y <= 1 || y == center || y >= range))
|
|
{
|
|
if (x != center || y != center)
|
|
{
|
|
if (x != center && y != center)
|
|
{
|
|
return StringFromFormat("%s:%s,%s", prefix.c_str(), x < center ? "LEFT" : "RIGHT",
|
|
y < center ? "DOWN" : "UP");
|
|
}
|
|
else if (x != center)
|
|
{
|
|
return StringFromFormat("%s:%s", prefix.c_str(), x < center ? "LEFT" : "RIGHT");
|
|
}
|
|
else
|
|
{
|
|
return StringFromFormat("%s:%s", prefix.c_str(), y < center ? "DOWN" : "UP");
|
|
}
|
|
}
|
|
else
|
|
{
|
|
return "";
|
|
}
|
|
}
|
|
else
|
|
{
|
|
return StringFromFormat("%s:%d,%d", prefix.c_str(), x, y);
|
|
}
|
|
}
|
|
|
|
static std::string Analog1DToString(u8 v, const std::string& prefix, u8 range = 255)
|
|
{
|
|
if (v > 0)
|
|
{
|
|
if (v == range)
|
|
{
|
|
return prefix;
|
|
}
|
|
else
|
|
{
|
|
return StringFromFormat("%s:%d", prefix.c_str(), v);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
return "";
|
|
}
|
|
}
|
|
|
|
// NOTE: CPU Thread
|
|
static void SetInputDisplayString(ControllerState padState, int controllerID)
|
|
{
|
|
std::string display_str = StringFromFormat("P%d:", controllerID + 1);
|
|
|
|
if (padState.A)
|
|
display_str += " A";
|
|
if (padState.B)
|
|
display_str += " B";
|
|
if (padState.X)
|
|
display_str += " X";
|
|
if (padState.Y)
|
|
display_str += " Y";
|
|
if (padState.Z)
|
|
display_str += " Z";
|
|
if (padState.Start)
|
|
display_str += " START";
|
|
|
|
if (padState.DPadUp)
|
|
display_str += " UP";
|
|
if (padState.DPadDown)
|
|
display_str += " DOWN";
|
|
if (padState.DPadLeft)
|
|
display_str += " LEFT";
|
|
if (padState.DPadRight)
|
|
display_str += " RIGHT";
|
|
if (padState.reset)
|
|
display_str += " RESET";
|
|
|
|
display_str += Analog1DToString(padState.TriggerL, " L");
|
|
display_str += Analog1DToString(padState.TriggerR, " R");
|
|
display_str += Analog2DToString(padState.AnalogStickX, padState.AnalogStickY, " ANA");
|
|
display_str += Analog2DToString(padState.CStickX, padState.CStickY, " C");
|
|
|
|
std::lock_guard<std::mutex> guard(s_input_display_lock);
|
|
s_InputDisplay[controllerID] = std::move(display_str);
|
|
}
|
|
|
|
// NOTE: CPU Thread
|
|
static void SetWiiInputDisplayString(int remoteID, u8* const data,
|
|
const WiimoteEmu::ReportFeatures& rptf, int ext,
|
|
const wiimote_key key)
|
|
{
|
|
int controllerID = remoteID + 4;
|
|
|
|
std::string display_str = StringFromFormat("R%d:", remoteID + 1);
|
|
|
|
u8* const coreData = rptf.core ? (data + rptf.core) : nullptr;
|
|
u8* const accelData = rptf.accel ? (data + rptf.accel) : nullptr;
|
|
u8* const irData = rptf.ir ? (data + rptf.ir) : nullptr;
|
|
u8* const extData = rptf.ext ? (data + rptf.ext) : nullptr;
|
|
|
|
if (coreData)
|
|
{
|
|
wm_buttons buttons = *(wm_buttons*)coreData;
|
|
if (buttons.left)
|
|
display_str += " LEFT";
|
|
if (buttons.right)
|
|
display_str += " RIGHT";
|
|
if (buttons.down)
|
|
display_str += " DOWN";
|
|
if (buttons.up)
|
|
display_str += " UP";
|
|
if (buttons.a)
|
|
display_str += " A";
|
|
if (buttons.b)
|
|
display_str += " B";
|
|
if (buttons.plus)
|
|
display_str += " +";
|
|
if (buttons.minus)
|
|
display_str += " -";
|
|
if (buttons.one)
|
|
display_str += " 1";
|
|
if (buttons.two)
|
|
display_str += " 2";
|
|
if (buttons.home)
|
|
display_str += " HOME";
|
|
|
|
// A few bits of accelData are actually inside the coreData struct.
|
|
if (accelData)
|
|
{
|
|
wm_accel* dt = (wm_accel*)accelData;
|
|
display_str += StringFromFormat(" ACC:%d,%d,%d", dt->x << 2 | buttons.acc_x_lsb,
|
|
dt->y << 2 | buttons.acc_y_lsb << 1,
|
|
dt->z << 2 | buttons.acc_z_lsb << 1);
|
|
}
|
|
}
|
|
|
|
if (irData)
|
|
{
|
|
u16 x = irData[0] | ((irData[2] >> 4 & 0x3) << 8);
|
|
u16 y = irData[1] | ((irData[2] >> 6 & 0x3) << 8);
|
|
display_str += StringFromFormat(" IR:%d,%d", x, y);
|
|
}
|
|
|
|
// Nunchuk
|
|
if (extData && ext == 1)
|
|
{
|
|
wm_nc nunchuk;
|
|
memcpy(&nunchuk, extData, sizeof(wm_nc));
|
|
WiimoteDecrypt(&key, (u8*)&nunchuk, 0, sizeof(wm_nc));
|
|
nunchuk.bt.hex = nunchuk.bt.hex ^ 0x3;
|
|
|
|
std::string accel = StringFromFormat(
|
|
" N-ACC:%d,%d,%d", (nunchuk.ax << 2) | nunchuk.bt.acc_x_lsb,
|
|
(nunchuk.ay << 2) | nunchuk.bt.acc_y_lsb, (nunchuk.az << 2) | nunchuk.bt.acc_z_lsb);
|
|
|
|
if (nunchuk.bt.c)
|
|
display_str += " C";
|
|
if (nunchuk.bt.z)
|
|
display_str += " Z";
|
|
display_str += accel;
|
|
display_str += Analog2DToString(nunchuk.jx, nunchuk.jy, " ANA");
|
|
}
|
|
|
|
// Classic controller
|
|
if (extData && ext == 2)
|
|
{
|
|
wm_classic_extension cc;
|
|
memcpy(&cc, extData, sizeof(wm_classic_extension));
|
|
WiimoteDecrypt(&key, (u8*)&cc, 0, sizeof(wm_classic_extension));
|
|
cc.bt.hex = cc.bt.hex ^ 0xFFFF;
|
|
|
|
if (cc.bt.regular_data.dpad_left)
|
|
display_str += " LEFT";
|
|
if (cc.bt.dpad_right)
|
|
display_str += " RIGHT";
|
|
if (cc.bt.dpad_down)
|
|
display_str += " DOWN";
|
|
if (cc.bt.regular_data.dpad_up)
|
|
display_str += " UP";
|
|
if (cc.bt.a)
|
|
display_str += " A";
|
|
if (cc.bt.b)
|
|
display_str += " B";
|
|
if (cc.bt.x)
|
|
display_str += " X";
|
|
if (cc.bt.y)
|
|
display_str += " Y";
|
|
if (cc.bt.zl)
|
|
display_str += " ZL";
|
|
if (cc.bt.zr)
|
|
display_str += " ZR";
|
|
if (cc.bt.plus)
|
|
display_str += " +";
|
|
if (cc.bt.minus)
|
|
display_str += " -";
|
|
if (cc.bt.home)
|
|
display_str += " HOME";
|
|
|
|
display_str += Analog1DToString(cc.lt1 | (cc.lt2 << 3), " L", 31);
|
|
display_str += Analog1DToString(cc.rt, " R", 31);
|
|
display_str += Analog2DToString(cc.regular_data.lx, cc.regular_data.ly, " ANA", 63);
|
|
display_str += Analog2DToString(cc.rx1 | (cc.rx2 << 1) | (cc.rx3 << 3), cc.ry, " R-ANA", 31);
|
|
}
|
|
|
|
std::lock_guard<std::mutex> guard(s_input_display_lock);
|
|
s_InputDisplay[controllerID] = std::move(display_str);
|
|
}
|
|
|
|
// NOTE: CPU Thread
|
|
void CheckPadStatus(GCPadStatus* PadStatus, int controllerID)
|
|
{
|
|
s_padState.A = ((PadStatus->button & PAD_BUTTON_A) != 0);
|
|
s_padState.B = ((PadStatus->button & PAD_BUTTON_B) != 0);
|
|
s_padState.X = ((PadStatus->button & PAD_BUTTON_X) != 0);
|
|
s_padState.Y = ((PadStatus->button & PAD_BUTTON_Y) != 0);
|
|
s_padState.Z = ((PadStatus->button & PAD_TRIGGER_Z) != 0);
|
|
s_padState.Start = ((PadStatus->button & PAD_BUTTON_START) != 0);
|
|
|
|
s_padState.DPadUp = ((PadStatus->button & PAD_BUTTON_UP) != 0);
|
|
s_padState.DPadDown = ((PadStatus->button & PAD_BUTTON_DOWN) != 0);
|
|
s_padState.DPadLeft = ((PadStatus->button & PAD_BUTTON_LEFT) != 0);
|
|
s_padState.DPadRight = ((PadStatus->button & PAD_BUTTON_RIGHT) != 0);
|
|
|
|
s_padState.L = ((PadStatus->button & PAD_TRIGGER_L) != 0);
|
|
s_padState.R = ((PadStatus->button & PAD_TRIGGER_R) != 0);
|
|
s_padState.TriggerL = PadStatus->triggerLeft;
|
|
s_padState.TriggerR = PadStatus->triggerRight;
|
|
|
|
s_padState.AnalogStickX = PadStatus->stickX;
|
|
s_padState.AnalogStickY = PadStatus->stickY;
|
|
|
|
s_padState.CStickX = PadStatus->substickX;
|
|
s_padState.CStickY = PadStatus->substickY;
|
|
|
|
s_padState.disc = s_bDiscChange;
|
|
s_bDiscChange = false;
|
|
s_padState.reset = s_bReset;
|
|
s_bReset = false;
|
|
|
|
SetInputDisplayString(s_padState, controllerID);
|
|
}
|
|
|
|
// NOTE: CPU Thread
|
|
void RecordInput(GCPadStatus* PadStatus, int controllerID)
|
|
{
|
|
if (!IsRecordingInput() || !IsUsingPad(controllerID))
|
|
return;
|
|
|
|
CheckPadStatus(PadStatus, controllerID);
|
|
|
|
EnsureTmpInputSize((size_t)(s_currentByte + sizeof(ControllerState)));
|
|
memcpy(&tmpInput[s_currentByte], &s_padState, sizeof(ControllerState));
|
|
s_currentByte += sizeof(ControllerState);
|
|
s_totalBytes = s_currentByte;
|
|
}
|
|
|
|
// NOTE: CPU Thread
|
|
void CheckWiimoteStatus(int wiimote, u8* data, const WiimoteEmu::ReportFeatures& rptf, int ext,
|
|
const wiimote_key key)
|
|
{
|
|
SetWiiInputDisplayString(wiimote, data, rptf, ext, key);
|
|
|
|
if (IsRecordingInput())
|
|
RecordWiimote(wiimote, data, rptf.size);
|
|
}
|
|
|
|
void RecordWiimote(int wiimote, u8* data, u8 size)
|
|
{
|
|
if (!IsRecordingInput() || !IsUsingWiimote(wiimote))
|
|
return;
|
|
|
|
InputUpdate();
|
|
EnsureTmpInputSize((size_t)(s_currentByte + size + 1));
|
|
tmpInput[s_currentByte++] = size;
|
|
memcpy(&(tmpInput[s_currentByte]), data, size);
|
|
s_currentByte += size;
|
|
s_totalBytes = s_currentByte;
|
|
}
|
|
|
|
// NOTE: EmuThread / Host Thread
|
|
void ReadHeader()
|
|
{
|
|
s_controllers = tmpHeader.controllers;
|
|
s_recordingStartTime = tmpHeader.recordingStartTime;
|
|
if (s_rerecords < tmpHeader.numRerecords)
|
|
s_rerecords = tmpHeader.numRerecords;
|
|
|
|
if (tmpHeader.bSaveConfig)
|
|
{
|
|
s_bSaveConfig = true;
|
|
s_bDualCore = tmpHeader.bDualCore;
|
|
s_bProgressive = tmpHeader.bProgressive;
|
|
s_bPAL60 = tmpHeader.bPAL60;
|
|
s_bDSPHLE = tmpHeader.bDSPHLE;
|
|
s_bFastDiscSpeed = tmpHeader.bFastDiscSpeed;
|
|
s_iCPUCore = tmpHeader.CPUCore;
|
|
s_bClearSave = tmpHeader.bClearSave;
|
|
s_memcards = tmpHeader.memcards;
|
|
s_bongos = tmpHeader.bongos;
|
|
s_bSyncGPU = tmpHeader.bSyncGPU;
|
|
s_bNetPlay = tmpHeader.bNetPlay;
|
|
s_language = tmpHeader.language;
|
|
memcpy(s_revision, tmpHeader.revision, ArraySize(s_revision));
|
|
}
|
|
else
|
|
{
|
|
GetSettings();
|
|
}
|
|
|
|
s_videoBackend = (char*)tmpHeader.videoBackend;
|
|
s_discChange = (char*)tmpHeader.discChange;
|
|
s_author = (char*)tmpHeader.author;
|
|
memcpy(s_MD5, tmpHeader.md5, 16);
|
|
s_DSPiromHash = tmpHeader.DSPiromHash;
|
|
s_DSPcoefHash = tmpHeader.DSPcoefHash;
|
|
}
|
|
|
|
// NOTE: Host Thread
|
|
bool PlayInput(const std::string& filename)
|
|
{
|
|
if (s_playMode != MODE_NONE)
|
|
return false;
|
|
|
|
if (!File::Exists(filename))
|
|
return false;
|
|
|
|
File::IOFile g_recordfd;
|
|
|
|
if (!g_recordfd.Open(filename, "rb"))
|
|
return false;
|
|
|
|
g_recordfd.ReadArray(&tmpHeader, 1);
|
|
|
|
if (!IsMovieHeader(tmpHeader.filetype))
|
|
{
|
|
PanicAlertT("Invalid recording file");
|
|
g_recordfd.Close();
|
|
return false;
|
|
}
|
|
|
|
ReadHeader();
|
|
s_totalFrames = tmpHeader.frameCount;
|
|
s_totalLagCount = tmpHeader.lagCount;
|
|
s_totalInputCount = tmpHeader.inputCount;
|
|
s_totalTickCount = tmpHeader.tickCount;
|
|
s_currentFrame = 0;
|
|
s_currentLagCount = 0;
|
|
s_currentInputCount = 0;
|
|
|
|
s_playMode = MODE_PLAYING;
|
|
|
|
// Wiimotes cause desync issues if they're not reset before launching the game
|
|
Wiimote::ResetAllWiimotes();
|
|
|
|
Core::UpdateWantDeterminism();
|
|
|
|
s_totalBytes = g_recordfd.GetSize() - 256;
|
|
EnsureTmpInputSize((size_t)s_totalBytes);
|
|
g_recordfd.ReadArray(tmpInput, (size_t)s_totalBytes);
|
|
s_currentByte = 0;
|
|
g_recordfd.Close();
|
|
|
|
// Load savestate (and skip to frame data)
|
|
if (tmpHeader.bFromSaveState)
|
|
{
|
|
const std::string stateFilename = filename + ".sav";
|
|
if (File::Exists(stateFilename))
|
|
Core::SetStateFileName(stateFilename);
|
|
s_bRecordingFromSaveState = true;
|
|
Movie::LoadInput(filename);
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
void DoState(PointerWrap& p)
|
|
{
|
|
// many of these could be useful to save even when no movie is active,
|
|
// and the data is tiny, so let's just save it regardless of movie state.
|
|
p.Do(s_currentFrame);
|
|
p.Do(s_currentByte);
|
|
p.Do(s_currentLagCount);
|
|
p.Do(s_currentInputCount);
|
|
p.Do(s_bPolled);
|
|
p.Do(s_tickCountAtLastInput);
|
|
// other variables (such as s_totalBytes and s_totalFrames) are set in LoadInput
|
|
}
|
|
|
|
// NOTE: Host Thread
|
|
void LoadInput(const std::string& filename)
|
|
{
|
|
File::IOFile t_record;
|
|
if (!t_record.Open(filename, "r+b"))
|
|
{
|
|
PanicAlertT("Failed to read %s", filename.c_str());
|
|
EndPlayInput(false);
|
|
return;
|
|
}
|
|
|
|
t_record.ReadArray(&tmpHeader, 1);
|
|
|
|
if (!IsMovieHeader(tmpHeader.filetype))
|
|
{
|
|
PanicAlertT("Savestate movie %s is corrupted, movie recording stopping...", filename.c_str());
|
|
EndPlayInput(false);
|
|
return;
|
|
}
|
|
ReadHeader();
|
|
if (!s_bReadOnly)
|
|
{
|
|
s_rerecords++;
|
|
tmpHeader.numRerecords = s_rerecords;
|
|
t_record.Seek(0, SEEK_SET);
|
|
t_record.WriteArray(&tmpHeader, 1);
|
|
}
|
|
|
|
ChangePads(true);
|
|
if (SConfig::GetInstance().bWii)
|
|
ChangeWiiPads(true);
|
|
|
|
u64 totalSavedBytes = t_record.GetSize() - 256;
|
|
|
|
bool afterEnd = false;
|
|
// This can only happen if the user manually deletes data from the dtm.
|
|
if (s_currentByte > totalSavedBytes)
|
|
{
|
|
PanicAlertT("Warning: You loaded a save whose movie ends before the current frame in the save "
|
|
"(byte %u < %u) (frame %u < %u). You should load another save before continuing.",
|
|
(u32)totalSavedBytes + 256, (u32)s_currentByte + 256, (u32)tmpHeader.frameCount,
|
|
(u32)s_currentFrame);
|
|
afterEnd = true;
|
|
}
|
|
|
|
if (!s_bReadOnly || tmpInput == nullptr)
|
|
{
|
|
s_totalFrames = tmpHeader.frameCount;
|
|
s_totalLagCount = tmpHeader.lagCount;
|
|
s_totalInputCount = tmpHeader.inputCount;
|
|
s_totalTickCount = s_tickCountAtLastInput = tmpHeader.tickCount;
|
|
|
|
EnsureTmpInputSize((size_t)totalSavedBytes);
|
|
s_totalBytes = totalSavedBytes;
|
|
t_record.ReadArray(tmpInput, (size_t)s_totalBytes);
|
|
}
|
|
else if (s_currentByte > 0)
|
|
{
|
|
if (s_currentByte > totalSavedBytes)
|
|
{
|
|
}
|
|
else if (s_currentByte > s_totalBytes)
|
|
{
|
|
afterEnd = true;
|
|
PanicAlertT("Warning: You loaded a save that's after the end of the current movie. (byte %u "
|
|
"> %u) (input %u > %u). You should load another save before continuing, or load "
|
|
"this state with read-only mode off.",
|
|
(u32)s_currentByte + 256, (u32)s_totalBytes + 256, (u32)s_currentInputCount,
|
|
(u32)s_totalInputCount);
|
|
}
|
|
else if (s_currentByte > 0 && s_totalBytes > 0)
|
|
{
|
|
// verify identical from movie start to the save's current frame
|
|
std::vector<u8> movInput(s_currentByte);
|
|
t_record.ReadArray(movInput.data(), movInput.size());
|
|
|
|
const auto result = std::mismatch(movInput.begin(), movInput.end(), tmpInput);
|
|
|
|
if (result.first != movInput.end())
|
|
{
|
|
const ptrdiff_t mismatch_index = std::distance(movInput.begin(), result.first);
|
|
|
|
// this is a "you did something wrong" alert for the user's benefit.
|
|
// we'll try to say what's going on in excruciating detail, otherwise the user might not
|
|
// believe us.
|
|
if (IsUsingWiimote(0))
|
|
{
|
|
const size_t byte_offset = static_cast<size_t>(mismatch_index) + sizeof(DTMHeader);
|
|
|
|
// TODO: more detail
|
|
PanicAlertT("Warning: You loaded a save whose movie mismatches on byte %zu (0x%zX). "
|
|
"You should load another save before continuing, or load this state with "
|
|
"read-only mode off. Otherwise you'll probably get a desync.",
|
|
byte_offset, byte_offset);
|
|
|
|
std::copy(movInput.begin(), movInput.end(), tmpInput);
|
|
}
|
|
else
|
|
{
|
|
const ptrdiff_t frame = mismatch_index / sizeof(ControllerState);
|
|
ControllerState curPadState;
|
|
memcpy(&curPadState, &tmpInput[frame * sizeof(ControllerState)], sizeof(ControllerState));
|
|
ControllerState movPadState;
|
|
memcpy(&movPadState, &movInput[frame * sizeof(ControllerState)], sizeof(ControllerState));
|
|
PanicAlertT(
|
|
"Warning: You loaded a save whose movie mismatches on frame %td. You should load "
|
|
"another save before continuing, or load this state with read-only mode off. "
|
|
"Otherwise you'll probably get a desync.\n\n"
|
|
"More information: The current movie is %d frames long and the savestate's movie "
|
|
"is %d frames long.\n\n"
|
|
"On frame %td, the current movie presses:\n"
|
|
"Start=%d, A=%d, B=%d, X=%d, Y=%d, Z=%d, DUp=%d, DDown=%d, DLeft=%d, DRight=%d, "
|
|
"L=%d, R=%d, LT=%d, RT=%d, AnalogX=%d, AnalogY=%d, CX=%d, CY=%d"
|
|
"\n\n"
|
|
"On frame %td, the savestate's movie presses:\n"
|
|
"Start=%d, A=%d, B=%d, X=%d, Y=%d, Z=%d, DUp=%d, DDown=%d, DLeft=%d, DRight=%d, "
|
|
"L=%d, R=%d, LT=%d, RT=%d, AnalogX=%d, AnalogY=%d, CX=%d, CY=%d",
|
|
frame, (int)s_totalFrames, (int)tmpHeader.frameCount, frame, (int)curPadState.Start,
|
|
(int)curPadState.A, (int)curPadState.B, (int)curPadState.X, (int)curPadState.Y,
|
|
(int)curPadState.Z, (int)curPadState.DPadUp, (int)curPadState.DPadDown,
|
|
(int)curPadState.DPadLeft, (int)curPadState.DPadRight, (int)curPadState.L,
|
|
(int)curPadState.R, (int)curPadState.TriggerL, (int)curPadState.TriggerR,
|
|
(int)curPadState.AnalogStickX, (int)curPadState.AnalogStickY,
|
|
(int)curPadState.CStickX, (int)curPadState.CStickY, frame, (int)movPadState.Start,
|
|
(int)movPadState.A, (int)movPadState.B, (int)movPadState.X, (int)movPadState.Y,
|
|
(int)movPadState.Z, (int)movPadState.DPadUp, (int)movPadState.DPadDown,
|
|
(int)movPadState.DPadLeft, (int)movPadState.DPadRight, (int)movPadState.L,
|
|
(int)movPadState.R, (int)movPadState.TriggerL, (int)movPadState.TriggerR,
|
|
(int)movPadState.AnalogStickX, (int)movPadState.AnalogStickY,
|
|
(int)movPadState.CStickX, (int)movPadState.CStickY);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
t_record.Close();
|
|
|
|
s_bSaveConfig = tmpHeader.bSaveConfig;
|
|
|
|
if (!afterEnd)
|
|
{
|
|
if (s_bReadOnly)
|
|
{
|
|
if (s_playMode != MODE_PLAYING)
|
|
{
|
|
s_playMode = MODE_PLAYING;
|
|
Core::UpdateWantDeterminism();
|
|
Core::DisplayMessage("Switched to playback", 2000);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (s_playMode != MODE_RECORDING)
|
|
{
|
|
s_playMode = MODE_RECORDING;
|
|
Core::UpdateWantDeterminism();
|
|
Core::DisplayMessage("Switched to recording", 2000);
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
EndPlayInput(false);
|
|
}
|
|
}
|
|
|
|
// NOTE: CPU Thread
|
|
static void CheckInputEnd()
|
|
{
|
|
if (s_currentByte >= s_totalBytes ||
|
|
(CoreTiming::GetTicks() > s_totalTickCount && !IsRecordingInputFromSaveState()))
|
|
{
|
|
EndPlayInput(!s_bReadOnly);
|
|
}
|
|
}
|
|
|
|
// NOTE: CPU Thread
|
|
void PlayController(GCPadStatus* PadStatus, int controllerID)
|
|
{
|
|
// Correct playback is entirely dependent on the emulator polling the controllers
|
|
// in the same order done during recording
|
|
if (!IsPlayingInput() || !IsUsingPad(controllerID) || tmpInput == nullptr)
|
|
return;
|
|
|
|
if (s_currentByte + sizeof(ControllerState) > s_totalBytes)
|
|
{
|
|
PanicAlertT("Premature movie end in PlayController. %u + %zu > %u", (u32)s_currentByte,
|
|
sizeof(ControllerState), (u32)s_totalBytes);
|
|
EndPlayInput(!s_bReadOnly);
|
|
return;
|
|
}
|
|
|
|
// dtm files don't save the mic button or error bit. not sure if they're actually used, but better
|
|
// safe than sorry
|
|
signed char e = PadStatus->err;
|
|
memset(PadStatus, 0, sizeof(GCPadStatus));
|
|
PadStatus->err = e;
|
|
|
|
memcpy(&s_padState, &tmpInput[s_currentByte], sizeof(ControllerState));
|
|
s_currentByte += sizeof(ControllerState);
|
|
|
|
PadStatus->triggerLeft = s_padState.TriggerL;
|
|
PadStatus->triggerRight = s_padState.TriggerR;
|
|
|
|
PadStatus->stickX = s_padState.AnalogStickX;
|
|
PadStatus->stickY = s_padState.AnalogStickY;
|
|
|
|
PadStatus->substickX = s_padState.CStickX;
|
|
PadStatus->substickY = s_padState.CStickY;
|
|
|
|
PadStatus->button |= PAD_USE_ORIGIN;
|
|
|
|
if (s_padState.A)
|
|
{
|
|
PadStatus->button |= PAD_BUTTON_A;
|
|
PadStatus->analogA = 0xFF;
|
|
}
|
|
if (s_padState.B)
|
|
{
|
|
PadStatus->button |= PAD_BUTTON_B;
|
|
PadStatus->analogB = 0xFF;
|
|
}
|
|
if (s_padState.X)
|
|
PadStatus->button |= PAD_BUTTON_X;
|
|
if (s_padState.Y)
|
|
PadStatus->button |= PAD_BUTTON_Y;
|
|
if (s_padState.Z)
|
|
PadStatus->button |= PAD_TRIGGER_Z;
|
|
if (s_padState.Start)
|
|
PadStatus->button |= PAD_BUTTON_START;
|
|
|
|
if (s_padState.DPadUp)
|
|
PadStatus->button |= PAD_BUTTON_UP;
|
|
if (s_padState.DPadDown)
|
|
PadStatus->button |= PAD_BUTTON_DOWN;
|
|
if (s_padState.DPadLeft)
|
|
PadStatus->button |= PAD_BUTTON_LEFT;
|
|
if (s_padState.DPadRight)
|
|
PadStatus->button |= PAD_BUTTON_RIGHT;
|
|
|
|
if (s_padState.L)
|
|
PadStatus->button |= PAD_TRIGGER_L;
|
|
if (s_padState.R)
|
|
PadStatus->button |= PAD_TRIGGER_R;
|
|
if (s_padState.disc)
|
|
{
|
|
// This implementation assumes the disc change will only happen once. Trying
|
|
// to change more than that will cause it to load the last disc every time.
|
|
// As far as I know, there are no 3+ disc games, so this should be fine.
|
|
bool found = false;
|
|
std::string path;
|
|
for (const std::string& iso_folder : SConfig::GetInstance().m_ISOFolder)
|
|
{
|
|
path = iso_folder + '/' + s_discChange;
|
|
if (File::Exists(path))
|
|
{
|
|
found = true;
|
|
break;
|
|
}
|
|
}
|
|
if (found)
|
|
{
|
|
DVDInterface::ChangeDiscAsCPU(path);
|
|
}
|
|
else
|
|
{
|
|
CPU::Break();
|
|
PanicAlertT("Change the disc to %s", s_discChange.c_str());
|
|
}
|
|
}
|
|
|
|
if (s_padState.reset)
|
|
ProcessorInterface::ResetButton_Tap();
|
|
|
|
SetInputDisplayString(s_padState, controllerID);
|
|
CheckInputEnd();
|
|
}
|
|
|
|
// NOTE: CPU Thread
|
|
bool PlayWiimote(int wiimote, u8* data, const WiimoteEmu::ReportFeatures& rptf, int ext,
|
|
const wiimote_key key)
|
|
{
|
|
if (!IsPlayingInput() || !IsUsingWiimote(wiimote) || tmpInput == nullptr)
|
|
return false;
|
|
|
|
if (s_currentByte > s_totalBytes)
|
|
{
|
|
PanicAlertT("Premature movie end in PlayWiimote. %u > %u", (u32)s_currentByte,
|
|
(u32)s_totalBytes);
|
|
EndPlayInput(!s_bReadOnly);
|
|
return false;
|
|
}
|
|
|
|
u8 size = rptf.size;
|
|
|
|
u8 sizeInMovie = tmpInput[s_currentByte];
|
|
|
|
if (size != sizeInMovie)
|
|
{
|
|
PanicAlertT("Fatal desync. Aborting playback. (Error in PlayWiimote: %u != %u, byte %u.)%s",
|
|
(u32)sizeInMovie, (u32)size, (u32)s_currentByte,
|
|
(s_controllers & 0xF) ?
|
|
" Try re-creating the recording with all GameCube controllers "
|
|
"disabled (in Configure > GameCube > Device Settings)." :
|
|
"");
|
|
EndPlayInput(!s_bReadOnly);
|
|
return false;
|
|
}
|
|
|
|
s_currentByte++;
|
|
|
|
if (s_currentByte + size > s_totalBytes)
|
|
{
|
|
PanicAlertT("Premature movie end in PlayWiimote. %u + %d > %u", (u32)s_currentByte, size,
|
|
(u32)s_totalBytes);
|
|
EndPlayInput(!s_bReadOnly);
|
|
return false;
|
|
}
|
|
|
|
memcpy(data, &(tmpInput[s_currentByte]), size);
|
|
s_currentByte += size;
|
|
|
|
s_currentInputCount++;
|
|
|
|
CheckInputEnd();
|
|
return true;
|
|
}
|
|
|
|
// NOTE: Host / EmuThread / CPU Thread
|
|
void EndPlayInput(bool cont)
|
|
{
|
|
if (cont)
|
|
{
|
|
// If !IsMovieActive(), changing s_playMode requires calling UpdateWantDeterminism
|
|
_assert_(IsMovieActive());
|
|
|
|
s_playMode = MODE_RECORDING;
|
|
Core::DisplayMessage("Reached movie end. Resuming recording.", 2000);
|
|
}
|
|
else if (s_playMode != MODE_NONE)
|
|
{
|
|
// We can be called by EmuThread during boot (CPU::State::PowerDown)
|
|
bool was_running = Core::IsRunningAndStarted() && !CPU::IsStepping();
|
|
if (was_running)
|
|
CPU::Break();
|
|
s_rerecords = 0;
|
|
s_currentByte = 0;
|
|
s_playMode = MODE_NONE;
|
|
Core::DisplayMessage("Movie End.", 2000);
|
|
s_bRecordingFromSaveState = false;
|
|
// we don't clear these things because otherwise we can't resume playback if we load a movie
|
|
// state later
|
|
// s_totalFrames = s_totalBytes = 0;
|
|
// delete tmpInput;
|
|
// tmpInput = nullptr;
|
|
|
|
Core::QueueHostJob([=] {
|
|
Core::UpdateWantDeterminism();
|
|
if (was_running && !SConfig::GetInstance().m_PauseMovie)
|
|
CPU::EnableStepping(false);
|
|
});
|
|
}
|
|
}
|
|
|
|
// NOTE: Save State + Host Thread
|
|
void SaveRecording(const std::string& filename)
|
|
{
|
|
File::IOFile save_record(filename, "wb");
|
|
// Create the real header now and write it
|
|
DTMHeader header;
|
|
memset(&header, 0, sizeof(DTMHeader));
|
|
|
|
header.filetype[0] = 'D';
|
|
header.filetype[1] = 'T';
|
|
header.filetype[2] = 'M';
|
|
header.filetype[3] = 0x1A;
|
|
strncpy(header.gameID, SConfig::GetInstance().GetGameID().c_str(), 6);
|
|
header.bWii = SConfig::GetInstance().bWii;
|
|
header.controllers = s_controllers & (SConfig::GetInstance().bWii ? 0xFF : 0x0F);
|
|
|
|
header.bFromSaveState = s_bRecordingFromSaveState;
|
|
header.frameCount = s_totalFrames;
|
|
header.lagCount = s_totalLagCount;
|
|
header.inputCount = s_totalInputCount;
|
|
header.numRerecords = s_rerecords;
|
|
header.recordingStartTime = s_recordingStartTime;
|
|
|
|
header.bSaveConfig = true;
|
|
header.bSkipIdle = true;
|
|
header.bDualCore = s_bDualCore;
|
|
header.bProgressive = s_bProgressive;
|
|
header.bPAL60 = s_bPAL60;
|
|
header.bDSPHLE = s_bDSPHLE;
|
|
header.bFastDiscSpeed = s_bFastDiscSpeed;
|
|
strncpy((char*)header.videoBackend, s_videoBackend.c_str(), ArraySize(header.videoBackend));
|
|
header.CPUCore = s_iCPUCore;
|
|
header.bEFBAccessEnable = g_ActiveConfig.bEFBAccessEnable;
|
|
header.bEFBCopyEnable = true;
|
|
header.bSkipEFBCopyToRam = g_ActiveConfig.bSkipEFBCopyToRam;
|
|
header.bEFBCopyCacheEnable = false;
|
|
header.bEFBEmulateFormatChanges = g_ActiveConfig.bEFBEmulateFormatChanges;
|
|
header.bUseXFB = g_ActiveConfig.bUseXFB;
|
|
header.bUseRealXFB = g_ActiveConfig.bUseRealXFB;
|
|
header.memcards = s_memcards;
|
|
header.bClearSave = s_bClearSave;
|
|
header.bSyncGPU = s_bSyncGPU;
|
|
header.bNetPlay = s_bNetPlay;
|
|
strncpy((char*)header.discChange, s_discChange.c_str(), ArraySize(header.discChange));
|
|
strncpy((char*)header.author, s_author.c_str(), ArraySize(header.author));
|
|
memcpy(header.md5, s_MD5, 16);
|
|
header.bongos = s_bongos;
|
|
memcpy(header.revision, s_revision, ArraySize(header.revision));
|
|
header.DSPiromHash = s_DSPiromHash;
|
|
header.DSPcoefHash = s_DSPcoefHash;
|
|
header.tickCount = s_totalTickCount;
|
|
header.language = s_language;
|
|
|
|
// TODO
|
|
header.uniqueID = 0;
|
|
// header.audioEmulator;
|
|
|
|
save_record.WriteArray(&header, 1);
|
|
|
|
bool success = save_record.WriteArray(tmpInput, (size_t)s_totalBytes);
|
|
|
|
if (success && s_bRecordingFromSaveState)
|
|
{
|
|
std::string stateFilename = filename + ".sav";
|
|
success = File::Copy(File::GetUserPath(D_STATESAVES_IDX) + "dtm.sav", stateFilename);
|
|
}
|
|
|
|
if (success)
|
|
Core::DisplayMessage(StringFromFormat("DTM %s saved", filename.c_str()), 2000);
|
|
else
|
|
Core::DisplayMessage(StringFromFormat("Failed to save %s", filename.c_str()), 2000);
|
|
}
|
|
|
|
void SetGCInputManip(GCManipFunction func)
|
|
{
|
|
s_gc_manip_func = std::move(func);
|
|
}
|
|
void SetWiiInputManip(WiiManipFunction func)
|
|
{
|
|
s_wii_manip_func = std::move(func);
|
|
}
|
|
|
|
// NOTE: CPU Thread
|
|
void CallGCInputManip(GCPadStatus* PadStatus, int controllerID)
|
|
{
|
|
if (s_gc_manip_func)
|
|
s_gc_manip_func(PadStatus, controllerID);
|
|
}
|
|
// NOTE: CPU Thread
|
|
void CallWiiInputManip(u8* data, WiimoteEmu::ReportFeatures rptf, int controllerID, int ext,
|
|
const wiimote_key key)
|
|
{
|
|
if (s_wii_manip_func)
|
|
s_wii_manip_func(data, rptf, controllerID, ext, key);
|
|
}
|
|
|
|
// NOTE: GPU Thread
|
|
void SetGraphicsConfig()
|
|
{
|
|
g_Config.bEFBAccessEnable = tmpHeader.bEFBAccessEnable;
|
|
g_Config.bSkipEFBCopyToRam = tmpHeader.bSkipEFBCopyToRam;
|
|
g_Config.bEFBEmulateFormatChanges = tmpHeader.bEFBEmulateFormatChanges;
|
|
g_Config.bUseXFB = tmpHeader.bUseXFB;
|
|
g_Config.bUseRealXFB = tmpHeader.bUseRealXFB;
|
|
}
|
|
|
|
// NOTE: EmuThread / Host Thread
|
|
void GetSettings()
|
|
{
|
|
s_bSaveConfig = true;
|
|
s_bDualCore = SConfig::GetInstance().bCPUThread;
|
|
s_bProgressive = SConfig::GetInstance().bProgressive;
|
|
s_bPAL60 = SConfig::GetInstance().bPAL60;
|
|
s_bDSPHLE = SConfig::GetInstance().bDSPHLE;
|
|
s_bFastDiscSpeed = SConfig::GetInstance().bFastDiscSpeed;
|
|
s_videoBackend = g_video_backend->GetName();
|
|
s_bSyncGPU = SConfig::GetInstance().bSyncGPU;
|
|
s_iCPUCore = SConfig::GetInstance().iCPUCore;
|
|
s_bNetPlay = NetPlay::IsNetPlayRunning();
|
|
if (SConfig::GetInstance().bWii)
|
|
{
|
|
u64 title_id = SConfig::GetInstance().GetTitleID();
|
|
s_bClearSave =
|
|
!File::Exists(Common::GetTitleDataPath(title_id, Common::FROM_SESSION_ROOT) + "banner.bin");
|
|
s_language = SConfig::GetInstance().m_wii_language;
|
|
}
|
|
else
|
|
{
|
|
s_bClearSave = !File::Exists(SConfig::GetInstance().m_strMemoryCardA);
|
|
s_language = SConfig::GetInstance().SelectedLanguage;
|
|
}
|
|
s_memcards |=
|
|
(SConfig::GetInstance().m_EXIDevice[0] == ExpansionInterface::EXIDEVICE_MEMORYCARD ||
|
|
SConfig::GetInstance().m_EXIDevice[0] == ExpansionInterface::EXIDEVICE_MEMORYCARDFOLDER)
|
|
<< 0;
|
|
s_memcards |=
|
|
(SConfig::GetInstance().m_EXIDevice[1] == ExpansionInterface::EXIDEVICE_MEMORYCARD ||
|
|
SConfig::GetInstance().m_EXIDevice[1] == ExpansionInterface::EXIDEVICE_MEMORYCARDFOLDER)
|
|
<< 1;
|
|
|
|
std::array<u8, 20> revision = ConvertGitRevisionToBytes(scm_rev_git_str);
|
|
std::copy(std::begin(revision), std::end(revision), std::begin(s_revision));
|
|
|
|
if (!s_bDSPHLE)
|
|
{
|
|
std::string irom_file = File::GetUserPath(D_GCUSER_IDX) + DSP_IROM;
|
|
std::string coef_file = File::GetUserPath(D_GCUSER_IDX) + DSP_COEF;
|
|
|
|
if (!File::Exists(irom_file))
|
|
irom_file = File::GetSysDirectory() + GC_SYS_DIR DIR_SEP DSP_IROM;
|
|
if (!File::Exists(coef_file))
|
|
coef_file = File::GetSysDirectory() + GC_SYS_DIR DIR_SEP DSP_COEF;
|
|
std::vector<u16> irom(DSP::DSP_IROM_SIZE);
|
|
File::IOFile file_irom(irom_file, "rb");
|
|
|
|
file_irom.ReadArray(irom.data(), irom.size());
|
|
file_irom.Close();
|
|
for (u16& entry : irom)
|
|
entry = Common::swap16(entry);
|
|
|
|
std::vector<u16> coef(DSP::DSP_COEF_SIZE);
|
|
File::IOFile file_coef(coef_file, "rb");
|
|
|
|
file_coef.ReadArray(coef.data(), coef.size());
|
|
file_coef.Close();
|
|
for (u16& entry : coef)
|
|
entry = Common::swap16(entry);
|
|
s_DSPiromHash = HashAdler32(reinterpret_cast<u8*>(irom.data()), DSP::DSP_IROM_BYTE_SIZE);
|
|
s_DSPcoefHash = HashAdler32(reinterpret_cast<u8*>(coef.data()), DSP::DSP_COEF_BYTE_SIZE);
|
|
}
|
|
else
|
|
{
|
|
s_DSPiromHash = 0;
|
|
s_DSPcoefHash = 0;
|
|
}
|
|
}
|
|
|
|
static const mbedtls_md_info_t* s_md5_info = mbedtls_md_info_from_type(MBEDTLS_MD_MD5);
|
|
|
|
// NOTE: Entrypoint for own thread
|
|
void CheckMD5()
|
|
{
|
|
for (int i = 0, n = 0; i < 16; ++i)
|
|
{
|
|
if (tmpHeader.md5[i] != 0)
|
|
continue;
|
|
n++;
|
|
if (n == 16)
|
|
return;
|
|
}
|
|
Core::DisplayMessage("Verifying checksum...", 2000);
|
|
|
|
unsigned char gameMD5[16];
|
|
mbedtls_md_file(s_md5_info, SConfig::GetInstance().m_strFilename.c_str(), gameMD5);
|
|
|
|
if (memcmp(gameMD5, s_MD5, 16) == 0)
|
|
Core::DisplayMessage("Checksum of current game matches the recorded game.", 2000);
|
|
else
|
|
Core::DisplayMessage("Checksum of current game does not match the recorded game!", 3000);
|
|
}
|
|
|
|
// NOTE: Entrypoint for own thread
|
|
void GetMD5()
|
|
{
|
|
Core::DisplayMessage("Calculating checksum of game file...", 2000);
|
|
memset(s_MD5, 0, sizeof(s_MD5));
|
|
mbedtls_md_file(s_md5_info, SConfig::GetInstance().m_strFilename.c_str(), s_MD5);
|
|
Core::DisplayMessage("Finished calculating checksum.", 2000);
|
|
}
|
|
|
|
// NOTE: EmuThread
|
|
void Shutdown()
|
|
{
|
|
s_currentInputCount = s_totalInputCount = s_totalFrames = s_totalBytes = s_tickCountAtLastInput =
|
|
0;
|
|
delete[] tmpInput;
|
|
tmpInput = nullptr;
|
|
tmpInputAllocated = 0;
|
|
}
|
|
};
|