summaryrefslogtreecommitdiff
path: root/src/mongo/s/query_analysis_sampler_test.cpp
diff options
context:
space:
mode:
authorCheahuychou Mao <mao.cheahuychou@gmail.com>2022-11-03 20:40:57 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-11-03 21:24:24 +0000
commit8a72ef0233292c9e932c7805b2b85b4973bd1420 (patch)
tree63470e027b31778fb7e82c9e8173f456370f65f9 /src/mongo/s/query_analysis_sampler_test.cpp
parenteb2752ebc1912221f25f50a5715aa6fbd174d72b (diff)
downloadmongo-8a72ef0233292c9e932c7805b2b85b4973bd1420.tar.gz
SERVER-69802 Support sampling write queries on sharded clusters
Diffstat (limited to 'src/mongo/s/query_analysis_sampler_test.cpp')
-rw-r--r--src/mongo/s/query_analysis_sampler_test.cpp26
1 files changed, 13 insertions, 13 deletions
diff --git a/src/mongo/s/query_analysis_sampler_test.cpp b/src/mongo/s/query_analysis_sampler_test.cpp
index c7f14a59ce6..fda0a8d4688 100644
--- a/src/mongo/s/query_analysis_sampler_test.cpp
+++ b/src/mongo/s/query_analysis_sampler_test.cpp
@@ -741,31 +741,31 @@ TEST_F(QueryAnalysisSamplerTest, ShouldSampleBasic) {
setUpConfigurations(&sampler, configurations);
// Cannot sample if time has not elapsed.
- ASSERT_FALSE(sampler.shouldSample(nss0));
- ASSERT_FALSE(sampler.shouldSample(nss1));
+ ASSERT_FALSE(sampler.tryGenerateSampleId(nss0));
+ ASSERT_FALSE(sampler.tryGenerateSampleId(nss1));
advanceTime(Milliseconds(1000));
// The number of tokens available in the bucket for rateLimiter0 right after the refill is 0
// + 1.0.
- ASSERT(sampler.shouldSample(nss0));
- ASSERT_FALSE(sampler.shouldSample(nss0));
+ ASSERT(sampler.tryGenerateSampleId(nss0));
+ ASSERT_FALSE(sampler.tryGenerateSampleId(nss0));
// The number of tokens available in the bucket for rateLimiter1 right after the refill is 0 +
// 0.5.
- ASSERT_FALSE(sampler.shouldSample(nss1));
+ ASSERT_FALSE(sampler.tryGenerateSampleId(nss1));
// This collection doesn't have sampling enabled.
- ASSERT_FALSE(sampler.shouldSample(nss2));
+ ASSERT_FALSE(sampler.tryGenerateSampleId(nss2));
advanceTime(Milliseconds(1000));
// The number of tokens available in the bucket for rateLimiter0 right after the refill is 0
// + 1.0.
- ASSERT(sampler.shouldSample(nss0));
- ASSERT_FALSE(sampler.shouldSample(nss0));
+ ASSERT(sampler.tryGenerateSampleId(nss0));
+ ASSERT_FALSE(sampler.tryGenerateSampleId(nss0));
// The number of tokens available in the bucket for rateLimiter1 right after the refill is 0.5 +
// 0.5.
- ASSERT(sampler.shouldSample(nss1));
- ASSERT_FALSE(sampler.shouldSample(nss1));
+ ASSERT(sampler.tryGenerateSampleId(nss1));
+ ASSERT_FALSE(sampler.tryGenerateSampleId(nss1));
// This collection doesn't have sampling enabled.
- ASSERT_FALSE(sampler.shouldSample(nss2));
+ ASSERT_FALSE(sampler.tryGenerateSampleId(nss2));
}
TEST_F(QueryAnalysisSamplerTest, RefreshConfigurationsNewCollectionUuid) {
@@ -788,7 +788,7 @@ TEST_F(QueryAnalysisSamplerTest, RefreshConfigurationsNewCollectionUuid) {
advanceTime(Milliseconds(1000));
// The number of tokens available in the bucket right after the refill is 0 + 2.
- ASSERT(sampler.shouldSample(nss0));
+ ASSERT(sampler.tryGenerateSampleId(nss0));
// Force the sampler to refresh and return a different collection uuid and sample rate this
// time.
@@ -812,7 +812,7 @@ TEST_F(QueryAnalysisSamplerTest, RefreshConfigurationsNewCollectionUuid) {
// Cannot sample if time has not elapsed. There should be no tokens available in the bucket
// right after the refill unless the one token from the previous configurations was
// carried over, which is not the correct behavior.
- ASSERT_FALSE(sampler.shouldSample(nss0));
+ ASSERT_FALSE(sampler.tryGenerateSampleId(nss0));
}
} // namespace