@@ -373,39 +373,28 @@ mod tests {
373373 }
374374
375375 #[ test]
376- fn connect_ip4_loopback ( ) {
377- let addr = next_test_ip4 ( ) ;
378- let acceptor = t ! ( TcpListener :: bind( & addr) ) ;
379-
380- let _t = thread:: spawn ( move || {
381- let mut stream = t ! ( TcpStream :: connect( & ( "127.0.0.1" , addr. port( ) ) ) ) ;
382- t ! ( stream. write( & [ 44 ] ) ) ;
383- } ) ;
384-
385- let mut stream = t ! ( acceptor. accept( ) ) . 0 ;
386- let mut buf = [ 0 ] ;
387- t ! ( stream. read( & mut buf) ) ;
388- assert ! ( buf[ 0 ] == 44 ) ;
389- }
390-
391- #[ test]
392- fn connect_ip6_loopback ( ) {
393- let addr = next_test_ip6 ( ) ;
394- let acceptor = t ! ( TcpListener :: bind( & addr) ) ;
376+ fn connect_loopback ( ) {
377+ each_ip ( & mut |addr| {
378+ let acceptor = t ! ( TcpListener :: bind( & addr) ) ;
395379
396- let _t = thread:: spawn ( move || {
397- let mut stream = t ! ( TcpStream :: connect( & ( "::1" , addr. port( ) ) ) ) ;
398- t ! ( stream. write( & [ 66 ] ) ) ;
399- } ) ;
380+ let _t = thread:: spawn ( move || {
381+ let host = match addr {
382+ SocketAddr :: V4 ( ..) => "127.0.0.1" ,
383+ SocketAddr :: V6 ( ..) => "::1" ,
384+ } ;
385+ let mut stream = t ! ( TcpStream :: connect( & ( host, addr. port( ) ) ) ) ;
386+ t ! ( stream. write( & [ 66 ] ) ) ;
387+ } ) ;
400388
401- let mut stream = t ! ( acceptor. accept( ) ) . 0 ;
402- let mut buf = [ 0 ] ;
403- t ! ( stream. read( & mut buf) ) ;
404- assert ! ( buf[ 0 ] == 66 ) ;
389+ let mut stream = t ! ( acceptor. accept( ) ) . 0 ;
390+ let mut buf = [ 0 ] ;
391+ t ! ( stream. read( & mut buf) ) ;
392+ assert ! ( buf[ 0 ] == 66 ) ;
393+ } )
405394 }
406395
407396 #[ test]
408- fn smoke_test_ip6 ( ) {
397+ fn smoke_test ( ) {
409398 each_ip ( & mut |addr| {
410399 let acceptor = t ! ( TcpListener :: bind( & addr) ) ;
411400
@@ -425,7 +414,7 @@ mod tests {
425414 }
426415
427416 #[ test]
428- fn read_eof_ip4 ( ) {
417+ fn read_eof ( ) {
429418 each_ip ( & mut |addr| {
430419 let acceptor = t ! ( TcpListener :: bind( & addr) ) ;
431420
@@ -470,7 +459,7 @@ mod tests {
470459 }
471460
472461 #[ test]
473- fn multiple_connect_serial_ip4 ( ) {
462+ fn multiple_connect_serial ( ) {
474463 each_ip ( & mut |addr| {
475464 let max = 10 ;
476465 let acceptor = t ! ( TcpListener :: bind( & addr) ) ;
@@ -527,7 +516,7 @@ mod tests {
527516 }
528517
529518 #[ test]
530- fn multiple_connect_interleaved_lazy_schedule_ip4 ( ) {
519+ fn multiple_connect_interleaved_lazy_schedule ( ) {
531520 const MAX : usize = 10 ;
532521 each_ip ( & mut |addr| {
533522 let acceptor = t ! ( TcpListener :: bind( & addr) ) ;
@@ -560,7 +549,7 @@ mod tests {
560549 }
561550
562551 #[ test]
563- fn socket_and_peer_name_ip4 ( ) {
552+ fn socket_and_peer_name ( ) {
564553 each_ip ( & mut |addr| {
565554 let listener = t ! ( TcpListener :: bind( & addr) ) ;
566555 let so_name = t ! ( listener. local_addr( ) ) ;
0 commit comments