@@ -842,6 +842,8 @@ fn rackscale_memcached_checkout() {
842842fn s11_rackscale_memcached_benchmark_sharded_linux ( ) {
843843 use std:: fs:: remove_file;
844844
845+ use rexpect:: process:: signal:: Signal :: SIGKILL ;
846+
845847 let machine = Machine :: determine ( ) ;
846848 let out_dir_path = PathBuf :: from ( env ! ( "CARGO_TARGET_TMPDIR" ) ) . join ( "sharded-memcached" ) ;
847849 let is_smoke = cfg ! ( feature = "smoke" ) ;
@@ -893,7 +895,7 @@ fn s11_rackscale_memcached_benchmark_sharded_linux() {
893895 timeout_ms : u64 ,
894896 ) -> Result < PtySession > {
895897 let con_info = if config. protocol == "tcp" {
896- format ! ( "tcp://localhost:{}" , 11211 + id)
898+ format ! ( "tcp://localhost:{}" , 11212 + id)
897899 } else {
898900 let pathname = config. path . join ( format ! ( "memcached{id}.sock" ) ) ;
899901 remove_file ( pathname. clone ( ) ) ; // make sure the socket file is removed
@@ -941,7 +943,7 @@ fn s11_rackscale_memcached_benchmark_sharded_linux() {
941943 }
942944 if config. protocol == "tcp" {
943945 if config. is_local_host {
944- servers. push_str ( format ! ( "tcp://localhost:{}" , 11211 + i) . as_str ( ) ) ;
946+ servers. push_str ( format ! ( "tcp://localhost:{}" , 11212 + i) . as_str ( ) ) ;
945947 } else {
946948 // +1 because tap0 is reserved for the controller.
947949 let ip = 10 + i + 1 ;
@@ -1014,6 +1016,9 @@ fn s11_rackscale_memcached_benchmark_sharded_linux() {
10141016 let r = csv_file. write ( out. as_bytes ( ) ) ;
10151017 assert ! ( r. is_ok( ) ) ;
10161018
1019+ let r = pty. process . kill ( SIGKILL ) ;
1020+
1021+
10171022 println ! ( "{:?}" , res) ;
10181023
10191024 // single node
@@ -1029,6 +1034,9 @@ fn s11_rackscale_memcached_benchmark_sharded_linux() {
10291034 . args ( & [ "memcached" , "-s" , "SIGKILL" ] )
10301035 . status ( ) ;
10311036
1037+ // give some time so memcached can be cleaned up
1038+ std:: thread:: sleep ( Duration :: from_secs ( 5 ) ) ;
1039+
10321040 let mut memcached_ctrls = Vec :: new ( ) ;
10331041 for i in 0 ..num_nodes {
10341042 memcached_ctrls. push (
@@ -1344,7 +1352,7 @@ fn s11_rackscale_memcached_benchmark_sharded_nros() {
13441352 }
13451353
13461354 fn rackscale_timeout_fn ( num_cores : usize ) -> u64 {
1347- 600_000 + 60_000 * num_cores as u64
1355+ 1200_000 + 60_000 * num_cores as u64
13481356 }
13491357
13501358 fn mem_fn ( num_cores : usize , _num_clients : usize , is_smoke : bool ) -> usize {
0 commit comments