@@ -192,21 +192,40 @@ impl SelfProfileStorage for S3SelfProfileStorage {
192192 let upload = tempfile:: NamedTempFile :: new ( ) . context ( "cannot create temporary file" ) ?;
193193 match files {
194194 SelfProfileFiles :: Eight { file } => {
195+ let start = Instant :: now ( ) ;
195196 let data = tokio:: fs:: read ( file)
196197 . await
197198 . context ( "cannot read self-profile data" ) ?;
199+ log:: trace!(
200+ "Read self-profile duration: {}, size: {}" ,
201+ start. elapsed( ) . as_secs_f64( ) ,
202+ data. len( )
203+ ) ;
204+ let start = Instant :: now ( ) ;
198205 let mut data = snap:: read:: FrameEncoder :: new ( & data[ ..] ) ;
199206 let mut compressed = Vec :: new ( ) ;
200207 data. read_to_end ( & mut compressed)
201208 . context ( "cannot compress self-profile data" ) ?;
209+ log:: trace!(
210+ "Compress self-profile duration: {}, size: {}" ,
211+ start. elapsed( ) . as_secs_f64( ) ,
212+ compressed. len( )
213+ ) ;
214+ let start = Instant :: now ( ) ;
202215 tokio:: fs:: write ( upload. path ( ) , & compressed)
203216 . await
204217 . context ( "cannot write compressed self-profile data" ) ?;
218+ log:: trace!(
219+ "Write self-profile duration: {}" ,
220+ start. elapsed( ) . as_secs_f64( )
221+ ) ;
222+ compressed
205223 }
206224 } ;
207225
208226 log:: info!( "Uploading self-profile to {}" , file_path. display( ) ) ;
209227
228+ let start = Instant :: now ( ) ;
210229 let output = tokio:: process:: Command :: new ( "aws" )
211230 . arg ( "s3" )
212231 . arg ( "cp" )
@@ -232,6 +251,10 @@ impl SelfProfileStorage for S3SelfProfileStorage {
232251 String :: from_utf8_lossy( & output. stderr)
233252 ) ) ;
234253 }
254+ log:: trace!(
255+ "Upload self-profile duration: {}" ,
256+ start. elapsed( ) . as_secs_f64( )
257+ ) ;
235258 Ok ( ( ) )
236259 } )
237260 }
0 commit comments