@@ -368,22 +368,9 @@ static int endpoint_init(char *flags)
368
368
return -1 ;
369
369
}
370
370
371
- static int _ss_search ( char * src , char * dst , char * port , char * keyword )
371
+ static void run_subflow ( void )
372
372
{
373
- return SYS_NOFAIL ("ip netns exec %s ss -enita src %s dst %s %s %d | grep -q '%s'" ,
374
- NS_TEST , src , dst , port , PORT_1 , keyword );
375
- }
376
-
377
- static int ss_search (char * src , char * keyword )
378
- {
379
- return _ss_search (src , ADDR_1 , "dport" , keyword );
380
- }
381
-
382
- static void run_subflow (char * new )
383
- {
384
- int server_fd , client_fd , err ;
385
- char cc [TCP_CA_NAME_MAX ];
386
- socklen_t len ;
373
+ int server_fd , client_fd ;
387
374
388
375
server_fd = start_mptcp_server (AF_INET , ADDR_1 , PORT_1 , 0 );
389
376
if (!ASSERT_GE (server_fd , 0 , "start_mptcp_server" ))
@@ -393,19 +380,8 @@ static void run_subflow(char *new)
393
380
if (!ASSERT_GE (client_fd , 0 , "connect to fd" ))
394
381
goto close_server ;
395
382
396
- len = sizeof (cc );
397
- err = getsockopt (server_fd , SOL_TCP , TCP_CONGESTION , cc , & len );
398
- if (!ASSERT_OK (err , "getsockopt(server_fd, TCP_CONGESTION)" ))
399
- goto close_client ;
400
-
401
383
send_byte (client_fd );
402
384
403
- ASSERT_OK (ss_search (ADDR_1 , "fwmark:0x1" ), "ss_search fwmark:0x1" );
404
- ASSERT_OK (ss_search (ADDR_2 , "fwmark:0x2" ), "ss_search fwmark:0x2" );
405
- ASSERT_OK (ss_search (ADDR_1 , new ), "ss_search new cc" );
406
- ASSERT_OK (ss_search (ADDR_2 , cc ), "ss_search default cc" );
407
-
408
- close_client :
409
385
close (client_fd );
410
386
close_server :
411
387
close (server_fd );
@@ -441,7 +417,7 @@ static void test_subflow(void)
441
417
if (endpoint_init ("subflow" ) < 0 )
442
418
goto close_netns ;
443
419
444
- run_subflow (skel -> data -> cc );
420
+ run_subflow ();
445
421
446
422
close_netns :
447
423
cleanup_netns (nstoken );
@@ -470,9 +446,15 @@ static struct nstoken *sched_init(char *flags, char *sched)
470
446
return NULL ;
471
447
}
472
448
449
+ static int ss_search (char * src , char * dst , char * port , char * keyword )
450
+ {
451
+ return SYS_NOFAIL ("ip netns exec %s ss -enita src %s dst %s %s %d | grep -q '%s'" ,
452
+ NS_TEST , src , dst , port , PORT_1 , keyword );
453
+ }
454
+
473
455
static int has_bytes_sent (char * dst )
474
456
{
475
- return _ss_search (ADDR_1 , dst , "sport" , "bytes_sent:" );
457
+ return ss_search (ADDR_1 , dst , "sport" , "bytes_sent:" );
476
458
}
477
459
478
460
static void send_data_and_verify (char * sched , bool addr1 , bool addr2 )
0 commit comments