comments
This commit is contained in:
parent
50458d9524
commit
b2c2fa40a2
|
@ -875,6 +875,8 @@ mod tests {
|
||||||
}
|
}
|
||||||
assert!(one && two);
|
assert!(one && two);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// test that gossip requests are eventually generated for all nodes
|
||||||
#[test]
|
#[test]
|
||||||
fn gossip_request() {
|
fn gossip_request() {
|
||||||
let me = ReplicatedData::new(
|
let me = ReplicatedData::new(
|
||||||
|
@ -911,7 +913,8 @@ mod tests {
|
||||||
"127.0.0.1:1238".parse().unwrap(),
|
"127.0.0.1:1238".parse().unwrap(),
|
||||||
);
|
);
|
||||||
crdt.insert(&nxt2);
|
crdt.insert(&nxt2);
|
||||||
|
// check that the service works
|
||||||
|
// and that it eventually produces a request for both nodes
|
||||||
let (sender, reader) = channel();
|
let (sender, reader) = channel();
|
||||||
let recycler = BlobRecycler::default();
|
let recycler = BlobRecycler::default();
|
||||||
let exit = Arc::new(AtomicBool::new(false));
|
let exit = Arc::new(AtomicBool::new(false));
|
||||||
|
@ -945,6 +948,7 @@ mod tests {
|
||||||
assert!(one && two);
|
assert!(one && two);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// test window requests respond with the right blob, and do not overrun
|
||||||
#[test]
|
#[test]
|
||||||
fn run_window_request() {
|
fn run_window_request() {
|
||||||
let window = default_window();
|
let window = default_window();
|
||||||
|
|
Loading…
Reference in New Issue