diff options
author | Dylan Reid <dgreid@chromium.org> | 2020-04-21 22:02:58 +0000 |
---|---|---|
committer | Commit Bot <commit-bot@chromium.org> | 2020-04-23 22:12:11 +0000 |
commit | 8f9d4f71d752e3690922b13829ffab13bba23def (patch) | |
tree | 5fc86a9a3201baff5fc287b0f90737001eea7309 /msg_socket | |
parent | 9f22e23996d1542aa0978609e68c499c7263601e (diff) | |
download | crosvm-8f9d4f71d752e3690922b13829ffab13bba23def.tar crosvm-8f9d4f71d752e3690922b13829ffab13bba23def.tar.gz crosvm-8f9d4f71d752e3690922b13829ffab13bba23def.tar.bz2 crosvm-8f9d4f71d752e3690922b13829ffab13bba23def.tar.lz crosvm-8f9d4f71d752e3690922b13829ffab13bba23def.tar.xz crosvm-8f9d4f71d752e3690922b13829ffab13bba23def.tar.zst crosvm-8f9d4f71d752e3690922b13829ffab13bba23def.zip |
msg_socket: AsyncReceiver doesn't need a mut ref
The mut reference isn't used, an immutable reference is sufficient. Switch to make borrowing the receiver easier for users. Change-Id: Ic8582deb68997de53e5a53730b3909a1c4dcf699 Reviewed-on: https://chromium-review.googlesource.com/c/chromiumos/platform/crosvm/+/2159936 Reviewed-by: Chirantan Ekbote <chirantan@chromium.org> Tested-by: kokoro <noreply+kokoro@google.com> Tested-by: Dylan Reid <dgreid@chromium.org> Commit-Queue: Dylan Reid <dgreid@chromium.org>
Diffstat (limited to 'msg_socket')
-rw-r--r-- | msg_socket/src/lib.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/msg_socket/src/lib.rs b/msg_socket/src/lib.rs index c674f37..5a473ab 100644 --- a/msg_socket/src/lib.rs +++ b/msg_socket/src/lib.rs @@ -203,12 +203,12 @@ impl<O: MsgOnSocket> MsgReceiver for Receiver<O> { /// Asynchronous adaptor for `MsgSocket`. pub struct AsyncReceiver<'a, I: MsgOnSocket, O: MsgOnSocket> { - inner: &'a mut MsgSocket<I, O>, + inner: &'a MsgSocket<I, O>, done: bool, // Have hit an error and the Stream should return null when polled. } impl<'a, I: MsgOnSocket, O: MsgOnSocket> AsyncReceiver<'a, I, O> { - fn new(msg_socket: &mut MsgSocket<I, O>) -> MsgResult<AsyncReceiver<I, O>> { + fn new(msg_socket: &MsgSocket<I, O>) -> MsgResult<AsyncReceiver<I, O>> { add_fd_flags(msg_socket.as_raw_fd(), O_NONBLOCK).map_err(MsgError::SettingFdFlags)?; Ok(AsyncReceiver { inner: msg_socket, |