summary refs log tree commit diff
path: root/msg_socket
diff options
context:
space:
mode:
authorDylan Reid <dgreid@chromium.org>2020-04-21 22:02:58 +0000
committerCommit Bot <commit-bot@chromium.org>2020-04-23 22:12:11 +0000
commit8f9d4f71d752e3690922b13829ffab13bba23def (patch)
tree5fc86a9a3201baff5fc287b0f90737001eea7309 /msg_socket
parent9f22e23996d1542aa0978609e68c499c7263601e (diff)
downloadcrosvm-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.rs4
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,