@@ -4,7 +4,7 @@ use std::fs::File;
4
4
use std:: io:: Write ;
5
5
use std:: net:: { IpAddr , SocketAddr } ;
6
6
use std:: num:: NonZeroU64 ;
7
- use std:: path:: { Path , PathBuf } ;
7
+ use std:: path:: PathBuf ;
8
8
use std:: sync:: {
9
9
atomic:: { AtomicBool , AtomicUsize , Ordering } ,
10
10
Arc ,
@@ -299,11 +299,6 @@ pub fn opts() -> Result<Opt> {
299
299
Ok ( opt)
300
300
}
301
301
302
- fn history_file < P : AsRef < Path > > ( file : P ) -> PathBuf {
303
- let out = file. as_ref ( ) . to_path_buf ( ) ;
304
- out
305
- }
306
-
307
302
#[ derive( Copy , Clone , Debug , clap:: Args ) ]
308
303
struct BufferbloatWorkload {
309
304
/// Size in blocks of each IO
@@ -681,16 +676,14 @@ async fn load_write_log(
681
676
/*
682
677
* Fill the write count from a provided file.
683
678
*/
684
- let cp = history_file ( vi) ;
685
- ri. write_log = match read_json ( & cp) {
679
+ ri. write_log = match read_json ( & vi) {
686
680
Ok ( write_log) => write_log,
687
- Err ( e) => bail ! ( "Error {:?} reading verify config {:?}" , e, cp ) ,
681
+ Err ( e) => bail ! ( "Error {:?} reading verify config {:?}" , e, vi ) ,
688
682
} ;
689
- println ! ( "Loading write count information from file {:?}" , cp ) ;
683
+ println ! ( "Loading write count information from file {vi :?}" ) ;
690
684
if ri. write_log . len ( ) != ri. total_blocks {
691
685
bail ! (
692
- "Verify file {:?} blocks:{} does not match regions:{}" ,
693
- cp,
686
+ "Verify file {vi:?} blocks:{} does not match regions:{}" ,
694
687
ri. write_log. len( ) ,
695
688
ri. total_blocks
696
689
) ;
@@ -992,9 +985,8 @@ async fn main() -> Result<()> {
992
985
* things that came after the flush.
993
986
*/
994
987
if let Some ( vo) = & opt. verify_out {
995
- let cp = history_file ( vo) ;
996
- write_json ( & cp, & region_info. write_log , true ) ?;
997
- println ! ( "Wrote out file {:?}" , cp) ;
988
+ write_json ( vo, & region_info. write_log , true ) ?;
989
+ println ! ( "Wrote out file {vo:?}" ) ;
998
990
}
999
991
return Ok ( ( ) ) ;
1000
992
}
@@ -1137,9 +1129,8 @@ async fn main() -> Result<()> {
1137
1129
repair_workload ( & guest, count, & mut region_info) . await ?;
1138
1130
drop ( guest) ;
1139
1131
if let Some ( vo) = & opt. verify_out {
1140
- let cp = history_file ( vo) ;
1141
- write_json ( & cp, & region_info. write_log , true ) ?;
1142
- println ! ( "Wrote out file {:?}" , cp) ;
1132
+ write_json ( vo, & region_info. write_log , true ) ?;
1133
+ println ! ( "Wrote out file {vo:?}" ) ;
1143
1134
}
1144
1135
return Ok ( ( ) ) ;
1145
1136
}
@@ -1258,9 +1249,8 @@ async fn main() -> Result<()> {
1258
1249
bail ! ( "Initial volume verify failed: {:?}" , e)
1259
1250
}
1260
1251
if let Some ( vo) = & opt. verify_out {
1261
- let cp = history_file ( vo) ;
1262
- write_json ( & cp, & region_info. write_log , true ) ?;
1263
- println ! ( "Wrote out file {:?}" , cp) ;
1252
+ write_json ( vo, & region_info. write_log , true ) ?;
1253
+ println ! ( "Wrote out file {vo:?}" ) ;
1264
1254
}
1265
1255
if opt. quit {
1266
1256
println ! ( "Verify test completed" ) ;
@@ -1303,9 +1293,8 @@ async fn main() -> Result<()> {
1303
1293
}
1304
1294
1305
1295
if let Some ( vo) = & opt. verify_out {
1306
- let cp = history_file ( vo) ;
1307
- write_json ( & cp, & region_info. write_log , true ) ?;
1308
- println ! ( "Wrote out file {:?}" , cp) ;
1296
+ write_json ( vo, & region_info. write_log , true ) ?;
1297
+ println ! ( "Wrote out file {vo:?}" ) ;
1309
1298
}
1310
1299
1311
1300
println ! ( "CLIENT: Tests done. All submitted work has been ACK'd" ) ;
@@ -3541,9 +3530,8 @@ async fn burst_workload(
3541
3530
*/
3542
3531
println ! ( ) ;
3543
3532
if let Some ( vo) = & verify_out {
3544
- let cp = history_file ( vo) ;
3545
- write_json ( & cp, & ri. write_log , true ) ?;
3546
- println ! ( "Wrote out file {:?} at this time" , cp) ;
3533
+ write_json ( vo, & ri. write_log , true ) ?;
3534
+ println ! ( "Wrote out file {vo:?} at this time" ) ;
3547
3535
}
3548
3536
println ! (
3549
3537
"{:>0width$}/{:>0width$}: 2 second pause, then another test loop" ,
0 commit comments