@@ -273,7 +273,7 @@ impl VsockMuxer {
273
273
match req. _type {
274
274
defs:: SOCK_STREAM => {
275
275
debug ! ( "vsock: proxy create stream" ) ;
276
- let id = ( req. peer_port as u64 ) << 32 | defs:: TSI_PROXY_PORT as u64 ;
276
+ let id = ( ( req. peer_port as u64 ) << 32 ) | ( defs:: TSI_PROXY_PORT as u64 ) ;
277
277
match TcpProxy :: new (
278
278
id,
279
279
self . cid ,
@@ -295,7 +295,7 @@ impl VsockMuxer {
295
295
}
296
296
defs:: SOCK_DGRAM => {
297
297
debug ! ( "vsock: proxy create dgram" ) ;
298
- let id = ( req. peer_port as u64 ) << 32 | defs:: TSI_PROXY_PORT as u64 ;
298
+ let id = ( ( req. peer_port as u64 ) << 32 ) | ( defs:: TSI_PROXY_PORT as u64 ) ;
299
299
match UdpProxy :: new (
300
300
id,
301
301
self . cid ,
@@ -321,7 +321,7 @@ impl VsockMuxer {
321
321
fn process_connect ( & self , pkt : & VsockPacket ) {
322
322
debug ! ( "vsock: proxy connect request" ) ;
323
323
if let Some ( req) = pkt. read_connect_req ( ) {
324
- let id = ( req. peer_port as u64 ) << 32 | defs:: TSI_PROXY_PORT as u64 ;
324
+ let id = ( ( req. peer_port as u64 ) << 32 ) | ( defs:: TSI_PROXY_PORT as u64 ) ;
325
325
debug ! ( "vsock: proxy connect request: id={}" , id) ;
326
326
let update = self
327
327
. proxy_map
@@ -339,7 +339,7 @@ impl VsockMuxer {
339
339
fn process_getname ( & self , pkt : & VsockPacket ) {
340
340
debug ! ( "vsock: new getname request" ) ;
341
341
if let Some ( req) = pkt. read_getname_req ( ) {
342
- let id = ( req. peer_port as u64 ) << 32 | ( req. local_port as u64 ) ;
342
+ let id = ( ( req. peer_port as u64 ) << 32 ) | ( req. local_port as u64 ) ;
343
343
debug ! (
344
344
"vsock: new getname request: id={}, peer_port={}, local_port={}" ,
345
345
id, req. peer_port, req. local_port
@@ -354,7 +354,7 @@ impl VsockMuxer {
354
354
fn process_sendto_addr ( & self , pkt : & VsockPacket ) {
355
355
debug ! ( "vsock: new DGRAM sendto addr: src={}" , pkt. src_port( ) ) ;
356
356
if let Some ( req) = pkt. read_sendto_addr ( ) {
357
- let id = ( req. peer_port as u64 ) << 32 | defs:: TSI_PROXY_PORT as u64 ;
357
+ let id = ( ( req. peer_port as u64 ) << 32 ) | ( defs:: TSI_PROXY_PORT as u64 ) ;
358
358
debug ! ( "vsock: new DGRAM sendto addr: id={}" , id) ;
359
359
let update = self
360
360
. proxy_map
@@ -370,7 +370,7 @@ impl VsockMuxer {
370
370
}
371
371
372
372
fn process_sendto_data ( & self , pkt : & VsockPacket ) {
373
- let id = ( pkt. src_port ( ) as u64 ) << 32 | defs:: TSI_PROXY_PORT as u64 ;
373
+ let id = ( ( pkt. src_port ( ) as u64 ) << 32 ) | ( defs:: TSI_PROXY_PORT as u64 ) ;
374
374
debug ! ( "vsock: DGRAM sendto data: id={} src={}" , id, pkt. src_port( ) ) ;
375
375
if let Some ( proxy) = self . proxy_map . read ( ) . unwrap ( ) . get ( & id) {
376
376
proxy. lock ( ) . unwrap ( ) . sendto_data ( pkt) ;
0 commit comments