pcsx2/pcsx2/CDVD/CDVDdiscReader.cpp

555 lines
12 KiB
C++

/* PCSX2 - PS2 Emulator for PCs
* Copyright (C) 2002-2020 PCSX2 Dev Team
*
* PCSX2 is free software: you can redistribute it and/or modify it under the terms
* of the GNU Lesser General Public License as published by the Free Software Found-
* ation, either version 3 of the License, or (at your option) any later version.
*
* PCSX2 is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
* without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
* PURPOSE. See the GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License along with PCSX2.
* If not, see <http://www.gnu.org/licenses/>.
*/
#include "PrecompiledHeader.h"
#include "CDVDdiscReader.h"
#include "CDVD/CDVD.h"
#include <condition_variable>
#include <mutex>
#include <thread>
void (*newDiscCB)();
static std::mutex s_keepalive_lock;
static std::condition_variable s_keepalive_cv;
static std::thread s_keepalive_thread;
///////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////
// State Information //
u8 strack;
u8 etrack;
track tracks[100];
int curDiskType;
int curTrayStatus;
static u32 csector;
int cmode;
int lastReadInNewDiskCB = 0;
u8 directReadSectorBuffer[2448];
///////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////
// Utility Functions //
inline u8 dec_to_bcd(u8 dec)
{
return ((dec / 10) << 4) | (dec % 10);
}
inline void lsn_to_msf(u8* minute, u8* second, u8* frame, u32 lsn)
{
*frame = dec_to_bcd(lsn % 75);
lsn /= 75;
*second = dec_to_bcd(lsn % 60);
lsn /= 60;
*minute = dec_to_bcd(lsn % 100);
}
// TocStuff
void cdvdParseTOC()
{
tracks[1].start_lba = 0;
if (!src->GetSectorCount())
{
curDiskType = CDVD_TYPE_NODISC;
strack = 1;
etrack = 0;
return;
}
if (src->GetMediaType() >= 0)
{
tracks[1].type = CDVD_MODE1_TRACK;
strack = 1;
etrack = 1;
return;
}
strack = 0xFF;
etrack = 0;
for (auto& entry : src->ReadTOC())
{
if (entry.track < 1 || entry.track > 99)
continue;
strack = std::min(strack, entry.track);
etrack = std::max(etrack, entry.track);
tracks[entry.track].start_lba = entry.lba;
if ((entry.control & 0x0C) == 0x04)
{
std::array<u8, 2352> buffer;
// Byte 15 of a raw CD data sector determines the track mode
if (src->ReadSectors2352(entry.lba, 1, buffer.data()) && (buffer[15] & 3) == 2)
{
tracks[entry.track].type = CDVD_MODE2_TRACK;
}
else
{
tracks[entry.track].type = CDVD_MODE1_TRACK;
}
}
else
{
tracks[entry.track].type = CDVD_AUDIO_TRACK;
}
fprintf(stderr, "Track %u start sector: %u\n", entry.track, entry.lba);
}
}
///////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////
// CDVD processing functions //
std::atomic<bool> s_keepalive_is_open;
bool disc_has_changed = false;
bool weAreInNewDiskCB = false;
std::unique_ptr<IOCtlSrc> src;
extern u32 g_last_sector_block_lsn;
///////////////////////////////////////////////////////////////////////////////
// keepAliveThread throws a read event regularly to prevent drive spin down //
void keepAliveThread()
{
u8 throwaway[2352];
printf(" * CDVD: KeepAlive thread started...\n");
std::unique_lock<std::mutex> guard(s_keepalive_lock);
while (!s_keepalive_cv.wait_for(guard, std::chrono::seconds(30),
[]() { return !s_keepalive_is_open; }))
{
//printf(" * keepAliveThread: polling drive.\n");
if (src->GetMediaType() >= 0)
src->ReadSectors2048(g_last_sector_block_lsn, 1, throwaway);
else
src->ReadSectors2352(g_last_sector_block_lsn, 1, throwaway);
}
printf(" * CDVD: KeepAlive thread finished.\n");
}
bool StartKeepAliveThread()
{
if (s_keepalive_is_open == false)
{
s_keepalive_is_open = true;
s_keepalive_thread = std::thread(keepAliveThread);
}
return s_keepalive_is_open;
}
void StopKeepAliveThread()
{
if (!s_keepalive_thread.joinable())
return;
{
std::lock_guard<std::mutex> guard(s_keepalive_lock);
s_keepalive_is_open = false;
}
s_keepalive_cv.notify_one();
s_keepalive_thread.join();
}
s32 CALLBACK DISCopen(const char* pTitle)
{
std::string drive(pTitle);
GetValidDrive(drive);
if (drive.empty())
return -1;
// open device file
src = std::make_unique<IOCtlSrc>(std::move(drive));
if (!src->Reopen())
{
src.reset();
return -1;
}
//setup threading manager
cdvdStartThread();
StartKeepAliveThread();
return cdvdRefreshData();
}
void CALLBACK DISCclose()
{
StopKeepAliveThread();
cdvdStopThread();
//close device
src.reset();
}
s32 CALLBACK DISCreadTrack(u32 lsn, int mode)
{
csector = lsn;
cmode = mode;
if (weAreInNewDiskCB)
{
int ret = cdvdDirectReadSector(lsn, mode, directReadSectorBuffer);
if (ret == 0)
lastReadInNewDiskCB = 1;
return ret;
}
cdvdRequestSector(lsn, mode);
return 0;
}
s32 CALLBACK DISCgetBuffer(u8* dest)
{
// Do nothing for out of bounds disc sector reads. It prevents some games
// from hanging (All-Star Baseball 2005, Hello Kitty: Roller Rescue,
// Hot Wheels: Beat That! (NTSC), Ratchet & Clank 3 (PAL),
// Test Drive: Eve of Destruction, etc.).
if (csector >= src->GetSectorCount())
return 0;
int csize = 2352;
switch (cmode)
{
case CDVD_MODE_2048:
csize = 2048;
break;
case CDVD_MODE_2328:
csize = 2328;
break;
case CDVD_MODE_2340:
csize = 2340;
break;
}
if (lastReadInNewDiskCB)
{
lastReadInNewDiskCB = 0;
memcpy(dest, directReadSectorBuffer, csize);
return 0;
}
memcpy(dest, cdvdGetSector(csector, cmode), csize);
return 0;
}
s32 CALLBACK DISCreadSubQ(u32 lsn, cdvdSubQ* subq)
{
// the formatted subq command returns: control/adr, track, index, trk min, trk sec, trk frm, 0x00, abs min, abs sec, abs frm
if (lsn >= src->GetSectorCount())
return -1;
memset(subq, 0, sizeof(cdvdSubQ));
lsn_to_msf(&subq->discM, &subq->discS, &subq->discF, lsn + 150);
u8 i = strack;
while (i < etrack && lsn >= tracks[i + 1].start_lba)
++i;
lsn -= tracks[i].start_lba;
lsn_to_msf(&subq->trackM, &subq->trackS, &subq->trackF, lsn);
subq->mode = 1;
subq->ctrl = tracks[i].type;
subq->trackNum = i;
subq->trackIndex = 1;
return 0;
}
s32 CALLBACK DISCgetTN(cdvdTN* Buffer)
{
Buffer->strack = strack;
Buffer->etrack = etrack;
return 0;
}
s32 CALLBACK DISCgetTD(u8 Track, cdvdTD* Buffer)
{
if (Track == 0)
{
if (src == nullptr)
return -1;
Buffer->lsn = src->GetSectorCount();
Buffer->type = 0;
return 0;
}
if (Track < strack)
return -1;
if (Track > etrack)
return -1;
Buffer->lsn = tracks[Track].start_lba;
Buffer->type = tracks[Track].type;
return 0;
}
s32 CALLBACK DISCgetTOC(void* toc)
{
u8* tocBuff = static_cast<u8*>(toc);
if (curDiskType == CDVD_TYPE_NODISC)
return -1;
if (curDiskType == CDVD_TYPE_DETCTDVDS || curDiskType == CDVD_TYPE_DETCTDVDD)
{
memset(tocBuff, 0, 2048);
s32 mt = src->GetMediaType();
if (mt < 0)
return -1;
if (mt == 0)
{ //single layer
// Single Layer - Values are fixed.
tocBuff[0] = 0x04;
tocBuff[1] = 0x02;
tocBuff[2] = 0xF2;
tocBuff[3] = 0x00;
tocBuff[4] = 0x86;
tocBuff[5] = 0x72;
// These values are fixed on all discs, except position 14 which is the OTP/PTP flags which are 0 in single layer.
tocBuff[12] = 0x01;
tocBuff[13] = 0x02;
tocBuff[14] = 0x01; // Single layer.
tocBuff[15] = 0x00;
// Values are fixed.
tocBuff[16] = 0x00; // first sector for layer 0
tocBuff[17] = 0x03;
tocBuff[18] = 0x00;
tocBuff[19] = 0x00;
cdvdTD trackInfo;
if (DISCgetTD(0, &trackInfo) == -1)
trackInfo.lsn = 0;
// Max LSN in the TOC is calculated as the blocks + 0x30000, then - 1.
// same as layer 1 start.
const s32 maxlsn = trackInfo.lsn + (0x30000 - 1);
tocBuff[20] = maxlsn >> 24;
tocBuff[21] = (maxlsn >> 16) & 0xff;
tocBuff[22] = (maxlsn >> 8) & 0xff;
tocBuff[23] = (maxlsn >> 0) & 0xff;
}
else if (mt == 1)
{ //PTP
const s32 layer1start = src->GetLayerBreakAddress() + 0x30000;
// dual sided
tocBuff[0] = 0x24;
tocBuff[1] = 0x02;
tocBuff[2] = 0xF2;
tocBuff[3] = 0x00;
tocBuff[4] = 0x41;
tocBuff[5] = 0x95;
// These values are fixed on all discs, except position 14 which is the OTP/PTP flags.
tocBuff[12] = 0x01;
tocBuff[13] = 0x02;
tocBuff[14] = 0x21; // PTP
tocBuff[15] = 0x10;
// Values are fixed.
tocBuff[16] = 0x00;
tocBuff[17] = 0x03;
tocBuff[18] = 0x00;
tocBuff[19] = 0x00;
tocBuff[20] = (layer1start >> 24);
tocBuff[21] = (layer1start >> 16) & 0xff;
tocBuff[22] = (layer1start >> 8) & 0xff;
tocBuff[23] = (layer1start >> 0) & 0xff;
}
else
{ //OTP
const s32 layer1start = src->GetLayerBreakAddress() + 0x30000;
// dual sided
tocBuff[0] = 0x24;
tocBuff[1] = 0x02;
tocBuff[2] = 0xF2;
tocBuff[3] = 0x00;
tocBuff[4] = 0x41;
tocBuff[5] = 0x95;
// These values are fixed on all discs, except position 14 which is the OTP/PTP flags.
tocBuff[12] = 0x01;
tocBuff[13] = 0x02;
tocBuff[14] = 0x31; // OTP
tocBuff[15] = 0x10;
// Values are fixed.
tocBuff[16] = 0x00;
tocBuff[17] = 0x03;
tocBuff[18] = 0x00;
tocBuff[19] = 0x00;
tocBuff[24] = (layer1start >> 24);
tocBuff[25] = (layer1start >> 16) & 0xff;
tocBuff[26] = (layer1start >> 8) & 0xff;
tocBuff[27] = (layer1start >> 0) & 0xff;
}
}
else if (curDiskType == CDVD_TYPE_DETCTCD)
{
// cd toc
// (could be replaced by 1 command that reads the full toc)
u8 min, sec, frm, i;
s32 err;
cdvdTN diskInfo;
cdvdTD trackInfo;
memset(tocBuff, 0, 1024);
if (DISCgetTN(&diskInfo) == -1)
{
diskInfo.etrack = 0;
diskInfo.strack = 1;
}
if (DISCgetTD(0, &trackInfo) == -1)
trackInfo.lsn = 0;
tocBuff[0] = 0x41;
tocBuff[1] = 0x00;
//Number of FirstTrack
tocBuff[2] = 0xA0;
tocBuff[7] = dec_to_bcd(diskInfo.strack);
//Number of LastTrack
tocBuff[12] = 0xA1;
tocBuff[17] = dec_to_bcd(diskInfo.etrack);
//DiskLength
lba_to_msf(trackInfo.lsn, &min, &sec, &frm);
tocBuff[22] = 0xA2;
tocBuff[27] = dec_to_bcd(min);
tocBuff[28] = dec_to_bcd(sec);
tocBuff[29] = dec_to_bcd(frm);
fprintf(stderr, "Track 0: %u mins %u secs %u frames\n", min, sec, frm);
for (i = diskInfo.strack; i <= diskInfo.etrack; i++)
{
err = DISCgetTD(i, &trackInfo);
lba_to_msf(trackInfo.lsn, &min, &sec, &frm);
tocBuff[i * 10 + 30] = trackInfo.type;
tocBuff[i * 10 + 32] = err == -1 ? 0 : dec_to_bcd(i); //number
tocBuff[i * 10 + 37] = dec_to_bcd(min);
tocBuff[i * 10 + 38] = dec_to_bcd(sec);
tocBuff[i * 10 + 39] = dec_to_bcd(frm);
fprintf(stderr, "Track %u: %u mins %u secs %u frames\n", i, min, sec, frm);
}
}
else
return -1;
return 0;
}
s32 CALLBACK DISCgetDiskType()
{
return curDiskType;
}
s32 CALLBACK DISCgetTrayStatus()
{
return curTrayStatus;
}
s32 CALLBACK DISCctrlTrayOpen()
{
curTrayStatus = CDVD_TRAY_OPEN;
return 0;
}
s32 CALLBACK DISCctrlTrayClose()
{
curTrayStatus = CDVD_TRAY_CLOSE;
return 0;
}
void CALLBACK DISCnewDiskCB(void (*callback)())
{
newDiscCB = callback;
}
s32 CALLBACK DISCreadSector(u8* buffer, u32 lsn, int mode)
{
return cdvdDirectReadSector(lsn, mode, buffer);
}
s32 CALLBACK DISCgetDualInfo(s32* dualType, u32* _layer1start)
{
if (src == nullptr)
return -1;
switch (src->GetMediaType())
{
case 1:
*dualType = 1;
*_layer1start = src->GetLayerBreakAddress() + 1;
return 0;
case 2:
*dualType = 2;
*_layer1start = src->GetLayerBreakAddress() + 1;
return 0;
case 0:
*dualType = 0;
*_layer1start = 0;
return 0;
}
return -1;
}
CDVD_API CDVDapi_Disc =
{
DISCclose,
DISCopen,
DISCreadTrack,
DISCgetBuffer,
DISCreadSubQ,
DISCgetTN,
DISCgetTD,
DISCgetTOC,
DISCgetDiskType,
DISCgetTrayStatus,
DISCctrlTrayOpen,
DISCctrlTrayClose,
DISCnewDiskCB,
DISCreadSector,
DISCgetDualInfo,
};