piwalker/dolphin
1
0
Fork 0
mirror of https://github.com/dolphin-emu/dolphin.git synced 2025-07-25 07:09:48 -06:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #9550 from endrift/gba-flush

Browse Source 
SI/DeviceGBA: Ensure data socket isn't backed up
This commit is contained in:
Léo Lam
2021-03-05 10:38:55 +01:00
committed by GitHub
parent de30559862 f6e9003ddc
commit a4de2502c5
2 changed files with 36 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
Source/Core/Core/HW/SI/SI_DeviceGBA.cpp
View File

@ -253,7 +253,7 @@ void GBASockServer::Send(const u8* si_buffer)
Disconnect(); Disconnect();
} }
int GBASockServer::Receive(u8* si_buffer) int GBASockServer::Receive(u8* si_buffer, u8 bytes)
{ {
if (!m_client) if (!m_client)
return 0; return 0;
@ -267,8 +267,7 @@ int GBASockServer::Receive(u8* si_buffer)
size_t num_received = 0; size_t num_received = 0;
std::array<u8, RECV_MAX_SIZE> recv_data; std::array<u8, RECV_MAX_SIZE> recv_data;
sf::Socket::Status recv_stat = sf::Socket::Status recv_stat = m_client->receive(recv_data.data(), bytes, num_received);
m_client->receive(recv_data.data(), recv_data.size(), num_received);
if (recv_stat == sf::Socket::Disconnected) if (recv_stat == sf::Socket::Disconnected)
{ {
Disconnect(); Disconnect();
@ -286,6 +285,21 @@ int GBASockServer::Receive(u8* si_buffer)
return static_cast<int>(std::min(num_received, recv_data.size())); return static_cast<int>(std::min(num_received, recv_data.size()));
} }
void GBASockServer::Flush()
{
if (!m_client || !m_booted)
return;
size_t num_received = 1;
u8 byte;
while (num_received)
{
sf::Socket::Status recv_stat = m_client->receive(&byte, 1, num_received);
if (recv_stat == sf::Socket::Disconnected)
break;
}
}
CSIDevice_GBA::CSIDevice_GBA(SIDevices device, int device_number) : ISIDevice(device, device_number) CSIDevice_GBA::CSIDevice_GBA(SIDevices device, int device_number) : ISIDevice(device, device_number)
{ {
} }
@ -329,7 +343,23 @@ int CSIDevice_GBA::RunBuffer(u8* buffer, int request_length)
case NextAction::ReceiveResponse: case NextAction::ReceiveResponse:
{ {
int num_data_received = m_sock_server.Receive(buffer); u8 bytes = 1;
switch (m_last_cmd)
{
case CMD_RESET:
case CMD_STATUS:
bytes = 3;
break;
case CMD_READ:
bytes = 5;
break;
default:
break;
}
int num_data_received = m_sock_server.Receive(buffer, bytes);
if (m_last_cmd == CMD_STATUS && num_data_received == 3)
m_sock_server.Flush();
m_next_action = NextAction::SendCommand; m_next_action = NextAction::SendCommand;
if (num_data_received == 0) if (num_data_received == 0)
{ {

3
Source/Core/Core/HW/SI/SI_DeviceGBA.h
View File

@ -28,7 +28,8 @@ public:
bool IsConnected(); bool IsConnected();
void ClockSync(); void ClockSync();
void Send(const u8* si_buffer); void Send(const u8* si_buffer);
int Receive(u8* si_buffer); int Receive(u8* si_buffer, u8 bytes);
void Flush();
private: private:
void Disconnect(); void Disconnect();