Home
last modified time | relevance | path

Searched refs:Timestamp (Results 1 – 25 of 264) sorted by relevance

1234567891011

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
H A Dtime_helper.cpp24 Timestamp TimeHelper::lastSystemTimeUs_ = 0;
25 Timestamp TimeHelper::currentIncCount_ = 0;
28 Timestamp TimeHelper::GetSysCurrentTime() in GetSysCurrentTime()
89 Timestamp virtualSysTime = static_cast<Timestamp>(currentSysTime + localTimeOffset); in Initialize()
103 Timestamp TimeHelper::GetTime() in GetTime()
107 Timestamp currentLocalTime = currentSysTime + static_cast<Timestamp>(localTimeOffset); in GetTime()
110 Timestamp deltaTime = 1UL; in GetTime()
125 Timestamp TimeHelper::GetMaxDataItemTime() in GetMaxDataItemTime()
127 Timestamp timestamp = 0; in GetMaxDataItemTime()
147 Timestamp TimeHelper::GetMonotonicTime() in GetMonotonicTime()
[all …]
H A Dtime_helper.h38 static const Timestamp INVALID_TIMESTAMP = 0;
41 static Timestamp GetSysCurrentTime();
51 Timestamp GetTime();
54 Timestamp GetMaxDataItemTime();
64 static Timestamp GetMonotonicTime();
68 static Timestamp lastSystemTimeUs_;
69 static Timestamp currentIncCount_;
71 static std::atomic<Timestamp> lastMonotonicTime_;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_continue_token.h28 SQLiteSingleVerContinueToken(Timestamp begin, Timestamp end);
45 Timestamp GetQueryBeginTime() const;
46 Timestamp GetQueryEndTime() const;
47 Timestamp GetDeletedBeginTime() const;
48 Timestamp GetDeletedEndTime() const;
50 void SetNextBeginTime(const DeviceID &deviceID, Timestamp nextBeginTime);
52 void SetDeletedNextBeginTime(const DeviceID &deviceID, Timestamp nextBeginTime);
70 …void RemovePrevDevAndSetBeginTime(const DeviceID &deviceID, Timestamp nextBeginTime, MulDevTimeRan…
72 Timestamp GetBeginTimestamp(const MulDevTimeRanges &timeRanges) const;
73 Timestamp GetEndTimestamp(const MulDevTimeRanges &timeRanges) const;
H A Dsqlite_single_ver_continue_token.cpp21 SQLiteSingleVerContinueToken::SQLiteSingleVerContinueToken(Timestamp begin, Timestamp end) in SQLiteSingleVerContinueToken()
44 Timestamp SQLiteSingleVerContinueToken::GetQueryBeginTime() const in GetQueryBeginTime()
49 Timestamp SQLiteSingleVerContinueToken::GetQueryEndTime() const in GetQueryEndTime()
54 Timestamp SQLiteSingleVerContinueToken::GetDeletedBeginTime() const in GetDeletedBeginTime()
59 Timestamp SQLiteSingleVerContinueToken::GetDeletedEndTime() const in GetDeletedEndTime()
64 void SQLiteSingleVerContinueToken::SetNextBeginTime(const DeviceID &deviceID, Timestamp nextBeginTi… in SetNextBeginTime()
74 void SQLiteSingleVerContinueToken::SetDeletedNextBeginTime(const DeviceID &deviceID, Timestamp next… in SetDeletedNextBeginTime()
117 void SQLiteSingleVerContinueToken::RemovePrevDevAndSetBeginTime(const DeviceID &deviceID, Timestamp… in RemovePrevDevAndSetBeginTime()
128 Timestamp SQLiteSingleVerContinueToken::GetBeginTimestamp(const MulDevTimeRanges &timeRanges) const in GetBeginTimestamp()
136 Timestamp SQLiteSingleVerContinueToken::GetEndTimestamp(const MulDevTimeRanges &timeRanges) const in GetEndTimestamp()
[all …]
H A Dsqlite_single_ver_storage_executor.h44 Timestamp timestamp, SingleVerNaturalStoreCommitNotifyData *committedData);
62 Timestamp &timestamp);
75 void InitCurrentMaxStamp(Timestamp &maxStamp);
80 Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const;
82 Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const;
126 int UpdateLocalDataTimestamp(Timestamp timestamp);
152 int GetMaxTimestampDuringMigrating(Timestamp &maxTimestamp) const;
180 const std::pair<Timestamp, Timestamp> &timeRange, std::vector<DataItem> &dataItems) const;
242 …int PrepareForSyncDataByTime(Timestamp begin, Timestamp end, sqlite3_stmt *&statement, bool getDel…
303 int GetMinTimestampInCacheDB(Timestamp &minStamp) const;
[all …]
H A Dsqlite_single_ver_natural_store.h77 …int GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems, ContinueToken &c…
80 int GetSyncData(Timestamp begin, Timestamp end, std::vector<SingleVerKvEntry *> &entries,
97 void GetMaxTimestamp(Timestamp &stamp) const override;
131 Timestamp GetCurrentTimestamp(bool needStartSync = true) override;
169 int GetDatabaseCreateTimestamp(Timestamp &outTime) const override;
286 Timestamp &maxTimestamp, SingleVerNaturalStoreCommitNotifyData *commitData) const;
292 … std::vector<DataItem> &dataItems, const DeviceInfo &deviceInfo, Timestamp &maxTimestamp) const;
328 mutable Timestamp createDBTime_;
H A Dsqlite_cloud_kv_store.h46 …int GetUploadCount(const QuerySyncObject &query, const Timestamp &timestamp, bool isCloudForcePush,
49 int GetAllUploadCount(const QuerySyncObject &query, const std::vector<Timestamp> &timestampVec,
52 …int GetCloudData(const TableSchema &tableSchema, const QuerySyncObject &object, const Timestamp &b…
100 …void ReleaseUploadRecord(const std::string &tableName, const CloudWaterType &type, Timestamp local…
110 …static void FillTimestamp(Timestamp rawSystemTime, Timestamp virtualTime, CloudSyncBatch &syncBatc…
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dtime_sync.h30 void SetSourceTimeBegin(Timestamp sourceTimeBegin);
32 Timestamp GetSourceTimeBegin() const;
34 void SetSourceTimeEnd(Timestamp sourceTimeEnd);
36 Timestamp GetSourceTimeEnd() const;
38 void SetTargetTimeBegin(Timestamp targetTimeBegin);
40 Timestamp GetTargetTimeBegin() const;
42 void SetTargetTimeEnd(Timestamp targetTimeEnd);
44 Timestamp GetTargetTimeEnd() const;
63 Timestamp targetTimeEnd_; // end point time on peer
136 Timestamp GetSourceBeginTime(Timestamp packetBeginTime, uint32_t sessionId);
[all …]
H A Dtime_sync.cpp57 Timestamp TimeSyncPacket::GetSourceTimeBegin() const in GetSourceTimeBegin()
67 Timestamp TimeSyncPacket::GetSourceTimeEnd() const in GetSourceTimeEnd()
77 Timestamp TimeSyncPacket::GetTargetTimeBegin() const in GetTargetTimeBegin()
87 Timestamp TimeSyncPacket::GetTargetTimeEnd() const in GetTargetTimeEnd()
232 Timestamp startTime = timeHelper_->GetTime(); in SyncStart()
287 Timestamp srcEnd = packet->GetSourceTimeEnd(); in Serialization()
327 Timestamp srcBegin; in DeSerialization()
328 Timestamp srcEnd; in DeSerialization()
329 Timestamp targetBegin; in DeSerialization()
330 Timestamp targetEnd; in DeSerialization()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Ddb_types.h31 using Timestamp = uint64_t; variable
45 Timestamp timestamp = 0;
48 Timestamp writeTimestamp = 0;
53 Timestamp modifyTime = 0;
54 Timestamp createTime = 0;
140 Timestamp beginTime = 0;
141 Timestamp deleteBeginTime = 0;
142 Timestamp endTime = static_cast<Timestamp>(INT64_MAX);
143 Timestamp deleteEndTime = static_cast<Timestamp>(INT64_MAX);
144 Timestamp lastQueryTime = 0;
[all …]
H A Dperformance_analysis.h57 Timestamp startTime = 0;
58 Timestamp endTime = 0;
62 Timestamp max = 0;
63 Timestamp min = 0;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/
H A Dcloud_meta_data.h36 int GetLocalWaterMark(const TableName &tableName, Timestamp &localMark);
37 …int GetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timestamp &localMark);
40 int SetLocalWaterMark(const TableName &tableName, Timestamp localMark);
41 … int SetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timestamp localMark);
52 Timestamp localMark = 0u;
53 Timestamp insertLocalMark = 0u;
54 Timestamp updateLocalMark = 0u;
55 Timestamp deleteLocalMark = 0u;
60 int WriteMarkToMeta(const TableName &tableName, Timestamp localmark, std::string &cloudMark);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_single_ver_sync_db_Interface.h31 Timestamp timestamp = 0;
32 Timestamp writeTimestamp = 0;
41 Timestamp begin = 0u;
42 Timestamp end = 0u;
65 int GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems,
73 void GetMaxTimestamp(Timestamp& stamp) const override;
81 int PutData(const Key &key, const Value &value, const Timestamp &time, int flag);
83 int GetSyncData(Timestamp begin, Timestamp end, std::vector<SingleVerKvEntry *> &entries,
113 int GetDatabaseCreateTimestamp(Timestamp &outTime) const override;
153 int GetSyncData(Timestamp begin, Timestamp end, const DataSizeSpecInfo &dataSizeInfo,
[all …]
H A Dvirtual_single_ver_sync_db_Interface.cpp132 int VirtualSingleVerSyncDBInterface::GetSyncData(Timestamp begin, Timestamp end, std::vector<DataIt… in GetSyncData()
167 int VirtualSingleVerSyncDBInterface::PutData(const Key &key, const Value &value, const Timestamp &t… in PutData()
180 void VirtualSingleVerSyncDBInterface::GetMaxTimestamp(Timestamp& stamp) const in GetMaxTimestamp()
226 int VirtualSingleVerSyncDBInterface::GetSyncData(Timestamp begin, Timestamp end, in GetSyncData()
254 Timestamp currentWaterMark = 0; in GetSyncDataNext()
271 int VirtualSingleVerSyncDBInterface::GetSyncData(Timestamp begin, Timestamp end, const DataSizeSpec… in GetSyncData()
281 Timestamp currentWaterMark = 0; in GetSyncData()
396 int VirtualSingleVerSyncDBInterface::GetDatabaseCreateTimestamp(Timestamp &outTime) const in GetDatabaseCreateTimestamp()
588 bool VirtualSingleVerSyncDBInterface::GetDataInner(Timestamp begin, Timestamp end, Timestamp &curre… in GetDataInner()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_storage_executor.h53 int GetKvData(SingleVerDataType type, const Key &key, Value &value, Timestamp &timestamp) const;
62 Timestamp timestamp, SingleVerNaturalStoreCommitNotifyData *committedData);
86 Timestamp &timestamp);
93 void InitCurrentMaxStamp(Timestamp &maxStamp);
97 … int GetSyncDataByTimestamp(std::vector<DataItem> &dataItems, size_t appendLength, Timestamp begin,
98 Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const;
101 Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const;
127 bool CheckIfKeyExisted(const Key &key, bool isLocal, Value &value, Timestamp &timestamp) const;
131 int UpdateLocalDataTimestamp(Timestamp timestamp);
160 int GetMaxTimestampDuringMigrating(Timestamp &maxTimestamp) const;
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dstorage_proxy.h42 int GetLocalWaterMark(const std::string &tableName, Timestamp &localMark);
44 …int GetLocalWaterMarkByMode(const std::string &tableName, CloudWaterType mode, Timestamp &localMar…
46 int PutLocalWaterMark(const std::string &tableName, Timestamp &localMark);
48 int PutWaterMarkByMode(const std::string &tableName, CloudWaterType mode, Timestamp &localMark);
60 …int GetUploadCount(const std::string &tableName, const Timestamp &timestamp, const bool isCloudFor…
66 …int GetUploadCount(const QuerySyncObject &query, const Timestamp &localMark, bool isCloudForcePush,
69 int GetCloudData(const std::string &tableName, const Timestamp &timeRange,
72 int GetCloudData(const QuerySyncObject &querySyncObject, const Timestamp &timeRange,
156 …void ReleaseUploadRecord(const std::string &table, const CloudWaterType &type, Timestamp localWate…
163 static Timestamp EraseNanoTime(Timestamp localTime);
H A Dsingle_ver_kv_entry.h29 virtual Timestamp GetTimestamp() const = 0;
30 virtual void SetTimestamp(Timestamp timestamp) = 0;
31 virtual Timestamp GetWriteTimestamp() const = 0;
32 virtual void SetWriteTimestamp(Timestamp timestamp) = 0;
H A Dsync_generic_interface.h30 virtual int GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems, in GetSyncData()
40 … virtual int GetSyncData(Timestamp begin, Timestamp end, std::vector<SingleVerKvEntry *> &entries, in GetSyncData()
97 virtual int GetDatabaseCreateTimestamp(Timestamp &outTime) const in GetDatabaseCreateTimestamp()
/ohos5.0/foundation/multimedia/audio_lite/interfaces/kits/
H A Daudio_capturer.h80 class Timestamp {
82 Timestamp() : framePosition(0) in Timestamp() function
87 ~Timestamp() = default;
229 bool GetAudioTime(Timestamp &timestamp, Timestamp::Timebase base);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.h34 Timestamp start = 0;
35 Timestamp end = 0;
36 Timestamp deleteBeginTime = 0;
37 Timestamp deleteEndTime = 0;
46 Timestamp start = 0; // means normal or sync data localwatermark
47 Timestamp end = 0;
48 Timestamp deleteDataStart = 0; // means delete data localwatermark
49 Timestamp deleteDataEnd = 0;
137 void SetSessionEndTimestamp(Timestamp end);
139 Timestamp GetSessionEndTimestamp() const;
[all …]
/ohos5.0/foundation/systemabilitymgr/safwk/interfaces/innerkits/safwk/
H A Dexpire_lru_cache.h67 class Timestamp {
69 Timestamp() in Timestamp() function
73 ~Timestamp() {} in ~Timestamp()
75 int64_t operator-(const Timestamp& ts)
82 Timestamp now; in IsExpired()
99 std::map<TKey, Timestamp> timestamp_;
104 Timestamp now; in DoAdd()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dtime_tick_monitor.h57 static Timestamp GetSysCurrentTime();
60 static Timestamp GetMonotonicTime();
73 Timestamp lastMonotonicTime_ = 0;
74 Timestamp lastSystemTime_ = 0;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_store_sqlite_ext.cpp128 using Timestamp = uint64_t; typedef
184 Timestamp GetTime(TimeOffset timeOffset, const std::function<Timestamp()> &getDbMaxTimestamp, in GetTime()
220 bool TimeSkew(const std::function<Timestamp()> &getLocalTimeOffsetFromDB, Timestamp timeOffset) in TimeSkew()
252 Timestamp GetLastTime() const in GetLastTime()
298 Timestamp lastLocalTime_ = 0;
302 Timestamp lastSystemTime_ = 0;
303 Timestamp lastMonotonicTime_ = 0;
346 Timestamp timeOffset) in TimeSkew()
557 std::function<Timestamp()> getDbMaxTimestamp = [db]() -> Timestamp { in GetSysTime()
558 Timestamp maxTimestamp = 0; in GetSysTime()
[all …]
/ohos5.0/foundation/multimedia/audio_lite/frameworks/binder/
H A Daudio_capturer_client.h29 using OHOS::Audio::Timestamp;
46 bool GetAudioTime(Timestamp &timestamp, Timestamp::Timebase base);
63 Timestamp curTimestamp_;
/ohos5.0/foundation/multimedia/audio_framework/interfaces/inner_api/native/audiocommon/include/
H A Dtimestamp.h29 class Timestamp {
31 Timestamp() : framePosition(0) in Timestamp() function
36 virtual ~Timestamp() = default;

1234567891011