spacebar/rust-nex
6
0
Fork 0
Code Issues Pull requests Projects Releases Packages 50 Wiki Activity Actions

yet another attempt

Browse source
This commit is contained in:
Maple 2026-04-24 23:05:53 +02:00
commit 757ca292b9
1 changed files with 16 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

36
rnex-core/src/nex/matchmake.rs
View file

@ -239,33 +239,29 @@ impl ExtendedMatchmakeSession {
continue; continue;
} */ } */
for pid in &list_of_connected_pids { // for pid in &list_of_connected_pids {
if other_conn.pid != self.session.gathering.host_pid && other_conn.pid == *pid { other_conn
continue; .remote
} .process_notification_event(NotificationEvent {
other_conn pid_source: initiating_pid,
.remote notif_type: 3001,
.process_notification_event(NotificationEvent { param_1: self.session.gathering.self_gid as PID,
pid_source: initiating_pid, param_2: other_conn.pid,
notif_type: 3001, str_param: join_msg.clone(),
param_1: self.session.gathering.self_gid as PID, param_3: self.connected_players.len() as _,
param_2: *pid, })
str_param: join_msg.clone(), .await;
param_3: self.connected_players.len() as _, // }
})
.await;
}
} }
for old_conns in &old_particip { for old_conns in &old_particip {
let Some(old_conns) = old_conns.upgrade() else { let Some(old_conns) = old_conns.upgrade() else {
continue; continue;
}; };
if old_conns.pid != self.session.gathering.host_pid {
continue;
}
for new_conn_pid in conns.iter().filter_map(Weak::upgrade).map(|c| c.pid) { for new_conn_pid in conns.iter().filter_map(Weak::upgrade).map(|c| c.pid) {
if old_conns.pid != self.session.gathering.host_pid && old_conns.pid == new_conn_pid
{
continue;
}
old_conns old_conns
.remote .remote
.process_notification_event(NotificationEvent { .process_notification_event(NotificationEvent {