tests: apply formatter

Signed-off-by: Reto Achermann <achreto@gmail.com>

Author: achreto

kernel/tests/s11_rackscale_benchmarks.rs

@@ -812,7 +812,7 @@ fn rackscale_memcached_benchmark_sharded(is_shmem: bool) {
     // stuff has been built, now we can run the benchmark
     let mut config = if is_smoke {
         MemcachedShardedConfig {
-            num_servers:1,
+            num_servers: 1,
             num_queries: 100_000,
             mem_size: 16,
             protocol: "tcp",
@@ -823,7 +823,7 @@ fn rackscale_memcached_benchmark_sharded(is_shmem: bool) {
     } else {
         // keep in sync with the s10_memcached_benchmark_internal configuration
         MemcachedShardedConfig {
-            num_servers:1,
+            num_servers: 1,
             num_queries: 100_000_000,
             mem_size: 128 * 1024,
             protocol: "tcp",
@@ -886,7 +886,6 @@ fn rackscale_memcached_benchmark_sharded(is_shmem: bool) {
                     let ip = 10 + i;
                     servers.push_str(format!("tcp://172.31.0.{}:{}", ip, 11211).as_str());
                 }
-
             } else {
                 servers.push_str(format!("unix://memcached{}.sock", i).as_str());
             }
@@ -947,7 +946,8 @@ fn rackscale_memcached_benchmark_sharded(is_shmem: bool) {
                     spawn_memcached(i.to_string().as_str(), &config, timeout_ms);
                 }
 
-                let mut pty = spawn_loadbalancer(Some(&config), timeout_ms).expect("failed to spawn load balancer");
+                let mut pty = spawn_loadbalancer(Some(&config), timeout_ms)
+                    .expect("failed to spawn load balancer");
                 let mut output = String::new();
                 let res = parse_memcached_output(&mut pty, &mut output);
 
@@ -1037,7 +1037,7 @@ fn rackscale_memcached_benchmark_sharded(is_shmem: bool) {
             8192
         } else {
             // Memory must also be divisible by number of nodes, which could be 1, 2, 3, or 4
-            256*1024 //2048 * (((((num_cores + 1) / 2) + 3 - 1) / 3) * 3)
+            256 * 1024 //2048 * (((((num_cores + 1) / 2) + 3 - 1) / 3) * 3)
         }
     }
 

kernel/testutils/src/rackscale_runner.rs

@@ -47,10 +47,7 @@ type RackscaleMatchFn<T> = fn(
     arg: Option<T>,
 ) -> Result<()>;
 
-type ControllerRunFn<T> = fn(
-    config: Option<&T>,
-    timeout_ms: u64,
-) -> Result<PtySession>;
+type ControllerRunFn<T> = fn(config: Option<&T>, timeout_ms: u64) -> Result<PtySession>;
 
 #[derive(Clone)]
 pub struct RackscaleRun<T>
@@ -532,12 +529,12 @@ impl<T: Clone + Send + 'static> RackscaleRun<T> {
                             .lock()
                             .expect("Failed to get build timer lock");
                         send_signal(&tx);
-                            }
+                    }
 
                     if state.wait_for_client {
                         let tx = client_tx.lock().expect("Failed to get rx lock");
                         send_signal(&tx);
-                            }
+                    }
 
                     client_output_array
                         .lock()
@@ -599,19 +596,19 @@ impl<T: Clone + Send + 'static> RackscaleRun<T> {
                     qemu_run()
                 } else {
                     let mut cmdline_controller =
-                    RunnerArgs::new_with_build(&controller_kernel_test, &state.built)
-                        .timeout(state.controller_timeout)
-                        .transport(state.transport)
-                        .mode(RackscaleMode::Controller)
-                        .tap("tap0")
-                        .no_network_setup()
-                        .workers(state.num_clients + 1)
-                        .use_vmxnet3()
-                        .memory(state.memory)
-                        .nodes(1)
-                        .cores(controller_cores)
-                        .node_offset(controller_placement_cores[0].0)
-                        .setaffinity(controller_placement_cores[0].1.clone());
+                        RunnerArgs::new_with_build(&controller_kernel_test, &state.built)
+                            .timeout(state.controller_timeout)
+                            .transport(state.transport)
+                            .mode(RackscaleMode::Controller)
+                            .tap("tap0")
+                            .no_network_setup()
+                            .workers(state.num_clients + 1)
+                            .use_vmxnet3()
+                            .memory(state.memory)
+                            .nodes(1)
+                            .cores(controller_cores)
+                            .node_offset(controller_placement_cores[0].0)
+                            .setaffinity(controller_placement_cores[0].1.clone());
 
                     if use_large_pages {
                         cmdline_controller = cmdline_controller.large_pages().prealloc();
@@ -684,7 +681,6 @@ impl<T: Clone + Send + 'static> RackscaleRun<T> {
             })
             .expect("Controller thread failed to spawn");
 
-
         let mut client_rets = Vec::new();
         for client in client_procs {
             client_rets.push(client.join());