Home
last modified time | relevance | path

Searched refs:timeOffset (Results 1 - 20 of 20) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_time_sync_test.cpp170 * @tc.steps: step4. Fetch timeOffset value in HWTEST_F()
171 * @tc.expected: step4. (offsetB - offsetA ) - timeOffset < 100ms. in HWTEST_F()
173 TimeOffset timeOffset = 0; in HWTEST_F() local
174 g_timeSyncA->GetTimeOffset(timeOffset, TIME_SYNC_WAIT_TIME); in HWTEST_F()
177 EXPECT_TRUE(abs(offsetB - offsetA - timeOffset) < NETWORK_DELAY); in HWTEST_F()
209 * @tc.steps: step3. Fetch timeOffset value
210 * @tc.expected: step3. (offsetB - offsetA ) - timeOffset < 100ms.
212 TimeOffset timeOffset; local
213 g_timeSyncA->GetTimeOffset(timeOffset, TIME_SYNC_WAIT_TIME);
216 EXPECT_TRUE(abs(offsetB - offsetA - timeOffset) < NETWORK_DELA
262 TimeOffset timeOffset = 0; global() local
[all...]
H A Dvirtual_time_sync_communicator.cpp140 void VirtualTimeSyncCommunicator::GetTimeOffset(TimeOffset &timeOffset) const in GetTimeOffset()
142 timeOffset = timeOffset_; in GetTimeOffset()
H A Dvirtual_time_sync_communicator.h69 void GetTimeOffset(TimeOffset &timeOffset) const;
/foundation/distributedhardware/distributed_audio/common/test/unittest/src/
H A Ddaudio_utils_test.cpp195 int64_t timeOffset = UpdateTimeOffset(frameIndex, framePeriodNs, startTime); in HWTEST_F() local
197 EXPECT_EQ(0, timeOffset); in HWTEST_F()
200 timeOffset = UpdateTimeOffset(frameIndex, framePeriodNs, startTime); in HWTEST_F()
201 EXPECT_EQ(0, timeOffset); in HWTEST_F()
204 timeOffset = UpdateTimeOffset(frameIndex, framePeriodNs, startTime); in HWTEST_F()
205 EXPECT_NE(0, timeOffset); in HWTEST_F()
/foundation/multimedia/camera_framework/services/camera_service/src/avcodec/
H A Daudio_capturer_session.cpp135 int64_t timeOffset = 20; in ProcessAudioBuffer() local
136 sptr<AudioRecord> audioRecord = new AudioRecord(GetTickCount() - timeOffset); in ProcessAudioBuffer()
/foundation/arkui/ace_engine/frameworks/core/components/refresh/
H A Drefresh_component.h119 void SetTimeOffset(const Dimension& timeOffset) in SetTimeOffset() argument
121 timeOffset_ = timeOffset; in SetTimeOffset()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dmeta_data.cpp54 std::vector<uint8_t> timeOffset; in Initialize() local
57 int errCode = GetMetadataFromDb(key, timeOffset); in Initialize()
65 localTimeOffset_ = StringToLong(timeOffset); in Initialize()
83 metadata.timeOffset = inValue; in SaveTimeOffset()
94 outValue = metadata.timeOffset; in GetTimeOffset()
133 int Metadata::SaveLocalTimeOffset(TimeOffset timeOffset) in SaveLocalTimeOffset() argument
135 std::string timeOffsetString = std::to_string(timeOffset); in SaveLocalTimeOffset()
141 localTimeOffset_ = timeOffset; in SaveLocalTimeOffset()
142 LOGD("Metadata::SaveLocalTimeOffset offset = %" PRId64, timeOffset); in SaveLocalTimeOffset()
H A Dtime_sync.cpp234 TimeOffset timeOffset = metadata_->GetLocalTimeOffset(); in SyncStart() local
235 packet.SetRequestLocalOffset(timeOffset); in SyncStart()
237 LOGD("[TimeSync] startTime = %" PRIu64 ", offset = % " PRId64 " , dev = %s{private}", startTime, timeOffset, in SyncStart()
449 int TimeSync::SaveTimeOffset(const DeviceID &deviceID, TimeOffset timeOffset) in SaveTimeOffset() argument
451 return metadata_->SaveTimeOffset(deviceID, timeOffset); in SaveTimeOffset()
H A Dmeta_data.h31 TimeOffset timeOffset = 0; member
81 int SaveLocalTimeOffset(TimeOffset timeOffset);
H A Dtime_sync.h124 int SaveTimeOffset(const DeviceID &deviceID, TimeOffset timeOffset);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_store_sqlite_ext.cpp184 Timestamp GetTime(TimeOffset timeOffset, const std::function<Timestamp()> &getDbMaxTimestamp, in GetTime() argument
204 Timestamp currentLocalTime = currentSysTime + timeOffset + localTimeOffset_; in GetTime()
220 bool TimeSkew(const std::function<Timestamp()> &getLocalTimeOffsetFromDB, Timestamp timeOffset) in TimeSkew() argument
233 Timestamp currentLocalTime = currentSysTime + timeOffset + localTimeOffset; in TimeSkew()
346 Timestamp timeOffset) in TimeSkew()
353 return it->second.TimeSkew(getLocalTimeOffsetFromDB, timeOffset); in TimeSkew()
356 Timestamp GetTime(const std::string &storeId, TimeOffset timeOffset, in GetTime() argument
364 return it->second.GetTime(timeOffset, getDbMaxTimestamp, getDbLocalTimeOffset); in GetTime()
570 auto timeOffset = static_cast<TimeOffset>(sqlite3_value_int64(argv[0])); in GetSysTime() local
571 (void)TimeHelperManager::GetInstance()->TimeSkew(identity, getDbLocalTimeOffset, timeOffset); in GetSysTime()
345 TimeSkew(const std::string &storeId, const std::function<Timestamp()> &getLocalTimeOffsetFromDB, Timestamp timeOffset) TimeSkew() argument
[all...]
/foundation/distributedhardware/distributed_audio/services/audiomanager/managersource/src/
H A Ddspeaker_dev.cpp376 int64_t timeOffset = UpdateTimeOffset(frameIndex_, timeIntervalns, startTime_); in EnqueueThread() local
377 DHLOGD("Read frameIndex: %{public}" PRId64", timeOffset: %{public}" PRId64, frameIndex_, timeOffset); in EnqueueThread()
401 AbsoluteSleep(startTime_ + frameIndex_ * timeIntervalns - timeOffset); in EnqueueThread()
H A Ddmic_dev.cpp442 int64_t timeOffset = UpdateTimeOffset(frameIndex_, timeIntervalns, startTime_); in EnqueueThread() local
443 DHLOGD("Write frameIndex: %{public}" PRId64", timeOffset: %{public}" PRId64, frameIndex_, timeOffset); in EnqueueThread()
474 AbsoluteSleep(startTime_ + frameIndex_ * timeIntervalns - timeOffset); in EnqueueThread()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dicloud_sync_storage_interface.h53 TimeOffset timeOffset = 0; member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_cloud_kv_store.cpp259 downloadData.timeOffset = storageHandle_->GetLocalTimeOffsetForCloud(); in PutCloudSyncData()
456 TimeOffset timeOffset = storageHandle_->GetLocalTimeOffsetForCloud(); in GetLocalCloudVersion() local
457 Timestamp rawSysTime = static_cast<Timestamp>(static_cast<TimeOffset>(currentTime) - timeOffset); in GetLocalCloudVersion()
H A Dsqlite_single_ver_natural_store.cpp1373 std::vector<uint8_t> timeOffset; in GetTimestampFromDB() local
1376 int errCode = GetMetaData(key, timeOffset); in GetTimestampFromDB()
1378 std::string timeOffsetString(timeOffset.begin(), timeOffset.end()); in GetTimestampFromDB()
H A Dsqlite_cloud_kv_executor_utils.cpp1013 dataItem.timestamp = static_cast<Timestamp>(static_cast<int64_t>(dataItem.modifyTime) + downloadData.timeOffset); in GetDataItem()
/foundation/distributedhardware/distributed_audio/common/src/
H A Ddaudio_util.cpp399 int64_t timeOffset = 0; in UpdateTimeOffset() local
403 timeOffset = CalculateOffset(frameIndex, framePeriodNs, startTime); in UpdateTimeOffset()
405 return timeOffset; in UpdateTimeOffset()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor.cpp145 int GetExistedDataTimeOffset(sqlite3 *db, const std::string &tableName, bool isMem, int64_t &timeOffset) in GetExistedDataTimeOffset() argument
156 timeOffset = static_cast<int64_t>(sqlite3_column_int64(stmt, 0)); in GetExistedDataTimeOffset()
167 int64_t timeOffset = 0; in GeneLogInfoForExistedData() local
168 int errCode = GetExistedDataTimeOffset(db, tableName, isMemDb_, timeOffset); in GeneLogInfoForExistedData()
176 std::string timeOffsetStr = std::to_string(timeOffset); in GeneLogInfoForExistedData()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_cloud_syncable_storage_test.cpp665 int timeOffset = 30; in HWTEST_F() local
667 EXPECT_EQ(g_storageProxy->GetUploadCount(g_tableName, g_startTime + timeOffset, false, resCount), E_OK); in HWTEST_F()
677 EXPECT_EQ(g_storageProxy->GetUploadCount(g_tableName, g_startTime + timeOffset, false, resCount), E_OK); in HWTEST_F()

Completed in 24 milliseconds