oss/luanti
oss/luanti
1
0
Fork 0
mirror of https://github.com/luanti-org/luanti.git synced 2025-06-27 16:36:03 +00:00
Code Wiki Activity

Extend check for lingering clinets

Browse source
This commit is contained in:
sfan5 2025-05-27 11:31:16 +02:00
parent 957ebf7368
commit 9ce9d7f433
4 changed files with 12 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

1
src/network/serverpackethandler.cpp
View file

@ -302,6 +302,7 @@ void Server::handleCommand_Init2(NetworkPacket* pkt)
sendMediaAnnouncement(peer_id, lang);
RemoteClient *client = getClient(peer_id, CS_InitDone);
assert(client);
// Keep client language for server translations
client->setLangCode(lang);

2
src/script/lua_api/l_server.cpp
View file

@ -261,7 +261,7 @@ int ModApiServer::l_get_player_information(lua_State *L)
lua_settable(L, table);
lua_pushstring(L,"state");
lua_pushstring(L, ClientInterface::state2Name(info.state).c_str());
lua_pushstring(L, ClientInterface::state2Name(info.state));
lua_settable(L, table);
#endif

13
src/server/clientiface.cpp
View file

@ -47,7 +47,7 @@ const char *ClientInterface::statenames[] = {
"SudoMode",
};
std::string ClientInterface::state2Name(ClientState state)
const char *ClientInterface::state2Name(ClientState state)
{
return statenames[state];
}
@ -703,16 +703,13 @@ void ClientInterface::step(float dtime)
RecursiveMutexAutoLock clientslock(m_clients_mutex);
for (const auto &it : m_clients) {
auto state = it.second->getState();
if (state >= CS_HelloSent)
if (state >= CS_InitDone)
continue;
if (it.second->uptime() <= LINGER_TIMEOUT)
continue;
// CS_Created means nobody has even noticed the client is there
// (this is before on_prejoinplayer runs)
// CS_Invalid should not happen
// -> log those as warning, the rest as info
std::ostream &os = state == CS_Created || state == CS_Invalid ?
warningstream : infostream;
// Complain louder if this situation is unexpected
auto &os = state == CS_Disconnecting || state == CS_Denied ?
infostream : warningstream;
try {
Address addr = m_con->GetPeerAddress(it.second->peer_id);
os << "Disconnecting lingering client from "

7
src/server/clientiface.h
View file

@ -495,7 +495,8 @@ public:
m_env = env;
}
static std::string state2Name(ClientState state);
static const char *state2Name(ClientState state);
protected:
class AutoLock {
public:
@ -526,5 +527,7 @@ private:
static const char *statenames[];
static constexpr int LINGER_TIMEOUT = 10;
// Note that this puts a fixed timeout on the init & auth phase for a client.
// (lingering is enforced until CS_InitDone)
static constexpr int LINGER_TIMEOUT = 12;
};