NetPlay: Fix hosting being stuck if player leaves during pending start

The logic didn't account for the case where a player leaves, so the
host would be left in a dangling state where the UI is disabled but the
game won't start, requiring a full restart of Dolphin to fix.
This commit is contained in:
Techjar 2019-03-28 02:32:06 -04:00
parent 75e74315e6
commit 7870704087
7 changed files with 95 additions and 27 deletions

View File

@ -85,6 +85,9 @@ NetPlayClient::~NetPlayClient()
m_MD5_thread.join(); m_MD5_thread.join();
m_do_loop.Clear(); m_do_loop.Clear();
m_thread.join(); m_thread.join();
m_chunked_data_receive_queue.clear();
m_dialog->HideChunkedProgressDialog();
} }
if (m_server) if (m_server)
@ -365,8 +368,10 @@ unsigned int NetPlayClient::OnData(sf::Packet& packet)
u32 cid; u32 cid;
packet >> cid; packet >> cid;
if (m_chunked_data_receive_queue.count(cid))
{
OnData(m_chunked_data_receive_queue[cid]); OnData(m_chunked_data_receive_queue[cid]);
m_chunked_data_receive_queue.erase(m_chunked_data_receive_queue.find(cid)); m_chunked_data_receive_queue.erase(cid);
m_dialog->HideChunkedProgressDialog(); m_dialog->HideChunkedProgressDialog();
sf::Packet complete_packet; sf::Packet complete_packet;
@ -374,6 +379,7 @@ unsigned int NetPlayClient::OnData(sf::Packet& packet)
complete_packet << cid; complete_packet << cid;
Send(complete_packet, CHUNKED_DATA_CHANNEL); Send(complete_packet, CHUNKED_DATA_CHANNEL);
} }
}
break; break;
case NP_MSG_CHUNKED_DATA_PAYLOAD: case NP_MSG_CHUNKED_DATA_PAYLOAD:
@ -381,6 +387,8 @@ unsigned int NetPlayClient::OnData(sf::Packet& packet)
u32 cid; u32 cid;
packet >> cid; packet >> cid;
if (m_chunked_data_receive_queue.count(cid))
{
while (!packet.endOfPacket()) while (!packet.endOfPacket())
{ {
u8 byte; u8 byte;
@ -397,6 +405,20 @@ unsigned int NetPlayClient::OnData(sf::Packet& packet)
progress_packet << sf::Uint64{m_chunked_data_receive_queue[cid].getDataSize()}; progress_packet << sf::Uint64{m_chunked_data_receive_queue[cid].getDataSize()};
Send(progress_packet, CHUNKED_DATA_CHANNEL); Send(progress_packet, CHUNKED_DATA_CHANNEL);
} }
}
break;
case NP_MSG_CHUNKED_DATA_ABORT:
{
u32 cid;
packet >> cid;
if (m_chunked_data_receive_queue.count(cid))
{
m_chunked_data_receive_queue.erase(cid);
m_dialog->HideChunkedProgressDialog();
}
}
break; break;
case NP_MSG_PAD_MAPPING: case NP_MSG_PAD_MAPPING:

View File

@ -53,7 +53,7 @@ public:
virtual void OnConnectionError(const std::string& message) = 0; virtual void OnConnectionError(const std::string& message) = 0;
virtual void OnTraversalError(TraversalClient::FailureReason error) = 0; virtual void OnTraversalError(TraversalClient::FailureReason error) = 0;
virtual void OnTraversalStateChanged(TraversalClient::State state) = 0; virtual void OnTraversalStateChanged(TraversalClient::State state) = 0;
virtual void OnSaveDataSyncFailure() = 0; virtual void OnGameStartAborted() = 0;
virtual void OnGolferChanged(bool is_golfer, const std::string& golfer_name) = 0; virtual void OnGolferChanged(bool is_golfer, const std::string& golfer_name) = 0;
virtual bool IsRecording() = 0; virtual bool IsRecording() = 0;

View File

@ -122,6 +122,7 @@ enum
NP_MSG_CHUNKED_DATA_PAYLOAD = 0x42, NP_MSG_CHUNKED_DATA_PAYLOAD = 0x42,
NP_MSG_CHUNKED_DATA_PROGRESS = 0x43, NP_MSG_CHUNKED_DATA_PROGRESS = 0x43,
NP_MSG_CHUNKED_DATA_COMPLETE = 0x44, NP_MSG_CHUNKED_DATA_COMPLETE = 0x44,
NP_MSG_CHUNKED_DATA_ABORT = 0x45,
NP_MSG_PAD_DATA = 0x60, NP_MSG_PAD_DATA = 0x60,
NP_MSG_PAD_MAPPING = 0x61, NP_MSG_PAD_MAPPING = 0x61,

