Mirrors/overte
3
0
Fork 0
mirror of https://github.com/overte-org/overte.git synced 2025-08-09 04:37:48 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Cleanup connection on node kills

Browse source
This commit is contained in:
Atlante45 2015-08-26 16:07:47 +02:00
parent 373d4b8944
commit c96632d4b6
2 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
libraries/networking/src/LimitedNodeList.cpp
View file

@ -428,6 +428,10 @@ void LimitedNodeList::handleNodeKill(const SharedNodePointer& node) {
qCDebug(networking) << "Killed" << *node; qCDebug(networking) << "Killed" << *node;
node->stopPingTimer(); node->stopPingTimer();
emit nodeKilled(node); emit nodeKilled(node);
if (auto activeSocket = node->getActiveSocket()) {
_nodeSocket.cleanupConnection(*activeSocket);
}
} }
SharedNodePointer LimitedNodeList::addOrUpdateNode(const QUuid& uuid, NodeType_t nodeType, SharedNodePointer LimitedNodeList::addOrUpdateNode(const QUuid& uuid, NodeType_t nodeType,

4
libraries/networking/src/udt/Socket.h
View file

@ -73,10 +73,12 @@ public:
ConnectionStats::Stats sampleStatsForConnection(const HifiSockAddr& destination); ConnectionStats::Stats sampleStatsForConnection(const HifiSockAddr& destination);
std::vector<HifiSockAddr> getConnectionSockAddrs(); std::vector<HifiSockAddr> getConnectionSockAddrs();
public slots:
void cleanupConnection(HifiSockAddr sockAddr);
private slots: private slots:
void readPendingDatagrams(); void readPendingDatagrams();
void rateControlSync(); void rateControlSync();
void cleanupConnection(HifiSockAddr sockAddr);
private: private:
void setSystemBufferSizes(); void setSystemBufferSizes();