Searched refs:currentLocalTime (Results 1 – 4 of 4) sorted by relevance
107 Timestamp currentLocalTime = currentSysTime + static_cast<Timestamp>(localTimeOffset); in GetTime() local115 if (currentLocalTime <= lastLocalTime || currentLocalTime > BUFFER_VALID_TIME) { in GetTime()117 currentLocalTime = lastLocalTime; in GetTime()120 metadata_->SetLastLocalTime(currentLocalTime); in GetTime()122 return currentLocalTime; in GetTime()
181 Timestamp currentLocalTime = context->GetCurrentLocalTime(); in TransSendDataItemToLocal() local182 if (item->GetTimestamp() > currentLocalTime) { in TransSendDataItemToLocal()183 item->SetTimestamp(currentLocalTime); in TransSendDataItemToLocal()185 if (item->GetWriteTimestamp() > currentLocalTime) { in TransSendDataItemToLocal()186 item->SetWriteTimestamp(currentLocalTime); in TransSendDataItemToLocal()
471 Timestamp currentLocalTime = context_->GetCurrentLocalTime(); in OneCommitSyncFinish() local475 TimeOffset timefixOffset = (commit.timestamp < currentLocalTime) ? 0 : (commit.timestamp - in OneCommitSyncFinish()476 static_cast<Timestamp>(currentLocalTime)); in OneCommitSyncFinish()
204 Timestamp currentLocalTime = currentSysTime + timeOffset + localTimeOffset_; in GetTime() local205 if (currentLocalTime <= lastLocalTime_ || currentLocalTime > MAX_VALID_TIME) { in GetTime()207 lastLocalTime_, currentLocalTime, deltaTime); in GetTime()210 currentLocalTime = lastLocalTime_; in GetTime()212 lastLocalTime_ = currentLocalTime; in GetTime()217 return currentLocalTime; in GetTime()233 Timestamp currentLocalTime = currentSysTime + timeOffset + localTimeOffset; in TimeSkew() local234 auto virtualTimeOffset = static_cast<int64_t>(currentLocalTime - lastLocalTime_); in TimeSkew()