@@ -373,39 +373,28 @@ mod tests {
373
373
}
374
374
375
375
#[ 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) ) ;
395
379
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
+ } ) ;
400
388
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
+ } )
405
394
}
406
395
407
396
#[ test]
408
- fn smoke_test_ip6 ( ) {
397
+ fn smoke_test ( ) {
409
398
each_ip ( & mut |addr| {
410
399
let acceptor = t ! ( TcpListener :: bind( & addr) ) ;
411
400
@@ -425,7 +414,7 @@ mod tests {
425
414
}
426
415
427
416
#[ test]
428
- fn read_eof_ip4 ( ) {
417
+ fn read_eof ( ) {
429
418
each_ip ( & mut |addr| {
430
419
let acceptor = t ! ( TcpListener :: bind( & addr) ) ;
431
420
@@ -470,7 +459,7 @@ mod tests {
470
459
}
471
460
472
461
#[ test]
473
- fn multiple_connect_serial_ip4 ( ) {
462
+ fn multiple_connect_serial ( ) {
474
463
each_ip ( & mut |addr| {
475
464
let max = 10 ;
476
465
let acceptor = t ! ( TcpListener :: bind( & addr) ) ;
@@ -527,7 +516,7 @@ mod tests {
527
516
}
528
517
529
518
#[ test]
530
- fn multiple_connect_interleaved_lazy_schedule_ip4 ( ) {
519
+ fn multiple_connect_interleaved_lazy_schedule ( ) {
531
520
const MAX : usize = 10 ;
532
521
each_ip ( & mut |addr| {
533
522
let acceptor = t ! ( TcpListener :: bind( & addr) ) ;
@@ -560,7 +549,7 @@ mod tests {
560
549
}
561
550
562
551
#[ test]
563
- fn socket_and_peer_name_ip4 ( ) {
552
+ fn socket_and_peer_name ( ) {
564
553
each_ip ( & mut |addr| {
565
554
let listener = t ! ( TcpListener :: bind( & addr) ) ;
566
555
let so_name = t ! ( listener. local_addr( ) ) ;
0 commit comments