aboutsummaryrefslogtreecommitdiff
path: root/impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java
diff options
context:
space:
mode:
authorBogdan Drutu <bdrutu@google.com>2017-10-25 15:25:33 -0700
committerGitHub <noreply@github.com>2017-10-25 15:25:33 -0700
commit89f06e756efed61b9307f51af760d6a4b291572a (patch)
treece662441f4325ffadced2b5e2fbeab7e71391b31 /impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java
parentb44296aabfd7c67d9b1a9a1ca97d658fefd0513a (diff)
downloadopencensus-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.java7
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(),