@@ -57,9 +57,9 @@ impl FuseSession {
5757 ) -> Result < FuseSession > {
5858 let dest = mountpoint
5959 . canonicalize ( )
60- . map_err ( |_| SessionFailure ( format ! ( "invalid mountpoint {:?}" , mountpoint ) ) ) ?;
60+ . map_err ( |_| SessionFailure ( format ! ( "invalid mountpoint {mountpoint :?}" ) ) ) ?;
6161 if !dest. is_dir ( ) {
62- return Err ( SessionFailure ( format ! ( "{:?} is not a directory" , dest ) ) ) ;
62+ return Err ( SessionFailure ( format ! ( "{dest :?} is not a directory" ) ) ) ;
6363 }
6464
6565 Ok ( FuseSession {
@@ -82,7 +82,7 @@ impl FuseSession {
8282 let file = fuse_kern_mount ( & self . mountpoint , & self . fsname , & self . subtype , flags) ?;
8383
8484 fcntl ( file. as_raw_fd ( ) , FcntlArg :: F_SETFL ( OFlag :: O_NONBLOCK ) )
85- . map_err ( |e| SessionFailure ( format ! ( "set fd nonblocking: {}" , e ) ) ) ?;
85+ . map_err ( |e| SessionFailure ( format ! ( "set fd nonblocking: {e}" ) ) ) ?;
8686 self . file = Some ( file) ;
8787
8888 Ok ( ( ) )
@@ -136,7 +136,7 @@ impl FuseSession {
136136 if let Some ( file) = & self . file {
137137 let file = file
138138 . try_clone ( )
139- . map_err ( |e| SessionFailure ( format ! ( "dup fd: {}" , e ) ) ) ?;
139+ . map_err ( |e| SessionFailure ( format ! ( "dup fd: {e}" ) ) ) ?;
140140 let channel = FuseChannel :: new ( file, self . bufsize ) ?;
141141 let waker = channel. get_waker ( ) ;
142142 self . add_waker ( waker) ?;
@@ -151,7 +151,7 @@ impl FuseSession {
151151 let mut wakers = self
152152 . wakers
153153 . lock ( )
154- . map_err ( |e| SessionFailure ( format ! ( "lock wakers: {}" , e ) ) ) ?;
154+ . map_err ( |e| SessionFailure ( format ! ( "lock wakers: {e}" ) ) ) ?;
155155 wakers. push ( waker) ;
156156 Ok ( ( ) )
157157 }
@@ -161,11 +161,11 @@ impl FuseSession {
161161 let wakers = self
162162 . wakers
163163 . lock ( )
164- . map_err ( |e| SessionFailure ( format ! ( "lock wakers: {}" , e ) ) ) ?;
164+ . map_err ( |e| SessionFailure ( format ! ( "lock wakers: {e}" ) ) ) ?;
165165 for waker in wakers. iter ( ) {
166166 waker
167167 . wake ( )
168- . map_err ( |e| SessionFailure ( format ! ( "wake channel: {}" , e ) ) ) ?;
168+ . map_err ( |e| SessionFailure ( format ! ( "wake channel: {e}" ) ) ) ?;
169169 }
170170 Ok ( ( ) )
171171 }
@@ -189,9 +189,9 @@ pub struct FuseChannel {
189189
190190impl FuseChannel {
191191 fn new ( file : File , bufsize : usize ) -> Result < Self > {
192- let poll = Poll :: new ( ) . map_err ( |e| SessionFailure ( format ! ( "epoll create: {}" , e ) ) ) ?;
192+ let poll = Poll :: new ( ) . map_err ( |e| SessionFailure ( format ! ( "epoll create: {e}" ) ) ) ?;
193193 let waker = Waker :: new ( poll. registry ( ) , EXIT_FUSE_EVENT )
194- . map_err ( |e| SessionFailure ( format ! ( "epoll register session fd: {}" , e ) ) ) ?;
194+ . map_err ( |e| SessionFailure ( format ! ( "epoll register session fd: {e}" ) ) ) ?;
195195 let waker = Arc :: new ( waker) ;
196196
197197 // mio default add EPOLLET to event flags, so epoll will use edge-triggered mode.
@@ -205,7 +205,7 @@ impl FuseChannel {
205205 file. as_raw_fd ( ) ,
206206 Some ( & mut event) ,
207207 )
208- . map_err ( |e| SessionFailure ( format ! ( "epoll register channel fd: {}" , e ) ) ) ?;
208+ . map_err ( |e| SessionFailure ( format ! ( "epoll register channel fd: {e}" ) ) ) ?;
209209
210210 Ok ( FuseChannel {
211211 file,
@@ -233,7 +233,7 @@ impl FuseChannel {
233233 match self . poll . poll ( & mut events, None ) {
234234 Ok ( _) => { }
235235 Err ( ref e) if e. kind ( ) == std:: io:: ErrorKind :: Interrupted => continue ,
236- Err ( e) => return Err ( SessionFailure ( format ! ( "epoll wait: {}" , e ) ) ) ,
236+ Err ( e) => return Err ( SessionFailure ( format ! ( "epoll wait: {e}" ) ) ) ,
237237 }
238238
239239 for event in events. iter ( ) {
@@ -300,7 +300,7 @@ impl FuseChannel {
300300 }
301301 e => {
302302 warn ! { "read fuse dev failed on fd {}: {}" , fd, e} ;
303- return Err ( SessionFailure ( format ! ( "read new request: {:?}" , e ) ) ) ;
303+ return Err ( SessionFailure ( format ! ( "read new request: {e :?}" ) ) ) ;
304304 }
305305 } ,
306306 }
@@ -316,10 +316,10 @@ fn fuse_kern_mount(mountpoint: &Path, fsname: &str, subtype: &str, flags: MsFlag
316316 . read ( true )
317317 . write ( true )
318318 . open ( FUSE_DEVICE )
319- . map_err ( |e| SessionFailure ( format ! ( "open {}: {}" , FUSE_DEVICE , e ) ) ) ?;
319+ . map_err ( |e| SessionFailure ( format ! ( "open {FUSE_DEVICE }: {e}" ) ) ) ?;
320320 let meta = mountpoint
321321 . metadata ( )
322- . map_err ( |e| SessionFailure ( format ! ( "stat {:?}: {}" , mountpoint , e ) ) ) ?;
322+ . map_err ( |e| SessionFailure ( format ! ( "stat {mountpoint :?}: {e}" ) ) ) ?;
323323 let opts = format ! (
324324 "default_permissions,allow_other,fd={},rootmode={:o},user_id={},group_id={}" ,
325325 file. as_raw_fd( ) ,
@@ -350,7 +350,7 @@ fn fuse_kern_mount(mountpoint: &Path, fsname: &str, subtype: &str, flags: MsFlag
350350 flags,
351351 Some ( opts. deref ( ) ) ,
352352 )
353- . map_err ( |e| SessionFailure ( format ! ( "failed to mount {:?}: {}" , mountpoint , e ) ) ) ?;
353+ . map_err ( |e| SessionFailure ( format ! ( "failed to mount {mountpoint :?}: {e}" ) ) ) ?;
354354
355355 Ok ( file)
356356}
@@ -373,7 +373,7 @@ fn fuse_kern_umount(mountpoint: &str, file: File) -> Result<()> {
373373 // cause deadlock.
374374 drop ( file) ;
375375 umount2 ( mountpoint, MntFlags :: MNT_DETACH )
376- . map_err ( |e| SessionFailure ( format ! ( "failed to umount {}: {}" , mountpoint , e ) ) )
376+ . map_err ( |e| SessionFailure ( format ! ( "failed to umount {mountpoint }: {e}" ) ) )
377377}
378378
379379#[ cfg( test) ]
0 commit comments