asgardius/virtualx-engine
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

Merge pull request #55952 from Faless/net/4.x_webrtc_mp_connect_fix

Browse source
This commit is contained in:
Rémi Verschelde 2021-12-15 12:38:10 +01:00 committed by GitHub
commit 703a1be507
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
modules/webrtc/webrtc_multiplayer_peer.cpp
View file

@ -146,6 +146,10 @@ void WebRTCMultiplayerPeer::_find_next_peer() {
} }
// After last. // After last.
while (E) { while (E) {
if (!E->get()->connected) {
E = E->next();
continue;
}
for (const Ref<WebRTCDataChannel> &F : E->get()->channels) { for (const Ref<WebRTCDataChannel> &F : E->get()->channels) {
if (F->get_available_packet_count()) { if (F->get_available_packet_count()) {
next_packet_peer = E->key(); next_packet_peer = E->key();
@ -157,6 +161,10 @@ void WebRTCMultiplayerPeer::_find_next_peer() {
E = peer_map.front(); E = peer_map.front();
// Before last // Before last
while (E) { while (E) {
if (!E->get()->connected) {
E = E->next();
continue;
}
for (const Ref<WebRTCDataChannel> &F : E->get()->channels) { for (const Ref<WebRTCDataChannel> &F : E->get()->channels) {
if (F->get_available_packet_count()) { if (F->get_available_packet_count()) {
next_packet_peer = E->key(); next_packet_peer = E->key();
@ -378,6 +386,9 @@ int WebRTCMultiplayerPeer::get_available_packet_count() const {
} }
int size = 0; int size = 0;
for (const KeyValue<int, Ref<ConnectedPeer>> &E : peer_map) { for (const KeyValue<int, Ref<ConnectedPeer>> &E : peer_map) {
if (!E.value->connected) {
continue;
}
for (const Ref<WebRTCDataChannel> &F : E.value->channels) { for (const Ref<WebRTCDataChannel> &F : E.value->channels) {
size += F->get_available_packet_count(); size += F->get_available_packet_count();
} }