From ad148587dcf5244c2d2011dba339786c765c54c4 Mon Sep 17 00:00:00 2001 From: Elias Fleckenstein Date: Wed, 4 Nov 2020 16:19:54 +0100 Subject: Make Lint Happy --- src/clientiface.cpp | 230 ++++++++++++++++++++++++++-------------------------- 1 file changed, 116 insertions(+), 114 deletions(-) (limited to 'src/clientiface.cpp') diff --git a/src/clientiface.cpp b/src/clientiface.cpp index 602a44c90..9effa7eb7 100644 --- a/src/clientiface.cpp +++ b/src/clientiface.cpp @@ -34,33 +34,33 @@ with this program; if not, write to the Free Software Foundation, Inc., #include "face_position_cache.h" const char *ClientInterface::statenames[] = { - "Invalid", - "Disconnecting", - "Denied", - "Created", - "AwaitingInit2", - "HelloSent", - "InitDone", - "DefinitionsSent", - "Active", - "SudoMode", + "Invalid", + "Disconnecting", + "Denied", + "Created", + "AwaitingInit2", + "HelloSent", + "InitDone", + "DefinitionsSent", + "Active", + "SudoMode", }; - - std::string ClientInterface::state2Name(ClientState state) { return statenames[state]; } RemoteClient::RemoteClient() : - m_max_simul_sends(g_settings->getU16("max_simultaneous_block_sends_per_client")), - m_min_time_from_building( - g_settings->getFloat("full_block_send_enable_min_time_from_building")), - m_max_send_distance(g_settings->getS16("max_block_send_distance")), - m_block_optimize_distance(g_settings->getS16("block_send_optimize_distance")), - m_max_gen_distance(g_settings->getS16("max_block_generate_distance")), - m_occ_cull(g_settings->getBool("server_side_occlusion_culling")) + m_max_simul_sends(g_settings->getU16( + "max_simultaneous_block_sends_per_client")), + m_min_time_from_building(g_settings->getFloat( + "full_block_send_enable_min_time_from_building")), + m_max_send_distance(g_settings->getS16("max_block_send_distance")), + m_block_optimize_distance( + g_settings->getS16("block_send_optimize_distance")), + m_max_gen_distance(g_settings->getS16("max_block_generate_distance")), + m_occ_cull(g_settings->getBool("server_side_occlusion_culling")) { } @@ -90,11 +90,8 @@ LuaEntitySAO *getAttachedObject(PlayerSAO *sao, ServerEnvironment *env) return dynamic_cast(ao); } -void RemoteClient::GetNextBlocks ( - ServerEnvironment *env, - EmergeManager * emerge, - float dtime, - std::vector &dest) +void RemoteClient::GetNextBlocks(ServerEnvironment *env, EmergeManager *emerge, + float dtime, std::vector &dest) { // Increment timers m_nothing_to_send_pause_timer -= dtime; @@ -114,15 +111,15 @@ void RemoteClient::GetNextBlocks ( // Won't send anything if already sending if (m_blocks_sending.size() >= m_max_simul_sends) { - //infostream<<"Not sending any blocks, Queue full."<getBasePosition(); // if the player is attached, get the velocity from the attached object LuaEntitySAO *lsao = getAttachedObject(sao, env); - const v3f &playerspeed = lsao? lsao->getVelocity() : player->getSpeed(); - v3f playerspeeddir(0,0,0); + const v3f &playerspeed = lsao ? lsao->getVelocity() : player->getSpeed(); + v3f playerspeeddir(0, 0, 0); if (playerspeed.getLength() > 1.0f * BS) playerspeeddir = playerspeed / playerspeed.getLength(); // Predict to next block @@ -134,7 +131,7 @@ void RemoteClient::GetNextBlocks ( // Camera position and direction v3f camera_pos = sao->getEyePosition(); - v3f camera_dir = v3f(0,0,1); + v3f camera_dir = v3f(0, 0, 1); camera_dir.rotateYZBy(sao->getLookPitch()); camera_dir.rotateXZBy(sao->getRotation().Y); @@ -157,14 +154,14 @@ void RemoteClient::GetNextBlocks ( if (m_nearest_unsent_reset_timer > 20.0f) { m_nearest_unsent_reset_timer = 0.0f; m_nearest_unsent_d = 0; - //infostream<<"Resetting m_nearest_unsent_d for " + // infostream<<"Resetting m_nearest_unsent_d for " // <getPlayerName(peer_id)< &blocks) +void RemoteClient::SetBlocksNotSent(std::map &blocks) { m_nearest_unsent_d = 0; m_nothing_to_send_pause_timer = 0; @@ -461,10 +468,9 @@ void RemoteClient::SetBlocksNotSent(std::map &blocks) void RemoteClient::notifyEvent(ClientStateEvent event) { std::ostringstream myerror; - switch (m_state) - { + switch (m_state) { case CS_Invalid: - //intentionally do nothing + // intentionally do nothing break; case CS_Created: switch (event) { @@ -490,13 +496,12 @@ void RemoteClient::notifyEvent(ClientStateEvent event) /* don't do anything if in denied state */ break; case CS_HelloSent: - switch(event) - { + switch (event) { case CSE_AuthAccept: m_state = CS_AwaitingInit2; if (chosen_mech == AUTH_MECHANISM_SRP || chosen_mech == AUTH_MECHANISM_LEGACY_PASSWORD) - srp_verifier_delete((SRPVerifier *) auth_data); + srp_verifier_delete((SRPVerifier *)auth_data); chosen_mech = AUTH_MECHANISM_NONE; break; case CSE_Disconnect: @@ -506,17 +511,17 @@ void RemoteClient::notifyEvent(ClientStateEvent event) m_state = CS_Denied; if (chosen_mech == AUTH_MECHANISM_SRP || chosen_mech == AUTH_MECHANISM_LEGACY_PASSWORD) - srp_verifier_delete((SRPVerifier *) auth_data); + srp_verifier_delete((SRPVerifier *)auth_data); chosen_mech = AUTH_MECHANISM_NONE; break; default: - myerror << "HelloSent: Invalid client state transition! " << event; + myerror << "HelloSent: Invalid client state transition! " + << event; throw ClientStateError(myerror.str()); } break; case CS_AwaitingInit2: - switch(event) - { + switch (event) { case CSE_GotInit2: confirmSerializationVersion(); m_state = CS_InitDone; @@ -536,8 +541,7 @@ void RemoteClient::notifyEvent(ClientStateEvent event) break; case CS_InitDone: - switch(event) - { + switch (event) { case CSE_SetDefinitionsSent: m_state = CS_DefinitionsSent; break; @@ -555,8 +559,7 @@ void RemoteClient::notifyEvent(ClientStateEvent event) } break; case CS_DefinitionsSent: - switch(event) - { + switch (event) { case CSE_SetClientReady: m_state = CS_Active; break; @@ -568,13 +571,13 @@ void RemoteClient::notifyEvent(ClientStateEvent event) break; /* Init GotInit2 SetDefinitionsSent */ default: - myerror << "DefinitionsSent: Invalid client state transition! " << event; + myerror << "DefinitionsSent: Invalid client state transition! " + << event; throw ClientStateError(myerror.str()); } break; case CS_Active: - switch(event) - { + switch (event) { case CSE_SetDenied: m_state = CS_Denied; break; @@ -584,7 +587,7 @@ void RemoteClient::notifyEvent(ClientStateEvent event) case CSE_SudoSuccess: m_state = CS_SudoMode; if (chosen_mech == AUTH_MECHANISM_SRP) - srp_verifier_delete((SRPVerifier *) auth_data); + srp_verifier_delete((SRPVerifier *)auth_data); chosen_mech = AUTH_MECHANISM_NONE; break; /* Init GotInit2 SetDefinitionsSent SetMediaSent SetDenied */ @@ -595,8 +598,7 @@ void RemoteClient::notifyEvent(ClientStateEvent event) } break; case CS_SudoMode: - switch(event) - { + switch (event) { case CSE_SetDenied: m_state = CS_Denied; break; @@ -623,13 +625,9 @@ u64 RemoteClient::uptime() const return porting::getTimeS() - m_connection_time; } -ClientInterface::ClientInterface(const std::shared_ptr & con) -: - m_con(con), - m_env(NULL), - m_print_info_timer(0.0f) +ClientInterface::ClientInterface(const std::shared_ptr &con) : + m_con(con), m_env(NULL), m_print_info_timer(0.0f) { - } ClientInterface::~ClientInterface() { @@ -693,9 +691,8 @@ void ClientInterface::UpdatePlayerList() std::vector clients = getClientIDs(); m_clients_names.clear(); - if (!clients.empty()) - infostream<<"Players:"<getPlayer(i); @@ -707,7 +704,7 @@ void ClientInterface::UpdatePlayerList() { RecursiveMutexAutoLock clientslock(m_clients_mutex); - RemoteClient* client = lockedGetClientNoEx(i); + RemoteClient *client = lockedGetClientNoEx(i); if (client) client->PrintInfo(infostream); } @@ -717,8 +714,8 @@ void ClientInterface::UpdatePlayerList() } } -void ClientInterface::send(session_t peer_id, u8 channelnum, - NetworkPacket *pkt, bool reliable) +void ClientInterface::send( + session_t peer_id, u8 channelnum, NetworkPacket *pkt, bool reliable) { m_con->Send(peer_id, channelnum, pkt, reliable); } @@ -731,14 +728,17 @@ void ClientInterface::sendToAll(NetworkPacket *pkt) if (client->net_proto_version != 0) { m_con->Send(client->peer_id, - clientCommandFactoryTable[pkt->getCommand()].channel, pkt, - clientCommandFactoryTable[pkt->getCommand()].reliable); + clientCommandFactoryTable[pkt->getCommand()] + .channel, + pkt, + clientCommandFactoryTable[pkt->getCommand()] + .reliable); } } } -void ClientInterface::sendToAllCompat(NetworkPacket *pkt, NetworkPacket *legacypkt, - u16 min_proto_ver) +void ClientInterface::sendToAllCompat( + NetworkPacket *pkt, NetworkPacket *legacypkt, u16 min_proto_ver) { RecursiveMutexAutoLock clientslock(m_clients_mutex); for (auto &client_it : m_clients) { @@ -751,18 +751,20 @@ void ClientInterface::sendToAllCompat(NetworkPacket *pkt, NetworkPacket *legacyp pkt_to_send = legacypkt; } else { warningstream << "Client with unhandled version to handle: '" - << client->net_proto_version << "'"; + << client->net_proto_version << "'"; continue; } m_con->Send(client->peer_id, - clientCommandFactoryTable[pkt_to_send->getCommand()].channel, - pkt_to_send, - clientCommandFactoryTable[pkt_to_send->getCommand()].reliable); + clientCommandFactoryTable[pkt_to_send->getCommand()] + .channel, + pkt_to_send, + clientCommandFactoryTable[pkt_to_send->getCommand()] + .reliable); } } -RemoteClient* ClientInterface::getClientNoEx(session_t peer_id, ClientState state_min) +RemoteClient *ClientInterface::getClientNoEx(session_t peer_id, ClientState state_min) { RecursiveMutexAutoLock clientslock(m_clients_mutex); RemoteClientMap::const_iterator n = m_clients.find(peer_id); @@ -777,7 +779,8 @@ RemoteClient* ClientInterface::getClientNoEx(session_t peer_id, ClientState stat return NULL; } -RemoteClient* ClientInterface::lockedGetClientNoEx(session_t peer_id, ClientState state_min) +RemoteClient *ClientInterface::lockedGetClientNoEx( + session_t peer_id, ClientState state_min) { RemoteClientMap::const_iterator n = m_clients.find(peer_id); // The client may not exist; clients are immediately removed if their @@ -827,14 +830,14 @@ void ClientInterface::DeleteClient(session_t peer_id) /* Mark objects to be not known by the client */ - //TODO this should be done by client destructor!!! + // TODO this should be done by client destructor!!! RemoteClient *client = n->second; // Handle objects for (u16 id : client->m_known_objects) { // Get object - ServerActiveObject* obj = m_env->getActiveObject(id); + ServerActiveObject *obj = m_env->getActiveObject(id); - if(obj && obj->m_known_by_count > 0) + if (obj && obj->m_known_by_count > 0) obj->m_known_by_count--; } @@ -850,7 +853,8 @@ void ClientInterface::CreateClient(session_t peer_id) // Error check RemoteClientMap::iterator n = m_clients.find(peer_id); // The client shouldn't already exist - if (n != m_clients.end()) return; + if (n != m_clients.end()) + return; // Create client RemoteClient *client = new RemoteClient(); @@ -872,10 +876,8 @@ void ClientInterface::event(session_t peer_id, ClientStateEvent event) n->second->notifyEvent(event); } - if ((event == CSE_SetClientReady) || - (event == CSE_Disconnect) || - (event == CSE_SetDenied)) - { + if ((event == CSE_SetClientReady) || (event == CSE_Disconnect) || + (event == CSE_SetDenied)) { UpdatePlayerList(); } } @@ -894,8 +896,8 @@ u16 ClientInterface::getProtocolVersion(session_t peer_id) return n->second->net_proto_version; } -void ClientInterface::setClientVersion(session_t peer_id, u8 major, u8 minor, u8 patch, - const std::string &full) +void ClientInterface::setClientVersion( + session_t peer_id, u8 major, u8 minor, u8 patch, const std::string &full) { RecursiveMutexAutoLock conlock(m_clients_mutex); -- cgit v1.2.3