View File

@ -353,8 +353,8 @@ unsigned int NetPlayServer::OnConnect(ENetPeer* socket, sf::Packet& rpac)
if (npver != Common::scm_rev_git_str) if (npver != Common::scm_rev_git_str)
return CON_ERR_VERSION_MISMATCH; return CON_ERR_VERSION_MISMATCH;
// game is currently running // game is currently running or game start is pending
if (m_is_running) if (m_is_running || m_start_pending)
return CON_ERR_GAME_RUNNING; return CON_ERR_GAME_RUNNING;
// too many players // too many players
@ -483,6 +483,13 @@ unsigned int NetPlayServer::OnDisconnect(const Client& player)
} }
} }
if (m_start_pending)
{
ChunkedDataAbort();
m_dialog->OnGameStartAborted();
m_start_pending = false;
}
sf::Packet spac; sf::Packet spac;
spac << (MessageId)NP_MSG_PLAYER_LEAVE; spac << (MessageId)NP_MSG_PLAYER_LEAVE;
spac << pid; spac << pid;
@ -1046,7 +1053,8 @@ unsigned int NetPlayServer::OnData(sf::Packet& packet, Client& player)
{ {
m_dialog->AppendChat( m_dialog->AppendChat(
StringFromFormat(GetStringT("%s failed to synchronize.").c_str(), player.name.c_str())); StringFromFormat(GetStringT("%s failed to synchronize.").c_str(), player.name.c_str()));
m_dialog->OnSaveDataSyncFailure(); m_dialog->OnGameStartAborted();
ChunkedDataAbort();
m_start_pending = false; m_start_pending = false;
} }
break; break;
@ -1089,6 +1097,7 @@ unsigned int NetPlayServer::OnData(sf::Packet& packet, Client& player)
{ {
m_dialog->AppendChat(StringFromFormat(GetStringT("%s failed to synchronize codes.").c_str(), m_dialog->AppendChat(StringFromFormat(GetStringT("%s failed to synchronize codes.").c_str(),
player.name.c_str())); player.name.c_str()));
m_dialog->OnGameStartAborted();
m_start_pending = false; m_start_pending = false;
} }
break; break;
@ -1954,10 +1963,21 @@ void NetPlayServer::ChunkedDataThreadFunc()
{ {
m_chunked_data_event.Wait(); m_chunked_data_event.Wait();
if (m_abort_chunked_data)
{
// thread-safe clear
while (!m_chunked_data_queue.Empty())
m_chunked_data_queue.Pop();
m_abort_chunked_data = false;
}
while (!m_chunked_data_queue.Empty()) while (!m_chunked_data_queue.Empty())
{ {
if (!m_do_loop) if (!m_do_loop)
return; return;
if (m_abort_chunked_data)
break;
auto& e = m_chunked_data_queue.Front(); auto& e = m_chunked_data_queue.Front();
const u32 id = m_next_chunked_data_id++; const u32 id = m_next_chunked_data_id++;
@ -1993,16 +2013,28 @@ void NetPlayServer::ChunkedDataThreadFunc()
const float bytes_per_second = const float bytes_per_second =
(std::max(Config::Get(Config::NETPLAY_CHUNKED_UPLOAD_LIMIT), 1u) / 8.0f) * 1024.0f; (std::max(Config::Get(Config::NETPLAY_CHUNKED_UPLOAD_LIMIT), 1u) / 8.0f) * 1024.0f;
const std::chrono::duration<double> send_interval(CHUNKED_DATA_UNIT_SIZE / bytes_per_second); const std::chrono::duration<double> send_interval(CHUNKED_DATA_UNIT_SIZE / bytes_per_second);
bool skip_wait = false;
size_t index = 0; size_t index = 0;
do do
{ {
if (!m_do_loop) if (!m_do_loop)
return; return;
if (m_abort_chunked_data)
{
sf::Packet pac;
pac << static_cast<MessageId>(NP_MSG_CHUNKED_DATA_ABORT);
pac << id;
ChunkedDataSend(std::move(pac), e.target_pid, e.target_mode);
break;
}
if (e.target_mode == TargetMode::Only) if (e.target_mode == TargetMode::Only)
{ {
if (m_players.find(e.target_pid) == m_players.end()) if (m_players.find(e.target_pid) == m_players.end())
{
skip_wait = true;
break; break;
} }
}
auto start = std::chrono::steady_clock::now(); auto start = std::chrono::steady_clock::now();
@ -2022,6 +2054,7 @@ void NetPlayServer::ChunkedDataThreadFunc()
} }
} while (index < e.packet.getDataSize()); } while (index < e.packet.getDataSize());
if (!m_abort_chunked_data)
{ {
sf::Packet pac; sf::Packet pac;
pac << static_cast<MessageId>(NP_MSG_CHUNKED_DATA_END); pac << static_cast<MessageId>(NP_MSG_CHUNKED_DATA_END);
@ -2029,9 +2062,10 @@ void NetPlayServer::ChunkedDataThreadFunc()
ChunkedDataSend(std::move(pac), e.target_pid, e.target_mode); ChunkedDataSend(std::move(pac), e.target_pid, e.target_mode);
} }
while (m_chunked_data_complete_count[id] < player_count && m_do_loop) while (m_chunked_data_complete_count[id] < player_count && m_do_loop &&
!m_abort_chunked_data && !skip_wait)
m_chunked_data_complete_event.Wait(); m_chunked_data_complete_event.Wait();
m_chunked_data_complete_count.erase(m_chunked_data_complete_count.find(id)); m_chunked_data_complete_count.erase(id);
m_dialog->HideChunkedProgressDialog(); m_dialog->HideChunkedProgressDialog();
m_chunked_data_queue.Pop(); m_chunked_data_queue.Pop();
@ -2052,4 +2086,11 @@ void NetPlayServer::ChunkedDataSend(sf::Packet&& packet, const PlayerId pid,
SendAsyncToClients(std::move(packet), pid, CHUNKED_DATA_CHANNEL); SendAsyncToClients(std::move(packet), pid, CHUNKED_DATA_CHANNEL);
} }
} }
void NetPlayServer::ChunkedDataAbort()
{
m_abort_chunked_data = true;
m_chunked_data_event.Set();
m_chunked_data_complete_event.Set();
}
} // namespace NetPlay } // namespace NetPlay

