External/cloud-hypervisor
1
0
Fork 0
mirror of https://github.com/cloud-hypervisor/cloud-hypervisor.git synced 2025-03-20 07:58:55 +00:00
Code

vhost_rs: vhost_user: Update unit tests

Browse Source 
The Master::connect() function now takes a queue count.

Signed-off-by: Rob Bradford <robert.bradford@intel.com>
This commit is contained in:
Rob Bradford 2019-07-16 10:41:39 +01:00 committed by Samuel Ortiz
parent 7499210d0c
commit 1dfe16c382
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
vhost_rs/src/vhost_user/master.rs
View File

@ -620,7 +620,7 @@ mod tests {
fn create_pair(path: &str) -> (Master, Endpoint<MasterReq>) { fn create_pair(path: &str) -> (Master, Endpoint<MasterReq>) {
let listener = Listener::new(path, true).unwrap(); let listener = Listener::new(path, true).unwrap();
listener.set_nonblocking(true).unwrap(); listener.set_nonblocking(true).unwrap();
let master = Master::connect(path).unwrap(); let master = Master::connect(path, 2).unwrap();
let slave = listener.accept().unwrap().unwrap(); let slave = listener.accept().unwrap().unwrap();
(master, Endpoint::from_stream(slave)) (master, Endpoint::from_stream(slave))
} }
@ -630,7 +630,7 @@ mod tests {
let listener = Listener::new(UNIX_SOCKET_MASTER, true).unwrap(); let listener = Listener::new(UNIX_SOCKET_MASTER, true).unwrap();
listener.set_nonblocking(true).unwrap(); listener.set_nonblocking(true).unwrap();
let mut master = Master::connect(UNIX_SOCKET_MASTER).unwrap(); let mut master = Master::connect(UNIX_SOCKET_MASTER, 2).unwrap();
let mut slave = Endpoint::<MasterReq>::from_stream(listener.accept().unwrap().unwrap()); let mut slave = Endpoint::<MasterReq>::from_stream(listener.accept().unwrap().unwrap());
// Send two messages continuously // Send two messages continuously
@ -654,13 +654,13 @@ mod tests {
fn test_create_failure() { fn test_create_failure() {
let _ = Listener::new(UNIX_SOCKET_MASTER2, true).unwrap(); let _ = Listener::new(UNIX_SOCKET_MASTER2, true).unwrap();
let _ = Listener::new(UNIX_SOCKET_MASTER2, false).is_err(); let _ = Listener::new(UNIX_SOCKET_MASTER2, false).is_err();
assert!(Master::connect(UNIX_SOCKET_MASTER2).is_err()); assert!(Master::connect(UNIX_SOCKET_MASTER2, 2).is_err());
let listener = Listener::new(UNIX_SOCKET_MASTER2, true).unwrap(); let listener = Listener::new(UNIX_SOCKET_MASTER2, true).unwrap();
assert!(Listener::new(UNIX_SOCKET_MASTER2, false).is_err()); assert!(Listener::new(UNIX_SOCKET_MASTER2, false).is_err());
listener.set_nonblocking(true).unwrap(); listener.set_nonblocking(true).unwrap();
let _master = Master::connect(UNIX_SOCKET_MASTER2).unwrap(); let _master = Master::connect(UNIX_SOCKET_MASTER2, 2).unwrap();
let _slave = listener.accept().unwrap().unwrap(); let _slave = listener.accept().unwrap().unwrap();
} }