File tree 7 files changed +29
-39
lines changed
7 files changed +29
-39
lines changed Original file line number Diff line number Diff line change @@ -544,14 +544,10 @@ async fn handle_signals(
544
544
mut signals : Signals ,
545
545
early_shutdown : oneshot:: Sender < ( ) > ,
546
546
) {
547
- while let Some ( signal) = signals. next ( ) . await {
548
- match signal {
549
- SIGUSR1 => {
550
- early_shutdown. send ( ( ) ) . unwrap ( ) ;
551
- break ;
552
- }
553
- _ => unreachable ! ( ) ,
554
- }
547
+ match signals. next ( ) . await {
548
+ Some ( SIGUSR1 ) => early_shutdown. send ( ( ) ) . unwrap ( ) ,
549
+ Some ( _) => unreachable ! ( ) ,
550
+ None => ( ) , // signal sender is dropped
555
551
}
556
552
}
557
553
Original file line number Diff line number Diff line change @@ -658,24 +658,22 @@ pub async fn start_cli_client(attach: SocketAddr) -> Result<()> {
658
658
let tcp = sock. connect ( attach) ;
659
659
tokio:: pin!( tcp) ;
660
660
661
- let mut tcp: TcpStream = loop {
662
- tokio:: select! {
663
- _ = & mut deadline => {
664
- println!( "connect timeout" ) ;
665
- continue ' outer;
666
- }
667
- tcp = & mut tcp => {
668
- match tcp {
669
- Ok ( tcp) => {
670
- println!( "connected to {}" , attach) ;
671
- break tcp;
672
- }
673
- Err ( e) => {
674
- println!( "connect to {0} failure: {1:?}" ,
675
- attach, e) ;
676
- tokio:: time:: sleep_until( deadline_secs( 10.0 ) ) . await ;
677
- continue ' outer;
678
- }
661
+ let mut tcp: TcpStream = tokio:: select! {
662
+ _ = & mut deadline => {
663
+ println!( "connect timeout" ) ;
664
+ continue ' outer;
665
+ }
666
+ tcp = & mut tcp => {
667
+ match tcp {
668
+ Ok ( tcp) => {
669
+ println!( "connected to {}" , attach) ;
670
+ tcp
671
+ }
672
+ Err ( e) => {
673
+ println!( "connect to {0} failure: {1:?}" ,
674
+ attach, e) ;
675
+ tokio:: time:: sleep_until( deadline_secs( 10.0 ) ) . await ;
676
+ continue ' outer;
679
677
}
680
678
}
681
679
}
Original file line number Diff line number Diff line change @@ -725,7 +725,7 @@ async fn show_extent_block(
725
725
println ! ( ) ;
726
726
727
727
print ! ( "{} " , String :: from_utf8( vec![ b'-' ; 6 ] ) ?) ;
728
- for ( _ , _ ) in dvec. iter ( ) . enumerate ( ) {
728
+ for _ in & dvec {
729
729
print ! ( "{} " , String :: from_utf8( vec![ b'-' ; 24 ] ) ?) ;
730
730
}
731
731
if !only_show_differences {
@@ -784,7 +784,7 @@ async fn show_extent_block(
784
784
println ! ( ) ;
785
785
786
786
print ! ( "{} " , String :: from_utf8( vec![ b'-' ; 6 ] ) ?) ;
787
- for ( _ , _ ) in dvec. iter ( ) . enumerate ( ) {
787
+ for _ in & dvec {
788
788
print ! ( "{} " , String :: from_utf8( vec![ b'-' ; 32 ] ) ?) ;
789
789
}
790
790
if !only_show_differences {
@@ -848,7 +848,7 @@ async fn show_extent_block(
848
848
println ! ( ) ;
849
849
850
850
print ! ( "{} " , String :: from_utf8( vec![ b'-' ; 6 ] ) ?) ;
851
- for ( _ , _ ) in dvec. iter ( ) . enumerate ( ) {
851
+ for _ in & dvec {
852
852
print ! ( "{} " , String :: from_utf8( vec![ b'-' ; 16 ] ) ?) ;
853
853
}
854
854
if !only_show_differences {
Original file line number Diff line number Diff line change @@ -307,10 +307,8 @@ impl PantryEntry {
307
307
let volume_block_size =
308
308
self . volume . check_data_size ( size) . await ? as usize ;
309
309
310
- let mut buffer = crucible:: Buffer :: new (
311
- size / volume_block_size as usize ,
312
- volume_block_size,
313
- ) ;
310
+ let mut buffer =
311
+ crucible:: Buffer :: new ( size / volume_block_size, volume_block_size) ;
314
312
315
313
self . volume
316
314
. read_from_byte_offset ( offset, & mut buffer)
Original file line number Diff line number Diff line change @@ -150,7 +150,7 @@ impl ReadResponse {
150
150
}
151
151
152
152
pub fn first_hash ( & self ) -> Option < u64 > {
153
- self . block_contexts . get ( 0 ) . map ( |ctx| ctx. hash )
153
+ self . block_contexts . first ( ) . map ( |ctx| ctx. hash )
154
154
}
155
155
156
156
pub fn encryption_contexts ( & self ) -> Vec < Option < & EncryptionContext > > {
Original file line number Diff line number Diff line change 1
1
[toolchain ]
2
- channel = " 1.73 "
2
+ channel = " 1.75 "
3
3
profile = " default"
Original file line number Diff line number Diff line change @@ -116,12 +116,10 @@ pub(crate) mod up_test {
116
116
assert_eq ! ( span. buffer( ) [ i] , 0 ) ;
117
117
}
118
118
119
- let mut data = vec ! [ 0u8 ; 64 ] ;
119
+ let mut data = [ 0u8 ; 64 ] ;
120
120
span. read_from_blocks_into_buffer ( & mut data[ ..] ) ;
121
121
122
- for i in 0 ..64 {
123
- assert_eq ! ( data[ i] , 1 ) ;
124
- }
122
+ assert_eq ! ( data, [ 1 ; 64 ] ) ;
125
123
}
126
124
127
125
/*
You can’t perform that action at this time.
0 commit comments