diff options
author | osidorkin <osidorkin@yandex-team.com> | 2024-07-31 19:17:10 +0300 |
---|---|---|
committer | osidorkin <osidorkin@yandex-team.com> | 2024-07-31 19:31:11 +0300 |
commit | d20a7253e7c98c39d8a0c23745bbe7ab0484fd14 (patch) | |
tree | ddd3f5e9f4fbc2c17fa654bf2a199afd775265cf /yt | |
parent | f81030974a4660e301c110a5085c53dae44f7279 (diff) | |
download | ydb-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.cpp | 9 |
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); |