mirrors/crosvm
1
0
Fork 0
mirror of https://chromium.googlesource.com/crosvm/crosvm synced 2025-02-05 18:20:34 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

devices: virtio_net: handle errors in tapfd poll adding/removal

Browse source 
Add error handling for adding/removing the tapfd to epoll.

We only remove the tap fd from the poll context if the tap is
readable, i.e. it would busy loop, so don't assume it's removed
from the poll context when there's a deferred rx frame.

BUG=chromium:1010742
TEST=arcvm network works

Change-Id: I84aab2dbe7ea31d724f04d3b3fb0a6916f232300
Reviewed-on: https://chromium-review.googlesource.com/c/chromiumos/platform/crosvm/+/1842399
Tested-by: kokoro <noreply+kokoro@google.com>
Tested-by: Stephen Barber <smbarber@chromium.org>
Reviewed-by: Dylan Reid <dgreid@chromium.org>
Reviewed-by: Chirantan Ekbote <chirantan@chromium.org>
Commit-Queue: Stephen Barber <smbarber@chromium.org>
This commit is contained in:
Stephen Barber 2019-10-04 15:20:05 -07:00 committed by Commit Bot
parent 04e9c03f03
commit 7595d80248
1 changed files with 15 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
devices/src/virtio/net.rs
View file

@ -10,7 +10,7 @@ use std::sync::atomic::{AtomicUsize, Ordering};
use std::sync::Arc;
use std::thread;
use libc::EAGAIN;
use libc::{EAGAIN, EEXIST};
use net_sys;
use net_util::{Error as TapError, MacAddress, TapT};
use sys_util::guest_memory::Error as MemoryError;
@ -237,9 +237,12 @@ where
if self.rx_single_frame() {
self.deferred_rx = false;
} else {
// The guest has not yet made any buffers available. Remove the
// tapfd from the poll context until more are made available.
poll_ctx.delete(&self.tap).map_err(NetError::PollDeleteTap);
// There is an outstanding deferred frame and the guest has not yet
// made any buffers available. Remove the tapfd from the poll
// context until more are made available.
poll_ctx
.delete(&self.tap)
.map_err(NetError::PollDeleteTap)?;
continue;
}
}
@ -253,10 +256,14 @@ where
// There should be a buffer available now to receive the frame into.
if self.deferred_rx && self.rx_single_frame() {
// The guest has made buffers available, so add the tap back to the
// poll context.
poll_ctx
.add(&self.tap, Token::RxTap)
.map_err(NetError::PollAddTap);
// poll context in case it was removed.
match poll_ctx.add(&self.tap, Token::RxTap) {
Ok(_) => {}
Err(e) if e.errno() == EEXIST => {}
Err(e) => {
return Err(NetError::PollAddTap(e));
}
}
self.deferred_rx = false;
}
}