grassrootseconomics/openethereum
5
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

when error comes before initialization

Browse Source
This commit is contained in:
Svyatoslav Nikolsky 2017-07-14 14:51:24 +03:00
parent 18582d7b65
commit 5cc40d4525
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
secret_store/src/key_server_cluster/jobs/job_session.rs
View File

@ -299,22 +299,22 @@ impl<Executor, Transport> JobSession<Executor, Transport> where Executor: JobExe
return Err(Error::ConsensusUnreachable); return Err(Error::ConsensusUnreachable);
} }
let active_data = self.data.active_data.as_mut() if let Some(active_data) = self.data.active_data.as_mut() {
.expect("we have checked that we are on master node; on master nodes active_data is filled during initialization; qed"); if active_data.rejects.contains(node) {
if active_data.rejects.contains(node) {
return Ok(());
}
if active_data.requests.remove(node) || active_data.responses.remove(node).is_some() {
active_data.rejects.insert(node.clone());
if self.data.state == JobSessionState::Finished && active_data.responses.len() < self.meta.threshold + 1 {
self.data.state = JobSessionState::Active;
}
if active_data.requests.len() + active_data.responses.len() >= self.meta.threshold + 1 {
return Ok(()); return Ok(());
} }
if active_data.requests.remove(node) || active_data.responses.remove(node).is_some() {
active_data.rejects.insert(node.clone());
if self.data.state == JobSessionState::Finished && active_data.responses.len() < self.meta.threshold + 1 {
self.data.state = JobSessionState::Active;
}
if active_data.requests.len() + active_data.responses.len() >= self.meta.threshold + 1 {
return Ok(());
}
self.data.state = JobSessionState::Failed; self.data.state = JobSessionState::Failed;
return Err(Error::ConsensusUnreachable); return Err(Error::ConsensusUnreachable);
}
} }
Ok(()) Ok(())