parent
5193819d8e
commit
692b125391
11
src/drone.rs
11
src/drone.rs
|
@ -262,16 +262,7 @@ mod tests {
|
||||||
fn tmp_ledger_path(name: &str) -> String {
|
fn tmp_ledger_path(name: &str) -> String {
|
||||||
let keypair = KeyPair::new();
|
let keypair = KeyPair::new();
|
||||||
|
|
||||||
let id = {
|
format!("farf/{}-{}", name, keypair.pubkey())
|
||||||
let ids: Vec<_> = keypair
|
|
||||||
.pubkey()
|
|
||||||
.iter()
|
|
||||||
.map(|id| format!("{}", id))
|
|
||||||
.collect();
|
|
||||||
ids.join("")
|
|
||||||
};
|
|
||||||
|
|
||||||
format!("farf/{}-{}", name, id)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
|
|
|
@ -384,16 +384,7 @@ mod tests {
|
||||||
fn tmp_ledger_path(name: &str) -> String {
|
fn tmp_ledger_path(name: &str) -> String {
|
||||||
let keypair = KeyPair::new();
|
let keypair = KeyPair::new();
|
||||||
|
|
||||||
let id = {
|
format!("farf/{}-{}", name, keypair.pubkey())
|
||||||
let ids: Vec<_> = keypair
|
|
||||||
.pubkey()
|
|
||||||
.iter()
|
|
||||||
.map(|id| format!("{}", id))
|
|
||||||
.collect();
|
|
||||||
ids.join("")
|
|
||||||
};
|
|
||||||
|
|
||||||
format!("farf/{}-{}", name, id)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
|
|
|
@ -39,10 +39,6 @@ fn entry_at(file: &mut File, at: u64) -> io::Result<Entry> {
|
||||||
deserialize_from(file.take(len)).map_err(err_bincode_to_io)
|
deserialize_from(file.take(len)).map_err(err_bincode_to_io)
|
||||||
}
|
}
|
||||||
|
|
||||||
//fn next_offset(file: &mut File) -> io::Result<u64> {
|
|
||||||
// deserialize_from(file.take(SIZEOF_U64)).map_err(err_bincode_to_io)
|
|
||||||
//}
|
|
||||||
|
|
||||||
fn next_entry(file: &mut File) -> io::Result<Entry> {
|
fn next_entry(file: &mut File) -> io::Result<Entry> {
|
||||||
let len = deserialize_from(file.take(SIZEOF_USIZE)).map_err(err_bincode_to_io)?;
|
let len = deserialize_from(file.take(SIZEOF_USIZE)).map_err(err_bincode_to_io)?;
|
||||||
deserialize_from(file.take(len)).map_err(err_bincode_to_io)
|
deserialize_from(file.take(len)).map_err(err_bincode_to_io)
|
||||||
|
@ -441,8 +437,6 @@ mod tests {
|
||||||
assert!(entries0.verify(&id));
|
assert!(entries0.verify(&id));
|
||||||
}
|
}
|
||||||
|
|
||||||
fn tmp_ledger_path() -> String {}
|
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn test_ledger_reader_writer() {
|
fn test_ledger_reader_writer() {
|
||||||
let ledger_path = tmp_ledger_path("test_ledger_reader_writer");
|
let ledger_path = tmp_ledger_path("test_ledger_reader_writer");
|
||||||
|
|
|
@ -297,16 +297,7 @@ mod tests {
|
||||||
fn tmp_ledger_path(name: &str) -> String {
|
fn tmp_ledger_path(name: &str) -> String {
|
||||||
let keypair = KeyPair::new();
|
let keypair = KeyPair::new();
|
||||||
|
|
||||||
let id = {
|
format!("farf/{}-{}", name, keypair.pubkey())
|
||||||
let ids: Vec<_> = keypair
|
|
||||||
.pubkey()
|
|
||||||
.iter()
|
|
||||||
.map(|id| format!("{}", id))
|
|
||||||
.collect();
|
|
||||||
ids.join("")
|
|
||||||
};
|
|
||||||
|
|
||||||
format!("farf/{}-{}", name, id)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
|
|
11
src/tvu.rs
11
src/tvu.rs
|
@ -177,16 +177,7 @@ pub mod tests {
|
||||||
fn tmp_ledger_path(name: &str) -> String {
|
fn tmp_ledger_path(name: &str) -> String {
|
||||||
let keypair = KeyPair::new();
|
let keypair = KeyPair::new();
|
||||||
|
|
||||||
let id = {
|
format!("farf/{}-{}", name, keypair.pubkey())
|
||||||
let ids: Vec<_> = keypair
|
|
||||||
.pubkey()
|
|
||||||
.iter()
|
|
||||||
.map(|id| format!("{}", id))
|
|
||||||
.collect();
|
|
||||||
ids.join("")
|
|
||||||
};
|
|
||||||
|
|
||||||
format!("farf/{}-{}", name, id)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Test that message sent from leader to target1 and replicated to target2
|
/// Test that message sent from leader to target1 and replicated to target2
|
||||||
|
|
Loading…
Reference in New Issue