manually activate sockets for downstream servers

This commit is contained in:
Stephen Birarda 2017-06-13 15:46:14 -07:00
parent 50f46dafa6
commit 9085a0896a
3 changed files with 7 additions and 3 deletions
assignment-client/src
libraries/networking/src

View file

@ -169,7 +169,7 @@ void AudioMixerClientData::optionallyReplicatePacket(ReceivedMessage& message, c
packet->write(message.getMessage());
}
nodeList->sendUnreliablePacket(*packet, downstreamNode->getPublicSocket());
nodeList->sendUnreliablePacket(*packet, *downstreamNode);
}
});
}

View file

@ -146,7 +146,7 @@ void AvatarMixer::optionallyReplicatePacket(ReceivedMessage& message, const Node
packet->write(message.getMessage());
}
nodeList->sendUnreliablePacket(*packet, node->getPublicSocket());
nodeList->sendUnreliablePacket(*packet, *node);
});
}
}
@ -402,7 +402,7 @@ void AvatarMixer::nodeKilled(SharedNodePointer killedNode) {
replicatedKillPacket->writePrimitive(KillAvatarReason::AvatarDisconnected);
}
nodeList->sendUnreliablePacket(*replicatedKillPacket, node->getPublicSocket());
nodeList->sendUnreliablePacket(*replicatedKillPacket, *node);
}
});

View file

@ -163,6 +163,10 @@ void ThreadedAssignment::parseDownstreamServers(const QJsonObject& settingsObjec
// manually add the downstream node to our node list
auto node = nodeList->addOrUpdateNode(QUuid::createUuid(), NodeType::downstreamType(nodeType),
downstreamServerAddr, downstreamServerAddr);
// manually activate the public socket for the downstream node
node->activatePublicSocket();
callback(*node);
}
}