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

NetPlay: use move semantics instead of unique_ptrs

Browse Source
This commit is contained in:
Michael Maltese
2017-02-09 16:58:27 -08:00
parent 30f0ebf95e
commit 1834833edd
4 changed files with 66 additions and 67 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
Source/Core/Core/NetPlayClient.cpp
View File

@ -614,7 +614,7 @@ void NetPlayClient::Disconnect()
m_server = nullptr; m_server = nullptr;
} }
void NetPlayClient::SendAsync(std::unique_ptr<sf::Packet> packet) void NetPlayClient::SendAsync(sf::Packet&& packet)
{ {
{ {
std::lock_guard<std::recursive_mutex> lkq(m_crit.async_queue_write); std::lock_guard<std::recursive_mutex> lkq(m_crit.async_queue_write);
@ -635,7 +635,7 @@ void NetPlayClient::ThreadFunc()
net = enet_host_service(m_client, &netEvent, 250); net = enet_host_service(m_client, &netEvent, 250);
while (!m_async_queue.Empty()) while (!m_async_queue.Empty())
{ {
Send(*(m_async_queue.Front().get())); Send(m_async_queue.Front());
m_async_queue.Pop(); m_async_queue.Pop();
} }
if (net > 0) if (net > 0)
@ -733,9 +733,9 @@ std::vector<const Player*> NetPlayClient::GetPlayers()
// called from ---GUI--- thread // called from ---GUI--- thread
void NetPlayClient::SendChatMessage(const std::string& msg) void NetPlayClient::SendChatMessage(const std::string& msg)
{ {
auto spac = std::make_unique<sf::Packet>(); sf::Packet spac;
*spac << static_cast<MessageId>(NP_MSG_CHAT_MESSAGE); spac << static_cast<MessageId>(NP_MSG_CHAT_MESSAGE);
*spac << msg; spac << msg;
SendAsync(std::move(spac)); SendAsync(std::move(spac));
} }
@ -743,11 +743,11 @@ void NetPlayClient::SendChatMessage(const std::string& msg)
// called from ---CPU--- thread // called from ---CPU--- thread
void NetPlayClient::SendPadState(const int in_game_pad, const GCPadStatus& pad) void NetPlayClient::SendPadState(const int in_game_pad, const GCPadStatus& pad)
{ {
auto spac = std::make_unique<sf::Packet>(); sf::Packet spac;
*spac << static_cast<MessageId>(NP_MSG_PAD_DATA); spac << static_cast<MessageId>(NP_MSG_PAD_DATA);
*spac << static_cast<PadMapping>(in_game_pad); spac << static_cast<PadMapping>(in_game_pad);
*spac << pad.button << pad.analogA << pad.analogB << pad.stickX << pad.stickY << pad.substickX spac << pad.button << pad.analogA << pad.analogB << pad.stickX << pad.stickY << pad.substickX
<< pad.substickY << pad.triggerLeft << pad.triggerRight; << pad.substickY << pad.triggerLeft << pad.triggerRight;
SendAsync(std::move(spac)); SendAsync(std::move(spac));
} }
@ -755,13 +755,13 @@ void NetPlayClient::SendPadState(const int in_game_pad, const GCPadStatus& pad)
// called from ---CPU--- thread // called from ---CPU--- thread
void NetPlayClient::SendWiimoteState(const int in_game_pad, const NetWiimote& nw) void NetPlayClient::SendWiimoteState(const int in_game_pad, const NetWiimote& nw)
{ {
auto spac = std::make_unique<sf::Packet>(); sf::Packet spac;
*spac << static_cast<MessageId>(NP_MSG_WIIMOTE_DATA); spac << static_cast<MessageId>(NP_MSG_WIIMOTE_DATA);
*spac << static_cast<PadMapping>(in_game_pad); spac << static_cast<PadMapping>(in_game_pad);
*spac << static_cast<u8>(nw.size()); spac << static_cast<u8>(nw.size());
for (auto it : nw) for (auto it : nw)
{ {
*spac << it; spac << it;
} }
SendAsync(std::move(spac)); SendAsync(std::move(spac));
@ -770,9 +770,9 @@ void NetPlayClient::SendWiimoteState(const int in_game_pad, const NetWiimote& nw
// called from ---GUI--- thread // called from ---GUI--- thread
void NetPlayClient::SendStartGamePacket() void NetPlayClient::SendStartGamePacket()
{ {
auto spac = std::make_unique<sf::Packet>(); sf::Packet spac;
*spac << static_cast<MessageId>(NP_MSG_START_GAME); spac << static_cast<MessageId>(NP_MSG_START_GAME);
*spac << m_current_game; spac << m_current_game;
SendAsync(std::move(spac)); SendAsync(std::move(spac));
} }
@ -780,8 +780,8 @@ void NetPlayClient::SendStartGamePacket()
// called from ---GUI--- thread // called from ---GUI--- thread
void NetPlayClient::SendStopGamePacket() void NetPlayClient::SendStopGamePacket()
{ {
auto spac = std::make_unique<sf::Packet>(); sf::Packet spac;
*spac << static_cast<MessageId>(NP_MSG_STOP_GAME); spac << static_cast<MessageId>(NP_MSG_STOP_GAME);
SendAsync(std::move(spac)); SendAsync(std::move(spac));
} }
@ -1193,11 +1193,11 @@ void NetPlayClient::SendTimeBase()
u64 timebase = SystemTimers::GetFakeTimeBase(); u64 timebase = SystemTimers::GetFakeTimeBase();
auto spac = std::make_unique<sf::Packet>(); sf::Packet spac;
*spac << static_cast<MessageId>(NP_MSG_TIMEBASE); spac << static_cast<MessageId>(NP_MSG_TIMEBASE);
*spac << static_cast<u32>(timebase); spac << static_cast<u32>(timebase);
*spac << static_cast<u32>(timebase << 32); spac << static_cast<u32>(timebase << 32);
*spac << netplay_client->m_timebase_frame++; spac << netplay_client->m_timebase_frame++;
netplay_client->SendAsync(std::move(spac)); netplay_client->SendAsync(std::move(spac));
} }

5
Source/Core/Core/NetPlayClient.h
View File

@ -7,7 +7,6 @@
#include <SFML/Network/Packet.hpp> #include <SFML/Network/Packet.hpp>
#include <array> #include <array>
#include <map> #include <map>
#include <memory>
#include <mutex> #include <mutex>
#include <string> #include <string>
#include <thread> #include <thread>
@ -65,7 +64,7 @@ class NetPlayClient : public TraversalClientClient
{ {
public: public:
void ThreadFunc(); void ThreadFunc();
void SendAsync(std::unique_ptr<sf::Packet> packet); void SendAsync(sf::Packet&& packet);
NetPlayClient(const std::string& address, const u16 port, NetPlayUI* dialog, NetPlayClient(const std::string& address, const u16 port, NetPlayUI* dialog,
const std::string& name, bool traversal, const std::string& centralServer, const std::string& name, bool traversal, const std::string& centralServer,
@ -111,7 +110,7 @@ protected:
std::recursive_mutex async_queue_write; std::recursive_mutex async_queue_write;
} m_crit; } m_crit;
Common::FifoQueue<std::unique_ptr<sf::Packet>, false> m_async_queue; Common::FifoQueue<sf::Packet, false> m_async_queue;
std::array<Common::FifoQueue<GCPadStatus>, 4> m_pad_buffer; std::array<Common::FifoQueue<GCPadStatus>, 4> m_pad_buffer;
std::array<Common::FifoQueue<NetWiimote>, 4> m_wiimote_buffer; std::array<Common::FifoQueue<NetWiimote>, 4> m_wiimote_buffer;

74
Source/Core/Core/NetPlayServer.cpp
View File

@ -129,7 +129,7 @@ void NetPlayServer::ThreadFunc()
{ {
{ {
std::lock_guard<std::recursive_mutex> lkp(m_crit.players); std::lock_guard<std::recursive_mutex> lkp(m_crit.players);
SendToClients(*(m_async_queue.Front().get())); SendToClients(m_async_queue.Front());
} }
m_async_queue.Pop(); m_async_queue.Pop();
} }
@ -456,14 +456,14 @@ void NetPlayServer::AdjustPadBufferSize(unsigned int size)
m_target_buffer_size = size; m_target_buffer_size = size;
// tell clients to change buffer size // tell clients to change buffer size
auto spac = std::make_unique<sf::Packet>(); sf::Packet spac;
*spac << static_cast<MessageId>(NP_MSG_PAD_BUFFER); spac << static_cast<MessageId>(NP_MSG_PAD_BUFFER);
*spac << static_cast<u32>(m_target_buffer_size); spac << static_cast<u32>(m_target_buffer_size);
SendAsyncToClients(std::move(spac)); SendAsyncToClients(std::move(spac));
} }
void NetPlayServer::SendAsyncToClients(std::unique_ptr<sf::Packet> packet) void NetPlayServer::SendAsyncToClients(sf::Packet&& packet)
{ {
{ {
std::lock_guard<std::recursive_mutex> lkq(m_crit.async_queue_write); std::lock_guard<std::recursive_mutex> lkq(m_crit.async_queue_write);
@ -723,10 +723,10 @@ void NetPlayServer::OnTraversalStateChanged()
// called from ---GUI--- thread // called from ---GUI--- thread
void NetPlayServer::SendChatMessage(const std::string& msg) void NetPlayServer::SendChatMessage(const std::string& msg)
{ {
auto spac = std::make_unique<sf::Packet>(); sf::Packet spac;
*spac << static_cast<MessageId>(NP_MSG_CHAT_MESSAGE); spac << static_cast<MessageId>(NP_MSG_CHAT_MESSAGE);
*spac << static_cast<PlayerId>(0); // server id always 0 spac << static_cast<PlayerId>(0); // server id always 0
*spac << msg; spac << msg;
SendAsyncToClients(std::move(spac)); SendAsyncToClients(std::move(spac));
} }
@ -739,9 +739,9 @@ bool NetPlayServer::ChangeGame(const std::string& game)
m_selected_game = game; m_selected_game = game;
// send changed game to clients // send changed game to clients
auto spac = std::make_unique<sf::Packet>(); sf::Packet spac;
*spac << static_cast<MessageId>(NP_MSG_CHANGE_GAME); spac << static_cast<MessageId>(NP_MSG_CHANGE_GAME);
*spac << game; spac << game;
SendAsyncToClients(std::move(spac)); SendAsyncToClients(std::move(spac));
@ -751,9 +751,9 @@ bool NetPlayServer::ChangeGame(const std::string& game)
// called from ---GUI--- thread // called from ---GUI--- thread
bool NetPlayServer::ComputeMD5(const std::string& file_identifier) bool NetPlayServer::ComputeMD5(const std::string& file_identifier)
{ {
auto spac = std::make_unique<sf::Packet>(); sf::Packet spac;
*spac << static_cast<MessageId>(NP_MSG_COMPUTE_MD5); spac << static_cast<MessageId>(NP_MSG_COMPUTE_MD5);
*spac << file_identifier; spac << file_identifier;
SendAsyncToClients(std::move(spac)); SendAsyncToClients(std::move(spac));
@ -763,8 +763,8 @@ bool NetPlayServer::ComputeMD5(const std::string& file_identifier)
// called from ---GUI--- thread // called from ---GUI--- thread
bool NetPlayServer::AbortMD5() bool NetPlayServer::AbortMD5()
{ {
auto spac = std::make_unique<sf::Packet>(); sf::Packet spac;
*spac << static_cast<MessageId>(NP_MSG_MD5_ABORT); spac << static_cast<MessageId>(NP_MSG_MD5_ABORT);
SendAsyncToClients(std::move(spac)); SendAsyncToClients(std::move(spac));
@ -794,26 +794,26 @@ bool NetPlayServer::StartGame()
g_netplay_initial_rtc = Common::Timer::GetLocalTimeSinceJan1970(); g_netplay_initial_rtc = Common::Timer::GetLocalTimeSinceJan1970();
// tell clients to start game // tell clients to start game
auto spac = std::make_unique<sf::Packet>(); sf::Packet spac;
*spac << (MessageId)NP_MSG_START_GAME; spac << (MessageId)NP_MSG_START_GAME;
*spac << m_current_game; spac << m_current_game;
*spac << m_settings.m_CPUthread; spac << m_settings.m_CPUthread;
*spac << m_settings.m_CPUcore; spac << m_settings.m_CPUcore;
*spac << m_settings.m_EnableCheats; spac << m_settings.m_EnableCheats;
*spac << m_settings.m_SelectedLanguage; spac << m_settings.m_SelectedLanguage;
*spac << m_settings.m_OverrideGCLanguage; spac << m_settings.m_OverrideGCLanguage;
*spac << m_settings.m_ProgressiveScan; spac << m_settings.m_ProgressiveScan;
*spac << m_settings.m_PAL60; spac << m_settings.m_PAL60;
*spac << m_settings.m_DSPEnableJIT; spac << m_settings.m_DSPEnableJIT;
*spac << m_settings.m_DSPHLE; spac << m_settings.m_DSPHLE;
*spac << m_settings.m_WriteToMemcard; spac << m_settings.m_WriteToMemcard;
*spac << m_settings.m_CopyWiiSave; spac << m_settings.m_CopyWiiSave;
*spac << m_settings.m_OCEnable; spac << m_settings.m_OCEnable;
*spac << m_settings.m_OCFactor; spac << m_settings.m_OCFactor;
*spac << m_settings.m_EXIDevice[0]; spac << m_settings.m_EXIDevice[0];
*spac << m_settings.m_EXIDevice[1]; spac << m_settings.m_EXIDevice[1];
*spac << (u32)g_netplay_initial_rtc; spac << (u32)g_netplay_initial_rtc;
*spac << (u32)(g_netplay_initial_rtc >> 32); spac << (u32)(g_netplay_initial_rtc >> 32);
SendAsyncToClients(std::move(spac)); SendAsyncToClients(std::move(spac));

4
Source/Core/Core/NetPlayServer.h
View File

@ -26,7 +26,7 @@ class NetPlayServer : public TraversalClientClient
{ {
public: public:
void ThreadFunc(); void ThreadFunc();
void SendAsyncToClients(std::unique_ptr<sf::Packet> packet); void SendAsyncToClients(sf::Packet&& packet);
NetPlayServer(const u16 port, bool traversal, const std::string& centralServer, u16 centralPort); NetPlayServer(const u16 port, bool traversal, const std::string& centralServer, u16 centralPort);
~NetPlayServer(); ~NetPlayServer();
@ -118,7 +118,7 @@ private:
std::string m_selected_game; std::string m_selected_game;
std::thread m_thread; std::thread m_thread;
Common::FifoQueue<std::unique_ptr<sf::Packet>, false> m_async_queue; Common::FifoQueue<sf::Packet, false> m_async_queue;
ENetHost* m_server = nullptr; ENetHost* m_server = nullptr;
TraversalClient* m_traversal_client = nullptr; TraversalClient* m_traversal_client = nullptr;