2424#![ allow( warnings) ]
2525#![ cfg( feature = "tracing" ) ]
2626
27- // This is here and not in src/lib.rs since it is a direct dependency of tracing_chrome.rs and
28- // should not be included if the "tracing" feature is disabled.
29- extern crate tracing_core;
30-
31- use tracing_core:: { field:: Field , span, Event , Subscriber } ;
32- use tracing_subscriber:: {
27+ use rustc_log:: tracing_core:: { field:: Field , span, Event , Subscriber } ;
28+ use rustc_log:: tracing_subscriber:: {
29+ self ,
3330 layer:: Context ,
3431 registry:: { LookupSpan , SpanRef } ,
3532 Layer ,
@@ -526,16 +523,16 @@ where
526523 }
527524 } ,
528525 TraceStyle :: Async => Some (
529- span. scope ( )
530- . from_root ( )
531- . take ( 1 )
532- . next ( )
533- . unwrap_or ( span)
534- . id ( )
535- . into_u64 ( )
526+ span. scope ( )
527+ . from_root ( )
528+ . take ( 1 )
529+ . next ( )
530+ . unwrap_or ( span)
531+ . id ( )
532+ . into_u64 ( )
536533 . cast_signed ( ) // the comment above explains the cast
537534 ) ,
538- }
535+ }
539536 }
540537
541538 fn enter_span ( & self , span : SpanRef < S > , ts : f64 , tid : usize , out : & Sender < Message > ) {
@@ -570,11 +567,11 @@ where
570567 Some ( thread_data) => ( thread_data, false ) ,
571568 None => {
572569 let tid = self . max_tid . fetch_add ( 1 , Ordering :: SeqCst ) ;
573- let out = self . out . lock ( ) . unwrap ( ) . clone ( ) ;
570+ let out = self . out . lock ( ) . unwrap ( ) . clone ( ) ;
574571 let start = TracingChromeInstant :: setup_for_thread_and_start ( tid) ;
575572 * thread_data = Some ( ThreadData { tid, out, start } ) ;
576573 ( thread_data. as_mut ( ) . unwrap ( ) , true )
577- }
574+ }
578575 } ;
579576
580577 start. with_elapsed_micros_subtracting_tracing ( |ts| {
@@ -586,7 +583,7 @@ where
586583 let _ignored = out. send ( Message :: NewThread ( * tid, name) ) ;
587584 }
588585 f ( ts, * tid, out) ;
589- } ) ;
586+ } ) ;
590587 } ) ;
591588 }
592589}
@@ -608,15 +605,15 @@ where
608605 fn on_record ( & self , id : & span:: Id , values : & span:: Record < ' _ > , ctx : Context < ' _ , S > ) {
609606 if self . include_args {
610607 self . with_elapsed_micros_subtracting_tracing ( |_, _, _| {
611- let span = ctx. span ( id) . unwrap ( ) ;
612- let mut exts = span. extensions_mut ( ) ;
608+ let span = ctx. span ( id) . unwrap ( ) ;
609+ let mut exts = span. extensions_mut ( ) ;
613610
614- let args = exts. get_mut :: < ArgsWrapper > ( ) ;
611+ let args = exts. get_mut :: < ArgsWrapper > ( ) ;
615612
616- if let Some ( args) = args {
617- let args = Arc :: make_mut ( & mut args. args ) ;
618- values. record ( & mut JsonVisitor { object : args } ) ;
619- }
613+ if let Some ( args) = args {
614+ let args = Arc :: make_mut ( & mut args. args ) ;
615+ values. record ( & mut JsonVisitor { object : args } ) ;
616+ }
620617 } ) ;
621618 }
622619 }
@@ -639,16 +636,16 @@ where
639636
640637 fn on_new_span ( & self , attrs : & span:: Attributes < ' _ > , id : & span:: Id , ctx : Context < ' _ , S > ) {
641638 self . with_elapsed_micros_subtracting_tracing ( |ts, tid, out| {
642- if self . include_args {
643- let mut args = Object :: new ( ) ;
644- attrs. record ( & mut JsonVisitor { object : & mut args } ) ;
645- ctx. span ( id) . unwrap ( ) . extensions_mut ( ) . insert ( ArgsWrapper {
646- args : Arc :: new ( args) ,
647- } ) ;
648- }
649- if let TraceStyle :: Threaded = self . trace_style {
650- return ;
651- }
639+ if self . include_args {
640+ let mut args = Object :: new ( ) ;
641+ attrs. record ( & mut JsonVisitor { object : & mut args } ) ;
642+ ctx. span ( id) . unwrap ( ) . extensions_mut ( ) . insert ( ArgsWrapper {
643+ args : Arc :: new ( args) ,
644+ } ) ;
645+ }
646+ if let TraceStyle :: Threaded = self . trace_style {
647+ return ;
648+ }
652649
653650 self . enter_span ( ctx. span ( id) . expect ( "Span not found." ) , ts, tid, out) ;
654651 } ) ;
0 commit comments