aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--gradle/errorprone/experimental_warnings1
-rw-r--r--impl_core/src/main/java/io/opencensus/implcore/trace/export/SampledSpanStoreImpl.java14
2 files changed, 8 insertions, 7 deletions
diff --git a/gradle/errorprone/experimental_warnings b/gradle/errorprone/experimental_warnings
index 30ff6540..a5a45f4b 100644
--- a/gradle/errorprone/experimental_warnings
+++ b/gradle/errorprone/experimental_warnings
@@ -6,6 +6,7 @@ errorProneExperimentalWarnings = \
-Xep:EmptyTopLevelDeclaration:ERROR,\
-Xep:ExpectedExceptionChecker:ERROR,\
-Xep:HardCodedSdCardPath:ERROR,\
+-Xep:InconsistentOverloads:ERROR,\
-Xep:MissingDefault:OFF,\
-Xep:NonCanonicalStaticMemberImport:ERROR,\
-Xep:PrimitiveArrayPassedToVarargsMethod:ERROR,\
diff --git a/impl_core/src/main/java/io/opencensus/implcore/trace/export/SampledSpanStoreImpl.java b/impl_core/src/main/java/io/opencensus/implcore/trace/export/SampledSpanStoreImpl.java
index e0f9b832..60b1433c 100644
--- a/impl_core/src/main/java/io/opencensus/implcore/trace/export/SampledSpanStoreImpl.java
+++ b/impl_core/src/main/java/io/opencensus/implcore/trace/export/SampledSpanStoreImpl.java
@@ -91,12 +91,12 @@ public final class SampledSpanStoreImpl extends SampledSpanStore {
}
private void getSamples(int maxSpansToReturn, List<SpanImpl> output) {
- getSamples(sampledSpansQueue, maxSpansToReturn, output);
- getSamples(notSampledSpansQueue, maxSpansToReturn, output);
+ getSamples(maxSpansToReturn, output, sampledSpansQueue);
+ getSamples(maxSpansToReturn, output, notSampledSpansQueue);
}
private static void getSamples(
- EvictingQueue<SpanImpl> queue, int maxSpansToReturn, List<SpanImpl> output) {
+ int maxSpansToReturn, List<SpanImpl> output, EvictingQueue<SpanImpl> queue) {
for (SpanImpl span : queue) {
if (output.size() >= maxSpansToReturn) {
break;
@@ -108,17 +108,17 @@ public final class SampledSpanStoreImpl extends SampledSpanStore {
private void getSamplesFilteredByLatency(
long latencyLowerNs, long latencyUpperNs, int maxSpansToReturn, List<SpanImpl> output) {
getSamplesFilteredByLatency(
- sampledSpansQueue, latencyLowerNs, latencyUpperNs, maxSpansToReturn, output);
+ latencyLowerNs, latencyUpperNs, maxSpansToReturn, output, sampledSpansQueue);
getSamplesFilteredByLatency(
- notSampledSpansQueue, latencyLowerNs, latencyUpperNs, maxSpansToReturn, output);
+ latencyLowerNs, latencyUpperNs, maxSpansToReturn, output, notSampledSpansQueue);
}
private static void getSamplesFilteredByLatency(
- EvictingQueue<SpanImpl> queue,
long latencyLowerNs,
long latencyUpperNs,
int maxSpansToReturn,
- List<SpanImpl> output) {
+ List<SpanImpl> output,
+ EvictingQueue<SpanImpl> queue) {
for (SpanImpl span : queue) {
if (output.size() >= maxSpansToReturn) {
break;