mirror of
https://github.com/overte-org/overte.git
synced 2025-08-07 10:09:46 +02:00
activate the public socket always for upstream/downstream servers
This commit is contained in:
parent
0e0f216aed
commit
8b7eaaa23a
3 changed files with 2 additions and 6 deletions
|
@ -103,11 +103,6 @@ AudioMixer::AudioMixer(ReceivedMessage& message) :
|
||||||
);
|
);
|
||||||
|
|
||||||
connect(nodeList.data(), &NodeList::nodeKilled, this, &AudioMixer::handleNodeKilled);
|
connect(nodeList.data(), &NodeList::nodeKilled, this, &AudioMixer::handleNodeKilled);
|
||||||
connect(nodeList.data(), &NodeList::nodeAdded, this, [this](const SharedNodePointer& node) {
|
|
||||||
if (node->getType() == NodeType::DownstreamAudioMixer) {
|
|
||||||
node->activatePublicSocket();
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void AudioMixer::queueAudioPacket(QSharedPointer<ReceivedMessage> message, SharedNodePointer node) {
|
void AudioMixer::queueAudioPacket(QSharedPointer<ReceivedMessage> message, SharedNodePointer node) {
|
||||||
|
|
|
@ -66,7 +66,6 @@ AvatarMixer::AvatarMixer(ReceivedMessage& message) :
|
||||||
connect(nodeList.data(), &NodeList::nodeAdded, this, [this](const SharedNodePointer& node) {
|
connect(nodeList.data(), &NodeList::nodeAdded, this, [this](const SharedNodePointer& node) {
|
||||||
if (node->getType() == NodeType::DownstreamAvatarMixer) {
|
if (node->getType() == NodeType::DownstreamAvatarMixer) {
|
||||||
getOrCreateClientData(node);
|
getOrCreateClientData(node);
|
||||||
node->activatePublicSocket();
|
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
|
@ -670,8 +670,10 @@ void NodeList::parseNodeFromPacketStream(QDataStream& packetStream) {
|
||||||
nodeLocalSocket, isReplicated, false, connectionUUID, permissions);
|
nodeLocalSocket, isReplicated, false, connectionUUID, permissions);
|
||||||
|
|
||||||
// nodes that are downstream or upstream of our own type are kept alive when we hear about them from the domain server
|
// nodes that are downstream or upstream of our own type are kept alive when we hear about them from the domain server
|
||||||
|
// and always have their public socket as their active socket
|
||||||
if (node->getType() == NodeType::downstreamType(_ownerType) || node->getType() == NodeType::upstreamType(_ownerType)) {
|
if (node->getType() == NodeType::downstreamType(_ownerType) || node->getType() == NodeType::upstreamType(_ownerType)) {
|
||||||
node->setLastHeardMicrostamp(usecTimestampNow());
|
node->setLastHeardMicrostamp(usecTimestampNow());
|
||||||
|
node->activatePublicSocket();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue