@@ -76,7 +76,9 @@ const TEST_SIGNING_KEY: &str = "0123456789abcdef0123456789abcdef0123456789abcdef
7676/// fail a perfectly current cdylib.
7777fn newest_source_mtime ( ) -> std:: time:: SystemTime {
7878 fn walk ( dir : & std:: path:: Path , newest : & mut std:: time:: SystemTime ) {
79- let Ok ( rd) = std:: fs:: read_dir ( dir) else { return } ;
79+ let Ok ( rd) = std:: fs:: read_dir ( dir) else {
80+ return ;
81+ } ;
8082 for e in rd. flatten ( ) {
8183 let p = e. path ( ) ;
8284 if p. is_dir ( ) {
@@ -286,8 +288,8 @@ fn load_and_exercise_valkey_plugin_persists_to_real_valkey_across_reopen() {
286288 direct_key. allowed_scopes,
287289 Some ( vec![ busbar_api:: ScopeRef :: pool( "p" ) ] )
288290 ) ;
289- let direct_usage = Store :: get_usage ( & direct , vk_id , 200 )
290- . expect ( "get_usage via the direct connection" ) ;
291+ let direct_usage =
292+ Store :: get_usage ( & direct , vk_id , 200 ) . expect ( "get_usage via the direct connection" ) ;
291293 assert_eq ! (
292294 direct_usage. requests, 5 ,
293295 "usage must be physically present in Valkey, not just cached in-process by the plugin"
@@ -850,7 +852,8 @@ fn mcp_call_log_survives_an_unload_and_reload_over_the_real_plugin_abi() {
850852
851853 // BOOT 2 — a second, independent dlopen over the same file, a fresh `busbar_open`, a fresh
852854 // connection inside the plugin.
853- let store = load_store ( & path, & cfg) . expect ( "the valkey plugin must load again over the real ABI" ) ;
855+ let store =
856+ load_store ( & path, & cfg) . expect ( "the valkey plugin must load again over the real ABI" ) ;
854857
855858 let calls = store. list_mcp_calls ( & p_main) . expect ( "list_mcp_calls" ) ;
856859 assert_eq ! (
@@ -902,10 +905,7 @@ fn mcp_call_log_survives_an_unload_and_reload_over_the_real_plugin_abi() {
902905 "both records at ts 2001 go (one per principal); the one sitting exactly at the cutoff stays"
903906 ) ;
904907 assert_eq ! (
905- store
906- . list_mcp_calls( & p_main)
907- . expect( "list_mcp_calls" )
908- . len( ) ,
908+ store. list_mcp_calls( & p_main) . expect( "list_mcp_calls" ) . len( ) ,
909909 2
910910 ) ;
911911 assert ! ( store
0 commit comments