mirror of
https://github.com/cloud-hypervisor/cloud-hypervisor.git
synced 2026-08-05 02:19:16 +00:00
vhost_user_block: Use Mutex::get_mut() where possible
Signed-off-by: Wei Liu <liuwe@microsoft.com>
This commit is contained in:
@@ -334,8 +334,8 @@ impl VhostUserBackendMut for VhostUserBlkBackend {
|
|||||||
}
|
}
|
||||||
|
|
||||||
fn set_event_idx(&mut self, enabled: bool) {
|
fn set_event_idx(&mut self, enabled: bool) {
|
||||||
for thread in self.threads.iter() {
|
for thread in self.threads.iter_mut() {
|
||||||
thread.lock().unwrap().event_idx = enabled;
|
thread.get_mut().unwrap().event_idx = enabled;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -352,7 +352,7 @@ impl VhostUserBackendMut for VhostUserBlkBackend {
|
|||||||
|
|
||||||
debug!("event received: {:?}", device_event);
|
debug!("event received: {:?}", device_event);
|
||||||
|
|
||||||
let mut thread = self.threads[thread_id].lock().unwrap();
|
let thread = self.threads[thread_id].get_mut().unwrap();
|
||||||
match device_event {
|
match device_event {
|
||||||
0 => {
|
0 => {
|
||||||
let mut vring = vrings[0].get_mut();
|
let mut vring = vrings[0].get_mut();
|
||||||
|
|||||||
Reference in New Issue
Block a user