5 //! `VsockMuxer` is the device-facing component of the Unix domain sockets vsock backend. I.e.
7 //! between AF_VSOCK and AF_UNIX, and presents a clean interface to the rest of the vsock
10 //! The vsock muxer has two main roles:
12 //! ## Vsock connection multiplexer
18 //! Vsock packet traffic needs to be inspected, in order to detect connection request
25 //! There are three event categories that the vsock backend is interested it:
29 //!    the host is ready to issue a vsock connection request, informing us of the
102 /// The vsock connection multiplexer.
137     /// Deliver a vsock packet to the guest vsock driver.
201                 debug!("vsock muxer: RX pkt: {:?}", pkt.hdr());  in recv_pkt()
209     /// Deliver a guest-generated packet to its destination in the vsock backend.
216     /// returned to the guest vsock driver.
225             "vsock: muxer.send[rxq.len={}]: {:?}",  in send_pkt()
241                 "vsock: dropping guest packet for unknown CID: {:?}",  in send_pkt()
308         debug!("vsock: muxer received kick");  in notify()
335                     warn!("vsock: failed to consume muxer epoll event: {}", e);  in notify()
384             "vsock: muxer processing event: fd={}, event_set={:?}",  in handle_event()
409                     warn!("vsock: connection limit reached; refusing new host connection");  in handle_event()
430                         warn!("vsock: unable to accept local connection: {:?}", err);  in handle_event()
469                         info!("vsock: error adding local-init connection: {:?}", err);  in handle_event()
476                     "vsock: unexpected event: fd={:?}, event_set={:?}",  in handle_event()
483     /// Parse a host "connect" command, and extract the destination vsock port.
543                 "vsock: muxer connection limit reached ({})",  in add_connection()
665     /// Handle a new connection request coming from our peer (the guest vsock driver).
726                         warn!("vsock: unable to fully write connection ack msg.");  in apply_conn_mutation()
730                         warn!("vsock: unable to ack host connection: {:?}", err);  in apply_conn_mutation()
761                         "vsock: updating listener for (lp={}, pp={}): old={:?}, new={:?}",  in apply_conn_mutation()
777                             "vsock: error updating epoll listener for (lp={}, pp={}): {:?}",  in apply_conn_mutation()
795                         "vsock: error updating epoll listener for (lp={}, pp={}): {:?}",  in apply_conn_mutation()
841                 "vsock: muxer.rxq full; dropping RST packet for lp={}, pp={}",  in enq_rst()
1051         // The guest sent a SOCK_DGRAM packet. Per the vsock spec, we need to reply with an RST  in test_bad_peer_pkt()
1052         // packet, since vsock only supports stream sockets.  in test_bad_peer_pkt()