ank/avarus
1
Fork 0
Code Issues Activity

*really* deserialize chunkedtasks

Browse source
This commit is contained in:
Andy Killorin 2023-12-28 12:21:56 -06:00
parent 732435d3d5
commit 043baa7e35
Signed by: ank
GPG key ID: B6241CA3B552BCA4
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
server/src/mine.rs
View file

@ -378,16 +378,20 @@ struct ChunkedTask {
max: i32, max: i32,
#[serde(skip_deserializing)] #[serde(skip_deserializing)]
head: Arc<AtomicI32>, // highest active chunk head: Arc<AtomicI32>, // highest active chunk
#[serde(skip)] #[serde(skip, default = "channel")]
canceled: Option<(Sender<i32>, Receiver<i32>)>, canceled: Option<(Sender<i32>, Receiver<i32>)>,
} }
fn channel() -> Option<(Sender<i32>, Receiver<i32>)> {
Some(crossbeam::channel::unbounded())
}
impl Default for ChunkedTask { impl Default for ChunkedTask {
fn default() -> Self { fn default() -> Self {
Self { Self {
confirmed: Default::default(), confirmed: Default::default(),
head: Default::default(), head: Default::default(),
canceled: None, canceled: Some(crossbeam::channel::unbounded()),
max: 0, max: 0,
} }
} }
@ -397,7 +401,6 @@ impl ChunkedTask {
pub fn new(parts: i32) -> Self { pub fn new(parts: i32) -> Self {
Self { Self {
max: parts, max: parts,
canceled: Some(crossbeam::channel::unbounded()),
..Default::default() ..Default::default()
} }
} }