kitten/rust-nex
Watch
1
0
Fork
You've already forked rust-nex
 0
forked from spacebar/rust-nex
Code Pull requests Activity

reduce gc time and improve unreachable session detection

Browse source
This commit is contained in:
Maple Nebel 2026-05-31 16:47:01 +02:00
commit f51fc3a1db
2 changed files with 8 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -95,8 +95,8 @@ impl MatchmakeManager {
while let Some(this) = this.upgrade() {
this.garbage_collect().await;
// every 30 minutes
sleep(Duration::from_secs(60 * 30)).await;
// every 5 minutes
sleep(Duration::from_secs(60 * 5)).await;
}
});
}
@ -300,12 +300,12 @@ impl ExtendedMatchmakeSession {
}
}
pub fn has_active_players(&self) -> bool {
pub fn has_min_active_players(&self) -> bool {
self.connected_players
.iter()
.filter(|v| v.upgrade().is_some())
.count()
!= 0
>= self.session.gathering.minimum_participants as _
}
#[inline]
@ -313,14 +313,14 @@ impl ExtendedMatchmakeSession {
self.get_active_players()
.any(|v| v.pid == self.session.gathering.host_pid)
&& (if self.session.gathering.flags & PERSISTENT_GATHERING != 0 {
if self.has_active_players() {
if self.has_min_active_players() {
true
} else {
self.session.open_participation
}
} else {
self.has_active_players()
}) & self.has_active_players()
self.has_min_active_players()
}) & self.has_min_active_players()
}
#[inline]
pub fn is_joinable(&self) -> bool {

4
rnex-core/src/nex/user.rs
View file

@ -342,12 +342,10 @@ impl MatchmakeExtension for User {
let sessions = self.matchmake_manager.sessions.read().await;
for session in sessions.values() {
let mut session = session.lock().await;
println!("checking session!");
if !session.is_joinable() {
continue;
}
println!("checking session!");
let mut bool_matched_criteria = false;