File tree Expand file tree Collapse file tree 1 file changed +13
-3
lines changed Expand file tree Collapse file tree 1 file changed +13
-3
lines changed Original file line number Diff line number Diff line change @@ -185,7 +185,7 @@ impl VhostUserConsoleBackend {
185
185
Self :: epoll_register ( self . epoll_fd . as_raw_fd ( ) , stdin_fd, epoll:: Events :: EPOLLIN )
186
186
. map_err ( |_| Error :: EpollAdd ) ?;
187
187
} else {
188
- let listener = TcpListener :: bind ( tcpaddr_str) . expect ( "asdasd " ) ;
188
+ let listener = TcpListener :: bind ( tcpaddr_str) . expect ( "Failed bind tcp address " ) ;
189
189
self . listener = Some ( listener) ;
190
190
}
191
191
Ok ( ( ) )
@@ -530,7 +530,11 @@ impl VhostUserConsoleBackend {
530
530
. unwrap ( ) ;
531
531
532
532
if self . controller . read ( ) . unwrap ( ) . backend == BackendType :: Network {
533
- let listener_fd = self . listener . as_ref ( ) . expect ( "asd" ) . as_raw_fd ( ) ;
533
+ let listener_fd = self
534
+ . listener
535
+ . as_ref ( )
536
+ . expect ( "Failed get tcp listener ref" )
537
+ . as_raw_fd ( ) ;
534
538
vring_worker
535
539
. register_listener (
536
540
listener_fd,
@@ -568,7 +572,13 @@ impl VhostUserConsoleBackend {
568
572
569
573
fn create_new_stream_thread ( & mut self ) {
570
574
// Accept only one incoming connection
571
- if let Some ( stream) = self . listener . as_ref ( ) . expect ( "asd" ) . incoming ( ) . next ( ) {
575
+ if let Some ( stream) = self
576
+ . listener
577
+ . as_ref ( )
578
+ . expect ( "Failed get tcp listener ref" )
579
+ . incoming ( )
580
+ . next ( )
581
+ {
572
582
match stream {
573
583
Ok ( stream) => {
574
584
let local_addr = self
You can’t perform that action at this time.
0 commit comments