Improve error reporting
This commit is contained in:
@ -395,6 +395,6 @@ fn converge(
|
|||||||
}
|
}
|
||||||
|
|
||||||
fn read_leader(path: String) -> ReplicatedData {
|
fn read_leader(path: String) -> ReplicatedData {
|
||||||
let file = File::open(path).expect("file");
|
let file = File::open(path.clone()).expect(&format!("file not found: {}", path));
|
||||||
serde_json::from_reader(file).expect("parse")
|
serde_json::from_reader(file).expect(&format!("failed to parse {}", path))
|
||||||
}
|
}
|
||||||
|
@ -115,14 +115,20 @@ fn main() {
|
|||||||
if let Ok(data) = serde_json::from_reader(file) {
|
if let Ok(data) = serde_json::from_reader(file) {
|
||||||
repl_data = data;
|
repl_data = data;
|
||||||
} else {
|
} else {
|
||||||
warn!("failed to parse leader {}, generating new identity", path);
|
warn!("failed to parse {}, generating new identity", path);
|
||||||
}
|
}
|
||||||
|
} else {
|
||||||
|
warn!("failed to read {}, generating new identity", path);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
let threads = if matches.opt_present("v") {
|
let threads = if matches.opt_present("v") {
|
||||||
eprintln!("starting validator... {}", repl_data.requests_addr);
|
|
||||||
let path = matches.opt_str("v").unwrap();
|
let path = matches.opt_str("v").unwrap();
|
||||||
let file = File::open(path).expect("file");
|
eprintln!(
|
||||||
|
"starting validator... {} using {}",
|
||||||
|
repl_data.requests_addr, path
|
||||||
|
);
|
||||||
|
let file = File::open(path.clone()).expect(&format!("file not found: {}", path));
|
||||||
let leader = serde_json::from_reader(file).expect("parse");
|
let leader = serde_json::from_reader(file).expect("parse");
|
||||||
let s = Server::new_validator(
|
let s = Server::new_validator(
|
||||||
bank,
|
bank,
|
||||||
|
Reference in New Issue
Block a user