Mirrors/overte
3
0
Fork 0
mirror of https://github.com/overte-org/overte.git synced 2025-08-06 19:59:28 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

handle socketActivated

Browse source
This commit is contained in:
Brad Hefta-Gaub 2015-11-17 15:55:41 -08:00
parent 9c4286b6ca
commit 073215d067
2 changed files with 16 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
libraries/networking/src/MessagesClient.cpp
View file

@ -84,7 +84,6 @@ void MessagesClient::subscribe(const QString& channel) {
auto packetList = NLPacketList::create(PacketType::MessagesSubscribe, QByteArray(), true, true); auto packetList = NLPacketList::create(PacketType::MessagesSubscribe, QByteArray(), true, true);
packetList->write(channel.toUtf8()); packetList->write(channel.toUtf8());
nodeList->sendPacketList(std::move(packetList), *messagesMixer); nodeList->sendPacketList(std::move(packetList), *messagesMixer);
qDebug() << "sending MessagesSubscribe for channel:" << channel;
} }
} }
@ -102,10 +101,20 @@ void MessagesClient::unsubscribe(const QString& channel) {
void MessagesClient::handleNodeAdded(SharedNodePointer node) { void MessagesClient::handleNodeAdded(SharedNodePointer node) {
if (node->getType() == NodeType::MessagesMixer) { if (node->getType() == NodeType::MessagesMixer) {
qDebug() << "messages-mixer node type added..."; if (!node->getActiveSocket()) {
for (const auto& channel : _subscribedChannels) { connect(node.data(), &NetworkPeer::socketActivated, this, &MessagesClient::socketActivated);
qDebug() << "subscribing to channel:" << channel; } else {
subscribe(channel); resubscribeToAll();
} }
} }
} }
void MessagesClient::socketActivated(const HifiSockAddr& sockAddr) {
resubscribeToAll();
}
void MessagesClient::resubscribeToAll() {
for (const auto& channel : _subscribedChannels) {
subscribe(channel);
}
}

2
libraries/networking/src/MessagesClient.h
View file

@ -38,8 +38,10 @@ signals:
private slots: private slots:
void handleMessagesPacket(QSharedPointer<NLPacketList> packetList, SharedNodePointer senderNode); void handleMessagesPacket(QSharedPointer<NLPacketList> packetList, SharedNodePointer senderNode);
void handleNodeAdded(SharedNodePointer node); void handleNodeAdded(SharedNodePointer node);
void socketActivated(const HifiSockAddr& sockAddr);
protected: protected:
void resubscribeToAll();
QSet<QString> _subscribedChannels; QSet<QString> _subscribedChannels;
}; };