actix/actix-net
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-net synced 2025-03-20 16:05:18 +01:00
Code Issues Releases Wiki Activity

Fix worker_avail (#336)

Browse Source 
Co-authored-by: Rob Ede <robjtede@icloud.com>
This commit is contained in:
fakeshadow 2021-04-15 19:20:02 -07:00 committed by GitHub
parent fdafc1dd65
commit 20c2da17ed
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
actix-server/src/accept.rs
View File

@ -116,14 +116,11 @@ impl Availability {
panic!("Max WorkerHandle count is 512") panic!("Max WorkerHandle count is 512")
}; };
let off = 1 << idx as u128;
if avail { if avail {
self.0[offset] |= 1 << idx as u128; self.0[offset] |= off;
} else { } else {
let shift = 1 << idx as u128; self.0[offset] &= !off
debug_assert_ne!(self.0[offset] & shift, 0);
self.0[offset] ^= shift;
} }
} }
@ -527,6 +524,9 @@ mod test {
aval.set_available(idx, false); aval.set_available(idx, false);
assert!(!aval.available()); assert!(!aval.available());
aval.set_available(idx, false);
assert!(!aval.available());
} }
fn multi(aval: &mut Availability, mut idx: Vec<usize>) { fn multi(aval: &mut Availability, mut idx: Vec<usize>) {
@ -565,13 +565,6 @@ mod test {
single(&mut aval, 512); single(&mut aval, 512);
} }
#[test]
#[should_panic]
fn double_set_unavailable() {
let mut aval = Availability::default();
aval.set_available(233, false);
}
#[test] #[test]
fn pin_point() { fn pin_point() {
let mut aval = Availability::default(); let mut aval = Availability::default();