aboutsummaryrefslogtreecommitdiffstats
path: root/yt
diff options
context:
space:
mode:
authorosidorkin <osidorkin@yandex-team.com>2024-07-31 19:17:10 +0300
committerosidorkin <osidorkin@yandex-team.com>2024-07-31 19:31:11 +0300
commitd20a7253e7c98c39d8a0c23745bbe7ab0484fd14 (patch)
treeddd3f5e9f4fbc2c17fa654bf2a199afd775265cf /yt
parentf81030974a4660e301c110a5085c53dae44f7279 (diff)
downloadydb-d20a7253e7c98c39d8a0c23745bbe7ab0484fd14.tar.gz
YT-20327: More logging of ClockClusterTag in timestamp providers
7a6f61d1aa10edd839c19bc67e48c5f59cd44e32
Diffstat (limited to 'yt')
-rw-r--r--yt/yt/client/transaction_client/timestamp_provider_base.cpp9
1 files changed, 6 insertions, 3 deletions
diff --git a/yt/yt/client/transaction_client/timestamp_provider_base.cpp b/yt/yt/client/transaction_client/timestamp_provider_base.cpp
index 3971b897a1..c5e8246562 100644
--- a/yt/yt/client/transaction_client/timestamp_provider_base.cpp
+++ b/yt/yt/client/transaction_client/timestamp_provider_base.cpp
@@ -25,7 +25,9 @@ TFuture<TTimestamp> TTimestampProviderBase::GenerateTimestamps(int count, TCellT
{
VERIFY_THREAD_AFFINITY_ANY();
- YT_LOG_DEBUG("Generating fresh timestamps (Count: %v)", count);
+ YT_LOG_DEBUG("Generating fresh timestamps (Count: %v, ClockClusterTag: %v)",
+ count,
+ clockClusterTag);
return DoGenerateTimestamps(count, clockClusterTag).Apply(BIND(
&TTimestampProviderBase::OnGenerateTimestamps,
@@ -76,9 +78,10 @@ TFuture<TTimestamp> TTimestampProviderBase::OnGenerateTimestamps(
auto firstTimestamp = timestampOrError.Value();
auto lastTimestamp = firstTimestamp + count - 1;
- YT_LOG_DEBUG("Fresh timestamps generated (Timestamps: %v-%v)",
+ YT_LOG_DEBUG("Fresh timestamps generated (Timestamps: %v-%v, ClockClusterTag: %v)",
firstTimestamp,
- lastTimestamp);
+ lastTimestamp,
+ clockClusterTag);
auto& latestTimestamp = GetLatestTimestampReferenceByTag(clockClusterTag);
auto latestTimestampValue = latestTimestamp.load(std::memory_order::relaxed);