Skip to content

Commit 7196df9

Browse files
committed
Fix a bit of mess in sendXXXToYYY functions
- Move sendString, sendPacket to Comm:: - Keep sendPacketPtr, sendNetstring to STKHost - Leave a few sendNetstring-s in Comm:: as deprecated. [skip ci]
1 parent f89d8fa commit 7196df9

25 files changed

Lines changed: 175 additions & 258 deletions

src/modes/capture_the_flag.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@
3535
#include "states_screens/race_gui.hpp"
3636
#include "tracks/track.hpp"
3737
#include "tracks/track_object_manager.hpp"
38+
#include "utils/communication.hpp"
3839
#include "utils/game_info.hpp"
3940
#include "utils/string_utils.hpp"
4041
#include "utils/translation.hpp"
@@ -346,7 +347,7 @@ void CaptureTheFlag::checkScoring(FlagColor color)
346347
packet.kart_score = (int16_t)new_kart_score;
347348
packet.red_score = (uint8_t)new_red_score;
348349
packet.blue_score = (uint8_t)new_blue_score;
349-
STKHost::get()->sendPacketToAllPeers(packet);
350+
Comm::sendPacketToPeers(packet);
350351
}
351352
ctfScored(active_holder, (red_active) ? false : true /*red_team_scored*/,
352353
new_kart_score, new_red_score, new_blue_score);

src/modes/free_for_all.cpp

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
#include "network/protocols/game_events_protocol.hpp"
2424
#include "network/stk_host.hpp"
2525
#include "tracks/track.hpp"
26+
#include "utils/communication.hpp"
2627
#include "utils/string_utils.hpp"
2728

2829
#include <algorithm>
@@ -136,7 +137,7 @@ void FreeForAll::handleScoreInServer(int kart_id, int hitter)
136137
packet.new_score = (int16_t)new_score;
137138
}
138139

139-
STKHost::get()->sendPacketToAllPeers(packet);
140+
Comm::sendPacketToPeers(packet);
140141
}
141142
} // handleScoreInServer
142143

@@ -362,6 +363,6 @@ void FreeForAll::notifyAboutScoreIfNonzero(int id)
362363
packet.hitter_kart = (uint8_t)id;
363364
packet.new_score = (int16_t)m_scores[id];
364365

365-
STKHost::get()->sendPacketToAllPeers(packet);
366+
Comm::sendPacketToPeers(packet);
366367
}
367368
} // notifyAboutScoreIfNonzero

src/modes/linear_world.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@
4747
#include "tracks/drive_node.hpp"
4848
#include "tracks/track_sector.hpp"
4949
#include "tracks/track.hpp"
50+
#include "utils/communication.hpp"
5051
#include "utils/constants.hpp"
5152
#include "utils/string_utils.hpp"
5253
#include "utils/translation.hpp"
@@ -1357,7 +1358,7 @@ void LinearWorld::updateCheckLinesServer(int check_id, int kart_id)
13571358
cm->getCheckStructure(i)->saveIsActive(kart_id));
13581359
}
13591360

1360-
STKHost::get()->sendPacketToAllPeers(packet);
1361+
Comm::sendPacketToPeers(packet);
13611362
} // updateCheckLinesServer
13621363

13631364
// ----------------------------------------------------------------------------

src/modes/soccer_world.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@
4343
#include "tracks/track.hpp"
4444
#include "tracks/track_object_manager.hpp"
4545
#include "tracks/track_sector.hpp"
46+
#include "utils/communication.hpp"
4647
#include "utils/constants.hpp"
4748
#include "utils/game_info.hpp"
4849
#include "utils/translation.hpp"
@@ -978,7 +979,7 @@ void SoccerWorld::updateBallPosition(int ticks)
978979

