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

tinkering around

Browse source
This commit is contained in:
Perttu Ahola 2010-12-25 11:27:14 +02:00
parent ed6039d472
commit c37eb9b139
5 changed files with 21 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/connection.cpp
View file

@ -671,7 +671,7 @@ SharedBuffer<u8> Channel::ProcessPacket(
con->PrintInfo();
dout_con<<"DISCO: Removing peer "<<(peer_id)<<std::endl;
if(con->deletePeer(peer_id) == false)
if(con->deletePeer(peer_id, false) == false)
{
con->PrintInfo(derr_con);
derr_con<<"DISCO: Peer not found"<<std::endl;
@ -1301,15 +1301,13 @@ nextpeer:
continue;
}
// Remove timeouted peers
// Remove timed out peers
core::list<u16>::Iterator i = timeouted_peers.begin();
for(; i != timeouted_peers.end(); i++)
{
PrintInfo(derr_con);
derr_con<<"RunTimeouts(): Removing peer "<<(*i)<<std::endl;
m_peerhandler->deletingPeer(m_peers[*i], true);
delete m_peers[*i];
m_peers.remove(*i);
deletePeer(*i, true);
}
}
@ -1355,11 +1353,11 @@ core::list<Peer*> Connection::GetPeers()
return list;
}
bool Connection::deletePeer(u16 peer_id)
bool Connection::deletePeer(u16 peer_id, bool timeout)
{
if(m_peers.find(peer_id) == NULL)
return false;
m_peerhandler->deletingPeer(m_peers[peer_id], true);
m_peerhandler->deletingPeer(m_peers[peer_id], timeout);
delete m_peers[peer_id];
m_peers.remove(peer_id);
return true;