Home
last modified time | relevance | path

Searched refs:delayMs (Results 1 - 25 of 29) sorted by relevance

12

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvstore_sync_manager.cpp24 Status KvStoreSyncManager::AddSyncOperation(uintptr_t syncId, uint32_t delayMs, const SyncFunc &syncFunc, in AddSyncOperation() argument
33 endFunc = [opSeq, delayMs, syncEnd, this](const std::map<std::string, DistributedDB::DBStatus> &devices) { in AddSyncOperation()
34 RemoveSyncingOp(opSeq, (delayMs == 0) ? realtimeSyncingOps_ : delaySyncingOps_); in AddSyncOperation()
39 auto beginTime = std::chrono::steady_clock::now() + std::chrono::milliseconds(delayMs); in AddSyncOperation()
40 KvSyncOperation syncOp{ syncId, opSeq, delayMs, syncFunc, endFunc, beginTime }; in AddSyncOperation()
41 if (delayMs == 0) { in AddSyncOperation()
55 ZLOGD("add op %u delay %u count %zu.", opSeq, delayMs, scheduleSyncOps_.size()); in AddSyncOperation()
57 (nextScheduleTime_ > beginTime + std::chrono::milliseconds(GetExpireTimeRange(delayMs)))) { in AddSyncOperation()
63 uint32_t KvStoreSyncManager::GetExpireTimeRange(uint32_t delayMs) const in GetExpireTimeRange()
65 uint32_t range = delayMs / DELAY_TIME_RANGE_DIVISO in GetExpireTimeRange()
[all...]
H A Dkvstore_sync_manager.h47 uint32_t delayMs = 0; member
54 Status AddSyncOperation(uintptr_t syncId, uint32_t delayMs, const SyncFunc &syncFunc, const SyncEnd &syncEnd);
61 uint32_t GetExpireTimeRange(uint32_t delayMs) const;
/foundation/distributeddatamgr/pasteboard/test/fuzztest/ffrtutils_fuzzer/
H A Dffrtutils_fuzzer.cpp71 uint32_t delayMs = 5; // delay 5Ms in FuzzFfrtUtilsSubmitDelayTask() local
73 FFRTUtils::SubmitDelayTask(task, delayMs, serQueue); in FuzzFfrtUtilsSubmitDelayTask()
88 uint32_t delayMs = 5; // delay 5Ms in FuzzUtilsSubmitDelayTask() local
92 FFRTUtils::SubmitDelayTask(task, delayMs, queue); in FuzzUtilsSubmitDelayTask()
152 uint32_t delayMs = 5; // delay 5Ms in FuzzFfRTTimerMultiSetAndCancel() local
153 ffrtTimer.SetTimer(timerId1, task, delayMs); in FuzzFfRTTimerMultiSetAndCancel()
154 ffrtTimer.SetTimer(timerId2, task1, delayMs); in FuzzFfRTTimerMultiSetAndCancel()
/foundation/distributeddatamgr/pasteboard/framework/framework/ffrt/
H A Dffrt_utils.cpp36 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask &task, uint32_t delayMs, FFRTQueue &queue) in SubmitDelayTask() argument
39 milliseconds ms(delayMs); in SubmitDelayTask()
44 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask &task, uint32_t delayMs, std::shared_ptr<FFRTQueue> queue) in SubmitDelayTask() argument
47 milliseconds ms(delayMs); in SubmitDelayTask()
113 void FFRTTimer::SetTimer(const std::string &timerId, FFRTTask &task, uint32_t delayMs) in SetTimer() argument
115 if (delayMs == 0) { in SetTimer()
123 timerId.c_str(), taskId_[timerId], delayMs); in SetTimer()
124 handleMap_[timerId] = FFRTUtils::SubmitDelayTask(task, delayMs, queue_); in SetTimer()
/foundation/ability/form_fwk/services/src/
H A Dform_bundle_event_callback.cpp76 uint64_t delayMs = 0; in OnReceiveEvent() local
78 delayMs = CRYPTED_BUNDLE_DELAY_TIME; in OnReceiveEvent()
80 FormTaskMgr::GetInstance().PostTask(taskFunc, delayMs); in OnReceiveEvent()
H A Dform_util.cpp60 const int delayMs = 1; in GenerateFormId() local
79 std::this_thread::sleep_for(std::chrono::milliseconds(delayMs)); in GenerateFormId()
/foundation/distributeddatamgr/pasteboard/framework/framework/include/ffrt/
H A Dffrt_utils.h68 * @param delayMs Delay time, in milliseconds.
73 static FFRTHandle SubmitDelayTask(FFRTTask &task, uint32_t delayMs, FFRTQueue &queue);
81 * @param delayMs Delay time, in milliseconds.
86 static FFRTHandle SubmitDelayTask(FFRTTask &task, uint32_t delayMs, std::shared_ptr<FFRTQueue> queue);
129 void SetTimer(const std::string &timerId, FFRTTask &task, uint32_t delayMs);
/foundation/resourceschedule/ffrt/src/queue/
H A Dconcurrent_queue.cpp135 uint64_t delayMs = (task->GetDelay() - 1) / 1000 + 1; in PushDelayTaskToTimer() local
136 int timeout = delayMs > INT_MAX ? INT_MAX : delayMs; in PushDelayTaskToTimer()
/foundation/arkui/napi/native_engine/impl/ark/
H A Dark_idle_monitor.cpp112 void ArkIdleMonitor::PostMonitorTask(uint64_t delayMs) in PostMonitorTask() argument
129 currentTimerHandler_ = ffrt_timer_start(ffrt_qos_user_initiated, delayMs, this, task, false); in PostMonitorTask()
H A Dark_idle_monitor.h156 void PostMonitorTask(uint64_t delayMs = IDLE_MONITORING_INTERVAL);
/foundation/distributeddatamgr/pasteboard/framework/test/src/
H A Dffrt_utils_test.cpp110 uint32_t delayMs = 20; in HWTEST_F() local
115 FFRTHandle handle = FFRTUtils::SubmitDelayTask(task0, delayMs, queu); in HWTEST_F()
/foundation/CastEngine/castengine_wifi_display/services/protocol/rtcp/src/
H A Drtcp_context.cpp71 auto delayMs = (uint64_t)item->delaySinceLastSr_ * 1000 / 65536; // 1000:unit, 65536:max seq in OnRtcp() local
73 auto rtt = (int32_t)(msInc - delayMs); in OnRtcp()
/foundation/multimodalinput/input/service/key_command/test/
H A Dtwo_finger_long_touch_test.cpp114 void Delay(std::chrono::milliseconds delayMs);
197 void TwoFingerLongTouchTest::Delay(std::chrono::milliseconds delayMs) in Delay() argument
199 std::this_thread::sleep_for(delayMs); in Delay()
/foundation/communication/dsoftbus/core/authentication/src/
H A Dauth_common.c105 int32_t PostAuthEvent(EventType event, EventHandler handler, const void *obj, uint32_t size, uint64_t delayMs) in PostAuthEvent() argument
117 if (delayMs == 0) { in PostAuthEvent()
120 g_authHandler.looper->PostMessageDelay(g_authHandler.looper, msg, delayMs); in PostAuthEvent()
H A Dauth_session_key.c586 void ScheduleUpdateSessionKey(AuthHandle authHandle, uint64_t delayMs) in ScheduleUpdateSessionKey() argument
593 PostAuthEvent(EVENT_UPDATE_SESSION_KEY, HandleUpdateSessionKeyEvent, &authHandle, sizeof(AuthHandle), delayMs); in ScheduleUpdateSessionKey()
/foundation/communication/dsoftbus/core/authentication/include/
H A Dauth_common.h131 const void *obj, uint32_t size, uint64_t delayMs);
/foundation/distributeddatamgr/kv_store/frameworks/cj/include/
H A Ddistributed_kv_store_ffi.h100 uint32_t delayMs);
103 int64_t queryId, uint8_t mode, uint32_t delayMs);
H A Ddistributed_kv_store_impl.h315 int32_t Sync(const CArrStr deviceIds, uint8_t mode, uint32_t delayMs);
316 int32_t SyncByQuery(const CArrStr deviceIds, OHOS::sptr<CQuery> query, uint8_t mode, uint32_t delayMs);
/foundation/distributeddatamgr/kv_store/frameworks/cj/src/
H A Ddistributed_kv_store_ffi.cpp305 int32_t FfiOHOSDistributedKVStoreSingleKVStoreSync(int64_t id, const CArrStr deviceIds, uint8_t mode, uint32_t delayMs) in FfiOHOSDistributedKVStoreSingleKVStoreSync() argument
311 return instance->Sync(deviceIds, mode, delayMs); in FfiOHOSDistributedKVStoreSingleKVStoreSync()
315 uint8_t mode, uint32_t delayMs) in FfiOHOSDistributedKVStoreSingleKVStoreSyncByQuery()
322 return instance->SyncByQuery(deviceIds, query, mode, delayMs); in FfiOHOSDistributedKVStoreSingleKVStoreSyncByQuery()
314 FfiOHOSDistributedKVStoreSingleKVStoreSyncByQuery(int64_t id, const CArrStr deviceIds, int64_t queryId, uint8_t mode, uint32_t delayMs) FfiOHOSDistributedKVStoreSingleKVStoreSyncByQuery() argument
H A Ddistributed_kv_store_impl.cpp611 int32_t CJSingleKVStore::Sync(const CArrStr deviceIds, uint8_t mode, uint32_t delayMs) in Sync() argument
613 Status status = kvStore_->Sync(CArrStrToVectorString(deviceIds), static_cast<SyncMode>(mode), delayMs); in Sync()
617 int32_t CJSingleKVStore::SyncByQuery(const CArrStr deviceIds, OHOS::sptr<CQuery> query, uint8_t mode, uint32_t delayMs) in SyncByQuery() argument
621 static_cast<SyncMode>(mode), dataQuery, nullptr, delayMs); in SyncByQuery()
/foundation/arkui/ace_engine/interfaces/napi/kits/component_test/
H A Djs_component_test_component.cpp169 uint32_t delayMs = 0; in JSPress() local
174 NAPI_CALL(env, napi_get_value_uint32(env, argv, &delayMs)); in JSPress()
178 asyncContext->delayMs = delayMs; in JSPress()
190 asyncContext->componentImpl->PressImpl(asyncContext->ret, asyncContext->delayMs); in JSPress()
H A Djs_component_test_utils.h64 uint32_t delayMs = 0; member
H A Djs_component_test.cpp177 ErrCode::RET_ERROR_PARAM_INVALID, "Parameter delayMs is not of type number", NapiGetUndefined(env)); in JSDefineTest()
178 NAPI_CALL(env, napi_get_value_uint32(env, argv[ARG_COUNT_THREE], &asyncContext->delayMs)); in JSDefineTest()
196 (void*)asyncContext, asyncContext->delayMs); in JSDefineTest()
H A Djs_component_test_tester.cpp151 uint32_t delayMs = 0; in JSPump() local
154 COMPONENT_TEST_NAPI_ASSERT_CUSTOM(env, CheckAndParseUInt32(env, argv, delayMs, errMsg), in JSPump()
173 TaskExecutor::TaskType::JS, delayMs, {}); in JSPump()
/foundation/ability/form_fwk/services/include/
H A Dform_task_mgr.h293 * @param delayMs Task excute delay time(ms).
295 void PostTask(const std::function<void()> &func, uint64_t delayMs = FORM_TASK_DELAY_TIME);

Completed in 19 milliseconds

12