979980
ResetBallPacket packet;
980981
packet.reset_ball_ticks = m_reset_ball_ticks;
981-
STKHost::get()->sendPacketToAllPeers(packet);
982+
Comm::sendPacketToPeers(packet);
982983
}
983984
else if (!NetworkConfig::get()->isNetworking())
984985
{

src/network/network_console.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -210,7 +210,7 @@ void mainLoop(STKHost* host)
210210
message.pop_back();
211211
auto sl = LobbyProtocol::get<ServerLobby>();
212212
if (sl && !message.empty())
213-
Comm::sendStringToAllPeers(message);
213+
Comm::sendStringToPeers(message);
214214
}
215215
else
216216
{

src/network/protocol.hpp

Lines changed: 1 addition & 66 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
#define PROTOCOL_HPP
2525

2626
#include "utils/no_copy.hpp"
27+
#include "utils/constants.hpp"
2728

2829
#include <memory>
2930
#include <stddef.h>
@@ -121,72 +122,6 @@ class Protocol : public std::enable_shared_from_this<Protocol>,
121122
NetworkString* getNetworkString(size_t capacity = 16) const;
122123
bool checkDataSize(Event* event, unsigned int minimum_size);
123124

124-
// ----------------------------------------------------------------------------
125-
template<typename T>
126-
typename std::enable_if<std::is_base_of<Packet, T>::value, void>::type
127-
sendPacketToPeers(const T& packet,
128-
PacketReliabilityMode reliable = PRM_RELIABLE) const
129-
{
130-
std::shared_ptr<T> ptr1 = std::make_shared<T>(packet);
131-
std::shared_ptr<Packet> ptr2 = std::dynamic_pointer_cast<Packet>(ptr1);
132-
return sendPacketPtrToPeers(ptr2, reliable);
133-
}
134-
135-
template<typename T>
136-
typename std::enable_if<std::is_base_of<Packet, T>::value, void>::type
137-
sendPacketToPeersInServer(const T& packet,
138-
PacketReliabilityMode reliable = PRM_RELIABLE) const
139-
{
140-
std::shared_ptr<T> ptr1 = std::make_shared<T>(packet);
141-
std::shared_ptr<Packet> ptr2 = std::dynamic_pointer_cast<Packet>(ptr1);
142-
return sendPacketPtrToPeersInServer(ptr2, reliable);
143-
}
144-
145-
template<typename T>
146-
typename std::enable_if<std::is_base_of<Packet, T>::value, void>::type
147-
sendPacketToServer(const T& packet,
148-
PacketReliabilityMode reliable = PRM_RELIABLE)
149-
{
150-
std::shared_ptr<T> ptr1 = std::make_shared<T>(packet);
151-
std::shared_ptr<Packet> ptr2 = std::dynamic_pointer_cast<Packet>(ptr1);
152-
return sendPacketPtrToServer(ptr2, reliable);
153-
}
154-
155-
156-
template<typename T>
157-
typename std::enable_if<std::is_base_of<Packet, T>::value, void>::type
158-
sendPacketExcept(std::shared_ptr<STKPeer> peer, const T& packet,
159-
PacketReliabilityMode reliable = PRM_RELIABLE)
160-
{
161-
std::shared_ptr<T> ptr1 = std::make_shared<T>(packet);
162-
std::shared_ptr<Packet> ptr2 = std::dynamic_pointer_cast<Packet>(ptr1);
163-
return sendPacketPtrExcept(peer, ptr2, reliable);
164-
}
165-
166-
template<typename T>
167-
typename std::enable_if<std::is_base_of<Packet, T>::value, void>::type
168-
sendPacketToAllPeersWith(std::function<bool(std::shared_ptr<STKPeer>)> predicate,
169-
const T& packet, PacketReliabilityMode reliable = PRM_RELIABLE)
170-
{
171-
std::shared_ptr<T> ptr1 = std::make_shared<T>(packet);
172-
std::shared_ptr<Packet> ptr2 = std::dynamic_pointer_cast<Packet>(ptr1);
173-
return sendPacketPtrToAllPeersWith(predicate, ptr2, reliable);
174-
}
175-
// ----------------------------------------------------------------------------
176-
void sendPacketPtrToPeers(std::shared_ptr<Packet> packet,
177-
PacketReliabilityMode reliable = PRM_RELIABLE) const;
178-
179-
void sendPacketPtrToPeersInServer(std::shared_ptr<Packet> packet,
180-
PacketReliabilityMode reliable = PRM_RELIABLE) const;
181-
182-
void sendPacketPtrToServer(std::shared_ptr<Packet> packet,
183-
PacketReliabilityMode reliable = PRM_RELIABLE);
184-
185-
void sendPacketPtrExcept(std::shared_ptr<STKPeer> peer, std::shared_ptr<Packet> packet,
186-
PacketReliabilityMode reliable = PRM_RELIABLE);
187-
188-
void sendPacketPtrToAllPeersWith(std::function<bool(std::shared_ptr<STKPeer>)> predicate,
189-
std::shared_ptr<Packet> packet, PacketReliabilityMode reliable = PRM_RELIABLE);
190125
// ----------------------------------------------------------------------------
191126
virtual void requestStart();
192127
virtual void requestTerminate();

src/network/protocols/client_lobby.cpp

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,7 @@ void ClientLobby::setup()
178178
void ClientLobby::doneWithResults()
179179
{
180180
RaceFinishedAckPacket packet;
181-
sendPacketToServer(packet);
181+
Comm::sendPacketToServer(packet);
182182
} // doneWithResults
183183

184184
//-----------------------------------------------------------------------------
@@ -491,7 +491,7 @@ void ClientLobby::update(int ticks)
491491
}
492492
delete rest;
493493