View File

@ -137,8 +137,9 @@ private:
std::vector<std::pair<std::string, std::string>> GetInterfaceListInternal() const; std::vector<std::pair<std::string, std::string>> GetInterfaceListInternal() const;
void ChunkedDataThreadFunc(); void ChunkedDataThreadFunc();
void ChunkedDataSend(sf::Packet&& packet, PlayerId pid, const TargetMode target_mode); void ChunkedDataSend(sf::Packet&& packet, PlayerId pid, const TargetMode target_mode);
void SetupIndex(); void ChunkedDataAbort();
void SetupIndex();
bool PlayerHasControllerMapped(PlayerId pid) const; bool PlayerHasControllerMapped(PlayerId pid) const;
NetSettings m_settings; NetSettings m_settings;
@ -185,6 +186,7 @@ private:
std::thread m_chunked_data_thread; std::thread m_chunked_data_thread;
u32 m_next_chunked_data_id; u32 m_next_chunked_data_id;
std::unordered_map<u32, unsigned int> m_chunked_data_complete_count; std::unordered_map<u32, unsigned int> m_chunked_data_complete_count;
bool m_abort_chunked_data = false;
ENetHost* m_server = nullptr; ENetHost* m_server = nullptr;
TraversalClient* m_traversal_client = nullptr; TraversalClient* m_traversal_client = nullptr;

View File

@ -553,6 +553,8 @@ void NetPlayDialog::show(std::string nickname, bool use_traversal)
m_game_button->setEnabled(is_hosting); m_game_button->setEnabled(is_hosting);
m_kick_button->setEnabled(false); m_kick_button->setEnabled(false);
SetOptionsEnabled(true);
QDialog::show(); QDialog::show();
UpdateGUI(); UpdateGUI();
} }
@ -973,7 +975,7 @@ void NetPlayDialog::OnTraversalStateChanged(TraversalClient::State state)
} }
} }
void NetPlayDialog::OnSaveDataSyncFailure() void NetPlayDialog::OnGameStartAborted()
{ {
QueueOnObject(this, [this] { SetOptionsEnabled(true); }); QueueOnObject(this, [this] { SetOptionsEnabled(true); });
} }

View File

@ -57,7 +57,7 @@ public:
void OnConnectionError(const std::string& message) override; void OnConnectionError(const std::string& message) override;
void OnTraversalError(TraversalClient::FailureReason error) override; void OnTraversalError(TraversalClient::FailureReason error) override;
void OnTraversalStateChanged(TraversalClient::State state) override; void OnTraversalStateChanged(TraversalClient::State state) override;
void OnSaveDataSyncFailure() override; void OnGameStartAborted() override;
void OnGolferChanged(bool is_golfer, const std::string& golfer_name) override; void OnGolferChanged(bool is_golfer, const std::string& golfer_name) override;
bool IsRecording() override; bool IsRecording() override;