fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-07-31 17:01:58 +00:00
Code Issues Projects Releases Wiki Activity

Use different ports in the memory transport tests (#954)

Browse Source
This commit is contained in:
Pierre Krieger
2019-02-19 10:57:40 +01:00
committed by GitHub
parent e2f99efb30
commit 4fa00725e4
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
core/src/transport/memory.rs
View File

@@ -255,22 +255,22 @@ mod tests {
#[test]
fn listening_twice() {
let transport = MemoryTransport::default();
assert!(transport.listen_on("/memory/5".parse().unwrap()).is_ok());
assert!(transport.listen_on("/memory/5".parse().unwrap()).is_ok());
let _listener = transport.listen_on("/memory/5".parse().unwrap()).unwrap();
assert!(transport.listen_on("/memory/5".parse().unwrap()).is_err());
assert!(transport.listen_on("/memory/5".parse().unwrap()).is_err());
assert!(transport.listen_on("/memory/1639174018481".parse().unwrap()).is_ok());
assert!(transport.listen_on("/memory/1639174018481".parse().unwrap()).is_ok());
let _listener = transport.listen_on("/memory/1639174018481".parse().unwrap()).unwrap();
assert!(transport.listen_on("/memory/1639174018481".parse().unwrap()).is_err());
assert!(transport.listen_on("/memory/1639174018481".parse().unwrap()).is_err());
drop(_listener);
assert!(transport.listen_on("/memory/5".parse().unwrap()).is_ok());
assert!(transport.listen_on("/memory/5".parse().unwrap()).is_ok());
assert!(transport.listen_on("/memory/1639174018481".parse().unwrap()).is_ok());
assert!(transport.listen_on("/memory/1639174018481".parse().unwrap()).is_ok());
}
#[test]
fn port_not_in_use() {
let transport = MemoryTransport::default();
assert!(transport.dial("/memory/5".parse().unwrap()).is_err());
let _listener = transport.listen_on("/memory/5".parse().unwrap()).unwrap();
assert!(transport.dial("/memory/5".parse().unwrap()).is_ok());
assert!(transport.dial("/memory/810172461024613".parse().unwrap()).is_err());
let _listener = transport.listen_on("/memory/810172461024613".parse().unwrap()).unwrap();
assert!(transport.dial("/memory/810172461024613".parse().unwrap()).is_ok());
}
// TODO: test that is actually works