diff options
author | Bogdan Drutu <bdrutu@google.com> | 2017-10-25 15:25:33 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-10-25 15:25:33 -0700 |
commit | 89f06e756efed61b9307f51af760d6a4b291572a (patch) | |
tree | ce662441f4325ffadced2b5e2fbeab7e71391b31 /impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java | |
parent | b44296aabfd7c67d9b1a9a1ca97d658fefd0513a (diff) | |
download | opencensus-java-89f06e756efed61b9307f51af760d6a4b291572a.tar.gz |
Remove contention between threads and worker thread when register span names. (#729)
* Remove contention between threads and worker thread when register span names.
* Mark getRegisteredSpanNamesForCollection as test only.
Diffstat (limited to 'impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java')
-rw-r--r-- | impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java b/impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java index f5f70a52..f4c5ef76 100644 --- a/impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java +++ b/impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java @@ -41,7 +41,6 @@ public final class TraceComponentImplBase { private final ExportComponentImpl exportComponent; private final PropagationComponent propagationComponent = new PropagationComponentImpl(); private final Clock clock; - private final StartEndHandler startEndHandler; private final TraceConfig traceConfig = new TraceConfigImpl(); private final Tracer tracer; @@ -56,11 +55,11 @@ public final class TraceComponentImplBase { this.clock = clock; // TODO(bdrutu): Add a config/argument for supportInProcessStores. if (eventQueue instanceof SimpleEventQueue) { - exportComponent = ExportComponentImpl.createWithoutInProcessStores(); + exportComponent = ExportComponentImpl.createWithoutInProcessStores(eventQueue); } else { - exportComponent = ExportComponentImpl.createWithInProcessStores(); + exportComponent = ExportComponentImpl.createWithInProcessStores(eventQueue); } - startEndHandler = + StartEndHandler startEndHandler = new StartEndHandlerImpl( exportComponent.getSpanExporter(), exportComponent.getRunningSpanStore(), |