494-
sendPacketToServer(packet);
494+
Comm::sendPacketToServer(packet);
495495

496496
if (encryption)
497497
{
@@ -502,7 +502,7 @@ void ClientLobby::update(int ticks)
502502
else
503503
{
504504
packet.player_info_unencrypted = subpacket;
505-
sendPacketToServer(packet);
505+
Comm::sendPacketToServer(packet);
506506
}
507507

508508

@@ -552,7 +552,7 @@ void ClientLobby::update(int ticks)
552552
// Send a message to the server to start
553553
m_auto_started = true;
554554
RequestBeginPacket packet;
555-
sendPacketToServer(packet);
555+
Comm::sendPacketToServer(packet);
556556
}
557557
if (m_background_download.joinable())
558558
{
@@ -1294,7 +1294,7 @@ void ClientLobby::finishedLoadingWorld()
12941294
{
12951295
FinishedLoadingLiveJoinPacket packet;
12961296
packet.m_override_synchronous = m_server_send_live_load_world;
1297-
sendPacketToServer(packet);
1297+
Comm::sendPacketToServer(packet);
12981298
} // finishedLoadingWorld
12991299

13001300
//-----------------------------------------------------------------------------
@@ -1402,7 +1402,7 @@ void ClientLobby::requestKartInfo(uint8_t kart_id)
14021402
{
14031403
KartInfoRequestPacket packet;
14041404
packet.kart_id = kart_id;
1405-
sendPacketToServer(packet);
1405+
Comm::sendPacketToServer(packet);
14061406
} // requestKartInfo
14071407

14081408
//-----------------------------------------------------------------------------
@@ -1542,7 +1542,7 @@ void ClientLobby::sendChat(irr::core::stringw text, KartTeam team)
15421542
if (team != KART_TEAM_NONE)
15431543
packet.kart_team = team;
15441544

1545-
sendPacketToServer(packet);
1545+
Comm::sendPacketToServer(packet);
15461546
}
15471547
} // sendChat
15481548

@@ -1890,7 +1890,7 @@ void ClientLobby::handleClientCommand(const std::string& cmd)
18901890
CommandPacket packet;
18911891
packet.language = UserConfigParams::m_language;
18921892
packet.command = cmd;
1893-
sendPacketToServer(packet);
1893+
Comm::sendPacketToServer(packet);
18941894
}
18951895
#endif
18961896
} // handleClientCommand
@@ -1933,7 +1933,7 @@ void ClientLobby::updateAssetsToServer()
19331933
{
19341934
NewAssetsPacket packet;
19351935
packet.assets = getKartsTracksPacket();
1936-
sendPacketToServer(packet);
1936+
Comm::sendPacketToServer(packet);
19371937
} // updateAssetsToServer
19381938

19391939
// ----------------------------------------------------------------------------

0 commit comments

Comments
 (0)