aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorilnaz <ilnaz@ydb.tech>2023-11-16 17:59:21 +0300
committerilnaz <ilnaz@ydb.tech>2023-11-16 19:18:29 +0300
commit60dad5750b189c7004c4612656397c121b9cb15b (patch)
tree9d1b51bd7a2944aef67c4d51267ae06c765326d4
parentae3fa3e5280f175a36c198d90bd230d514bd2b82 (diff)
downloadydb-60dad5750b189c7004c4612656397c121b9cb15b.tar.gz
Explicit use of MicroSeconds() instead of GetValue()/FromValue() KIKIMR-16851
-rw-r--r--ydb/core/tx/datashard/change_collector.h2
-rw-r--r--ydb/core/tx/datashard/change_record.cpp2
-rw-r--r--ydb/core/tx/datashard/datashard.cpp2
3 files changed, 3 insertions, 3 deletions
diff --git a/ydb/core/tx/datashard/change_collector.h b/ydb/core/tx/datashard/change_collector.h
index dcef250a705..b18348d6e3b 100644
--- a/ydb/core/tx/datashard/change_collector.h
+++ b/ydb/core/tx/datashard/change_collector.h
@@ -62,7 +62,7 @@ public:
TInstant CreatedAt() const {
return Group
- ? TInstant::FromValue(Group)
+ ? TInstant::MicroSeconds(Group)
: TInstant::MilliSeconds(Step);
}
};
diff --git a/ydb/core/tx/datashard/change_record.cpp b/ydb/core/tx/datashard/change_record.cpp
index 0a2475d6738..d87038bd66f 100644
--- a/ydb/core/tx/datashard/change_record.cpp
+++ b/ydb/core/tx/datashard/change_record.cpp
@@ -66,7 +66,7 @@ i64 TChangeRecord::GetSeqNo() const {
TInstant TChangeRecord::GetApproximateCreationDateTime() const {
return GetGroup()
- ? TInstant::FromValue(GetGroup())
+ ? TInstant::MicroSeconds(GetGroup())
: TInstant::MilliSeconds(GetStep());
}
diff --git a/ydb/core/tx/datashard/datashard.cpp b/ydb/core/tx/datashard/datashard.cpp
index eac541490f9..b6a3ae7ca34 100644
--- a/ydb/core/tx/datashard/datashard.cpp
+++ b/ydb/core/tx/datashard/datashard.cpp
@@ -690,7 +690,7 @@ ui64 TDataShard::AllocateChangeRecordOrder(NIceDb::TNiceDb& db, ui64 count) {
}
ui64 TDataShard::AllocateChangeRecordGroup(NIceDb::TNiceDb& db) {
- const ui64 now = TInstant::Now().GetValue();
+ const ui64 now = TInstant::Now().MicroSeconds();
const ui64 result = now > LastChangeRecordGroup ? now : (LastChangeRecordGroup + 1);
LastChangeRecordGroup = result;