Home
last modified time | relevance | path

Searched refs:Timestamp (Results 1 - 25 of 183) sorted by relevance

12345678

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
H A Dtime_helper.cpp24 Timestamp TimeHelper::lastSystemTimeUs_ = 0;
25 Timestamp TimeHelper::currentIncCount_ = 0;
26 std::atomic<Timestamp> TimeHelper::lastMonotonicTime_ = 0;
28 Timestamp TimeHelper::GetSysCurrentTime() in GetSysCurrentTime()
47 return (curTime * TO_100_NS) + currentIncCount_; // Currently Timestamp is uint64_t in GetSysCurrentTime()
83 Timestamp currentSysTime = GetSysCurrentTime(); in Initialize()
85 Timestamp maxItemTime = GetMaxDataItemTime(); in Initialize()
89 Timestamp virtualSysTime = static_cast<Timestamp>(currentSysTime + localTimeOffset); in Initialize()
99 metadata_->SetLastLocalTime(currentSysTime + static_cast<Timestamp>(localTimeOffse in Initialize()
[all...]
H A Dtime_helper.h38 static const Timestamp INVALID_TIMESTAMP = 0;
41 static Timestamp GetSysCurrentTime();
50 // Get Timestamp when write data into db, export interface;
51 Timestamp GetTime();
54 Timestamp GetMaxDataItemTime();
64 static Timestamp GetMonotonicTime();
68 static Timestamp lastSystemTimeUs_;
69 static Timestamp currentIncCount_;
71 static std::atomic<Timestamp> lastMonotonicTime_;
/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, MulDevTimeRanges &timeRanges);
72 Timestamp GetBeginTimestam
[all...]
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 nextBeginTime) in SetNextBeginTime()
74 void SQLiteSingleVerContinueToken::SetDeletedNextBeginTime(const DeviceID &deviceID, Timestamp nextBeginTime) in SetDeletedNextBeginTime()
117 void SQLiteSingleVerContinueToken::RemovePrevDevAndSetBeginTime(const DeviceID &deviceID, Timestamp nextBeginTime, in RemovePrevDevAndSetBeginTime()
128 Timestamp SQLiteSingleVerContinueToke
[all...]
H A Dsqlite_single_ver_storage_executor.h38 virtual int GetKvData(SingleVerDataType type, const Key &key, Value &value, Timestamp &timestamp) const;
45 Timestamp timestamp, SingleVerNaturalStoreCommitNotifyData *committedData);
60 Timestamp &maxStamp, SingleVerNaturalStoreCommitNotifyData *committedData, bool isPermitForceWrite = true);
63 Timestamp &timestamp);
76 void InitCurrentMaxStamp(Timestamp &maxStamp);
80 int GetSyncDataByTimestamp(std::vector<DataItem> &dataItems, size_t appendLength, Timestamp begin,
81 Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const;
82 int GetDeletedSyncDataByTimestamp(std::vector<DataItem> &dataItems, size_t appendLength, Timestamp begin,
83 Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const;
85 int GetUnSyncTotalByTimestamp(Timestamp begi
[all...]
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 &beginTime,
100 void ReleaseUploadRecord(const std::string &tableName, const CloudWaterType &type, Timestamp localMark) override;
112 static void FillTimestamp(Timestamp rawSystemTime, Timestamp virtualTime, CloudSyncBatch &syncBatch);
/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;
60 Timestamp sourceTimeBegin_; // start point time on peer
61 Timestamp sourceTimeEnd
[all...]
H A Dtime_sync.cpp52 void TimeSyncPacket::SetSourceTimeBegin(Timestamp sourceTimeBegin) in SetSourceTimeBegin()
57 Timestamp TimeSyncPacket::GetSourceTimeBegin() const in GetSourceTimeBegin()
62 void TimeSyncPacket::SetSourceTimeEnd(Timestamp sourceTimeEnd) in SetSourceTimeEnd()
67 Timestamp TimeSyncPacket::GetSourceTimeEnd() const in GetSourceTimeEnd()
72 void TimeSyncPacket::SetTargetTimeBegin(Timestamp targetTimeBegin) in SetTargetTimeBegin()
77 Timestamp TimeSyncPacket::GetTargetTimeBegin() const in GetTargetTimeBegin()
82 void TimeSyncPacket::SetTargetTimeEnd(Timestamp targetTimeEnd) in SetTargetTimeEnd()
87 Timestamp TimeSyncPacket::GetTargetTimeEnd() const in GetTargetTimeEnd()
232 Timestamp startTime = timeHelper_->GetTime(); in SyncStart()
286 Timestamp srcBegi in Serialization()
[all...]
/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);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Ddb_types.h31 using Timestamp = uint64_t;
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 deleteEndTim
[all...]
H A Dperformance_analysis.h57 Timestamp startTime = 0;
58 Timestamp endTime = 0;
62 Timestamp max = 0;
63 Timestamp min = 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 en
[all...]
/foundation/multimedia/audio_lite/interfaces/kits/
H A Daudio_capturer.h80 class Timestamp { class
82 Timestamp() : framePosition(0) in Timestamp() function in OHOS::Audio::Timestamp
87 ~Timestamp() = default;
92 * @brief Enumerates the time base of this <b>Timestamp</b>. Different timing methods are supported.
222 * @param timestamp Indicates a {@link Timestamp} instance reference provided by the caller.
223 * @param base Indicates the time base, which can be {@link Timestamp.Timebase#BOOTTIME Timestamp.Timebase.BOOTTIME}
224 * or {@link Timestamp.Timebase#MONOTONIC Timestamp.Timebase.MONOTONIC}.
229 bool GetAudioTime(Timestamp
[all...]
/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 &localMark);
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 isCloudForcePush,
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,
154 void ReleaseUploadRecord(const std::string &table, const CloudWaterType &type, Timestamp localWaterMark);
163 static Timestamp EraseNanoTim
[all...]
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()
67 virtual int GetUnSyncTotal(Timestamp begin, Timestamp end, uint32_t &total) const in GetUnSyncTotal()
107 virtual int GetDatabaseCreateTimestamp(Timestamp &outTime) const in GetDatabaseCreateTimestamp()
H A Dsingle_ver_kvdb_sync_interface.h26 using MulDevTimeRanges = std::map<DeviceID, std::pair<Timestamp, Timestamp>>;
/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;
/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;
100 int GetDeletedSyncDataByTimestamp(std::vector<DataItem> &dataItems, size_t appendLength, Timestamp begin,
101 Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const;
127 bool CheckIfKeyExisted(const Key &key, bool isLocal, Value &value, Timestamp &timestamp) const;
131 int UpdateLocalDataTimestamp(Timestamp timestam
[all...]
/foundation/multimedia/audio_framework/interfaces/inner_api/native/audiocommon/include/
H A Dtimestamp.h27 * @brief Represents Timestamp information, including the frame position information and high-resolution time source.
29 class Timestamp { class
31 Timestamp() : framePosition(0) in Timestamp() function in OHOS::AudioStandard::Timestamp
36 virtual ~Timestamp() = default;
41 * @brief Enumerates the time base of this <b>Timestamp</b>. Different timing methods are supported.
/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_;
/foundation/systemabilitymgr/safwk/interfaces/innerkits/safwk/
H A Dexpire_lru_cache.h67 class Timestamp { class in OHOS::ExpireLruCache
69 Timestamp() in Timestamp() function in OHOS::ExpireLruCache::Timestamp
73 ~Timestamp() {} in ~Timestamp()
75 int64_t operator-(const Timestamp& ts) in operator -()
82 Timestamp now; in IsExpired()
99 std::map<TKey, Timestamp> timestamp_;
104 Timestamp now; in DoAdd()
/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;
142 void SetSessionEndTimestamp(Timestamp end);
144 Timestamp GetSessionEndTimestam
[all...]
/foundation/multimedia/audio_lite/services/impl/
H A Daudio_capturer_impl.h48 bool GetTimestamp(Timestamp &timestamp, Timestamp::Timebase base);
57 Timestamp timestamp_;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/
H A Dmulti_ver_commit.h46 Timestamp GetTimestamp() const override;
47 void SetTimestamp(Timestamp timestamp) override;
65 Timestamp timestamp_;

Completed in 9 milliseconds

12345678