edg-l/ddnet
1
0
Fork 0
mirror of https://github.com/ddnet/ddnet.git synced 2024-11-20 06:58:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

Try to prevent network spamming issues

Browse source
This commit is contained in:
def 2013-07-30 22:48:31 +02:00
parent 764a73e997
commit e871fbbaad
3 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
src/engine/shared/network.h
View file

@ -187,6 +187,7 @@ public:
// Needed for GotProblems in NetClient // Needed for GotProblems in NetClient
int64 LastRecvTime() const { return m_LastRecvTime; } int64 LastRecvTime() const { return m_LastRecvTime; }
int64 ConnectTime() const { return m_LastUpdateTime; }
int AckSequence() const { return m_Ack; } int AckSequence() const { return m_Ack; }
}; };

3
src/engine/shared/network_conn.cpp
View file

@ -124,8 +124,7 @@ int CNetConnection::QueueChunkEx(int Flags, int DataSize, const void *pData, int
} }
else else
{ {
// out of buffer // out of buffer, don't save the packet and hope nobody will ask for resend
Disconnect("too weak connection (out of buffer)");
return -1; return -1;
} }
} }

8
src/engine/shared/network_server.cpp
View file

@ -69,11 +69,17 @@ int CNetServer::Drop(int ClientID, const char *pReason)
int CNetServer::Update() int CNetServer::Update()
{ {
int64 Now = time_get();
for(int i = 0; i < MaxClients(); i++) for(int i = 0; i < MaxClients(); i++)
{ {
m_aSlots[i].m_Connection.Update(); m_aSlots[i].m_Connection.Update();
if(m_aSlots[i].m_Connection.State() == NET_CONNSTATE_ERROR) if(m_aSlots[i].m_Connection.State() == NET_CONNSTATE_ERROR)
Drop(i, m_aSlots[i].m_Connection.ErrorString()); {
if (Now - m_aSlots[i].m_Connection.ConnectTime() < time_freq() && NetBan())
NetBan()->BanAddr(ClientAddr(i), 60, "Stressing network");
else
Drop(i, m_aSlots[i].m_Connection.ErrorString());
}
} }
return 0; return 0;