@@ -170,7 +170,7 @@ where
170
170
trace ! ( "fetching from disk" ) ;
171
171
reader. seek ( SeekFrom :: Start ( * offset) ) ?;
172
172
let mut data = vec ! [ 0 ; usize :: try_from( * length) . unwrap( ) ] ;
173
- reader. read_exact ( & mut data) ;
173
+ reader. read_exact ( & mut data) ? ;
174
174
Ok ( Some ( data) )
175
175
}
176
176
( None , Occupied ( cached) ) => {
@@ -190,10 +190,7 @@ where
190
190
#[ tracing:: instrument( level = "trace" , skip( self , block) ) ]
191
191
fn put_keyed ( & self , k : & Cid , block : & [ u8 ] ) -> anyhow:: Result < ( ) > {
192
192
let CarBackedBlockstoreInner {
193
- reader,
194
- write_cache,
195
- index,
196
- ..
193
+ write_cache, index, ..
197
194
} = & mut * self . inner . lock ( ) ;
198
195
match ( index. get ( k) , write_cache. entry ( * k) ) {
199
196
( None , Occupied ( already) ) => match already. get ( ) == block {
@@ -281,7 +278,7 @@ fn read_u32_or_eof(mut reader: impl Read) -> Option<io::Result<u32>> {
281
278
match reader. read ( & mut byte) {
282
279
Ok ( 0 ) => None ,
283
280
Ok ( 1 ) => match read_u32 ( byte. chain ( reader) ) {
284
- Ok ( u) => ( Some ( Ok ( u) ) ) ,
281
+ Ok ( u) => Some ( Ok ( u) ) ,
285
282
Err ( Decode ( e) ) => Some ( Err ( io:: Error :: new ( InvalidData , e) ) ) ,
286
283
Err ( Io ( e) ) => Some ( Err ( e) ) ,
287
284
Err ( other) => Some ( Err ( io:: Error :: new ( Other , other) ) ) ,
0 commit comments