This repository was archived by the owner on May 4, 2019. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +7
-11
lines changed
core/src/main/java/io/netifi/proteus/tracing Expand file tree Collapse file tree 1 file changed +7
-11
lines changed Original file line number Diff line number Diff line change 3131import java .util .Map ;
3232import java .util .concurrent .TimeUnit ;
3333import java .util .concurrent .atomic .AtomicBoolean ;
34- import java .util .concurrent .atomic .AtomicLong ;
3534
3635/**
3736 * A trace representation of the {@link Subscriber}
@@ -150,16 +149,13 @@ public void request(long n) {
150149 if (log .isTraceEnabled ()) {
151150 log .trace ("Request" );
152151 }
153- try (Scope scope = this .tracer .scopeManager ().activate (span , false )) {
154- scope .span ().log (TimeUnit .MILLISECONDS .toMicros (System .currentTimeMillis ()), "request" );
155- if (log .isTraceEnabled ()) {
156- log .trace ("Request - continued" );
157- }
158- this .s .request (n );
159- // no additional cleaning is required cause we operate on scopes
160- if (log .isTraceEnabled ()) {
161- log .trace ("Request after cleaning. Current span [{}]" , this .tracer .activeSpan ());
162- }
152+ if (log .isTraceEnabled ()) {
153+ log .trace ("Request - continued" );
154+ }
155+ this .s .request (n );
156+ // no additional cleaning is required cause we operate on scopes
157+ if (log .isTraceEnabled ()) {
158+ log .trace ("Request after cleaning. Current span [{}]" , this .tracer .activeSpan ());
163159 }
164160 }
165161
You can’t perform that action at this time.
0 commit comments