void/ZeroTierOne
2
0
Fork 0
mirror of https://github.com/zerotier/ZeroTierOne.git synced 2025-06-06 20:43:44 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

added comments

Browse source
This commit is contained in:
monica 2023-03-22 13:58:45 -04:00
parent adf3fe3cb5
commit c83b337c7a
No known key found for this signature in database
GPG key ID: ADCCDBBE0E3D3B3B
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
zssp/src/fragged.rs
View file

@ -58,6 +58,7 @@ impl<Fragment, const MAX_FRAGMENTS: usize> Fragged<Fragment, MAX_FRAGMENTS> {
#[inline(always)] #[inline(always)]
pub fn assemble(&self, counter: u64, fragment: Fragment, fragment_no: u8, fragment_count: u8) -> Option<Assembled<Fragment, MAX_FRAGMENTS>> { pub fn assemble(&self, counter: u64, fragment: Fragment, fragment_no: u8, fragment_count: u8) -> Option<Assembled<Fragment, MAX_FRAGMENTS>> {
if fragment_no < fragment_count && (fragment_count as usize) <= MAX_FRAGMENTS { if fragment_no < fragment_count && (fragment_count as usize) <= MAX_FRAGMENTS {
// We must hold the RwLock for the entire duration of this function, in case the counter changes and we need to drop everything
let r = self.counter_want.read().unwrap(); let r = self.counter_want.read().unwrap();
let (mut r_counter, mut r_want) = *r; let (mut r_counter, mut r_want) = *r;
let mut _r_guard = Some(r); let mut _r_guard = Some(r);
@ -65,6 +66,7 @@ impl<Fragment, const MAX_FRAGMENTS: usize> Fragged<Fragment, MAX_FRAGMENTS> {
// If the counter has changed, reset the structure to receive a new packet. // If the counter has changed, reset the structure to receive a new packet.
if counter != r_counter { if counter != r_counter {
// Switch to locking in write mode, and recheck the condition in case another thread entered the critical section while relocking.
_r_guard.take(); _r_guard.take();
let mut w = self.counter_want.write().unwrap(); let mut w = self.counter_want.write().unwrap();
let (w_counter, w_want) = *w; let (w_counter, w_want) = *w;