Home
last modified time | relevance | path

Searched refs:retry (Results 1 – 25 of 162) sorted by relevance

1234567

/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/
H A Dsettings.rs480 let retry = Retry::new(1); in ut_retry_new() localVariable
481 assert!(retry.is_ok()); in ut_retry_new()
482 let retry = Retry::new(3); in ut_retry_new() localVariable
483 assert!(retry.is_err()); in ut_retry_new()
484 let retry = Retry::new(10); in ut_retry_new() localVariable
485 assert!(retry.is_err()); in ut_retry_new()
512 assert_eq!(retry.clone(), retry) in ut_retry_clone()
522 let retry = Retry::default(); in ut_retry_default() localVariable
523 assert_eq!(retry, Retry::none()) in ut_retry_default()
533 let retry = Retry::max(); in ut_retry_max() localVariable
[all …]
H A Dclient.rs21 pub(crate) retry: Retry,
31 retry: Retry::none(), in new()
/ohos5.0/foundation/window/window_manager/wmserver/src/
H A Dwindow_common_event.cpp58 int retry = RETRY_MAX_COUNT; in SubscriberEvent() local
59 SubscriberEventInner(retry); in SubscriberEvent()
62 void WindowCommonEvent::SubscriberEventInner(int retry) in SubscriberEventInner() argument
64 if (retry <= 0) { in SubscriberEventInner()
67 retry--; in SubscriberEventInner()
68 WLOGI("called action = %{public}d", retry); in SubscriberEventInner()
72 std::function<void()> func = [this, retry]() { this->SubscriberEventInner(retry); }; in SubscriberEventInner()
/ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/
H A Dnetsys_tcp_client.c60 int64_t Poll(int sock, short event, int *retry) in Poll() argument
73 if (*retry < MAX_POLL_RETRY) { in Poll()
74 ++(*retry); in Poll()
88 int retry = 0; in ProcData() local
90 int32_t resPoll = Poll(sock, event, &retry); in ProcData()
99 if (errno == EAGAIN && retry < MAX_POLL_RETRY) { in ProcData()
100 ++retry; in ProcData()
H A Dnetsys_udp_transfer.cpp35 int retry = 0; in ProcUdpData() local
39 if (errno == EAGAIN && retry < MAX_POLL_RETRY) { in ProcUdpData()
40 ++retry; in ProcUdpData()
/ohos5.0/base/print/print_fwk/services/print_service/src/
H A Dprint_service_helper.cpp60 uint32_t retry = 0; in StartAbility() local
61 while (retry++ < MAX_RETRY_TIMES) { in StartAbility()
68 PRINT_HILOGD("PrintServiceHelper::StartAbility %{public}d", retry); in StartAbility()
70 if (retry > MAX_RETRY_TIMES) { in StartAbility()
83 uint32_t retry = 0; in StartPluginPrintIconExtAbility() local
92 while (retry++ < MAX_RETRY_TIMES) { in StartPluginPrintIconExtAbility()
98 PRINT_HILOGE("PrintServiceHelper::StartPluginPrintIconExtAbility %{public}d", retry); in StartPluginPrintIconExtAbility()
100 if (retry > MAX_RETRY_TIMES) { in StartPluginPrintIconExtAbility()
/ohos5.0/foundation/communication/dsoftbus/adapter/common/bus_center/driver/
H A Dlnn_hdf_driver_monitor.c123 static int32_t retry = 0; in DelayInitFunction() local
126 if (retry >= MAX_BIND_HDF_RETRY_COUNT) { in DelayInitFunction()
131 LNN_LOGE(LNN_INIT, "get hdf dsoftbus service fail=%{public}d", retry); in DelayInitFunction()
133 ++retry; in DelayInitFunction()
137 LNN_LOGI(LNN_INIT, "init hdf driver monitor=%{public}d, result=%{public}d", retry, rc); in DelayInitFunction()
143 ++retry; in DelayInitFunction()
/ohos5.0/base/update/updater/services/updater_binary/
H A Dmain.cpp35 bool retry = false; in main() local
43 retry = true; in main()
50 retry = strcmp(argv[3], "retry=0") == 0 ? false : true; // 3: retry index in main()
55 return ProcessUpdater(retry, pipeFd, packagePath, Utils::GetCertName()); in main()
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/
H A Dsoftbus_adapter.cpp96 …SoftbusAdapter::DealSendSoftbusEvent(std::shared_ptr<DSchedDataBuffer> buffer, const int32_t retry) in DealSendSoftbusEvent() argument
118 return RetrySendSoftbusEvent(buffer, retry); in DealSendSoftbusEvent()
123 …oftbusAdapter::RetrySendSoftbusEvent(std::shared_ptr<DSchedDataBuffer> buffer, const int32_t retry) in RetrySendSoftbusEvent() argument
125 HILOGI("Retry post broadcast, current retry times %{public}d", retry); in RetrySendSoftbusEvent()
126 if (retry == RETRY_SENT_EVENT_MAX_TIME) { in RetrySendSoftbusEvent()
130 auto feedfunc = [this, buffer, retry]() mutable { in RetrySendSoftbusEvent()
131 DealSendSoftbusEvent(buffer, retry + 1); in RetrySendSoftbusEvent()
/ohos5.0/foundation/distributeddatamgr/pasteboard/framework/framework/device/
H A Ddistributed_module_config.cpp58 uint32_t retry = 0; in GetRetryTask() local
60 while (retry < RETRY_TIMES) { in GetRetryTask()
61 ++retry; in GetRetryTask()
65 "newStatus:%{public}d", retry, status_, status); in GetRetryTask()
72 "newStatus:%{public}d", retry, status_, status); in GetRetryTask()
/ohos5.0/base/update/updater/test/unittest/updater_test/
H A Dtest_update_binary.cpp41 bool retry = false; in main() local
44 retry = true; in main()
55 if (retry) { in main()
H A Dtest_update_binary_abnormal.cpp41 bool retry = false; in main() local
44 retry = true; in main()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/
H A Dsync_event.cpp19 SyncEvent::EventInfo::EventInfo(int32_t mode, int32_t wait, bool retry, std::shared_ptr<GenQuery> q… in EventInfo() argument
20 …: retry_(retry), mode_(mode), wait_(wait), query_(std::move(query)), asyncDetail_(std::move(async)) in EventInfo()
24 SyncEvent::EventInfo::EventInfo(const SyncParam &syncParam, bool retry, std::shared_ptr<GenQuery> q… in EventInfo() argument
25 : retry_(retry), mode_(syncParam.mode), wait_(syncParam.wait), query_(std::move(query)), in EventInfo()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/src/
H A Daccount_delegate_normal_impl.cpp139 ExecutorPool::Task AccountDelegateNormalImpl::GetTask(uint32_t retry) in GetTask() argument
141 return [this, retry] { in GetTask()
147 ZLOGD("fail to register subscriber, error:%{public}d, time:%{public}d", result, retry); in GetTask()
149 if (retry + 1 > MAX_RETRY_TIME) { in GetTask()
153 executors_->Schedule(std::chrono::seconds(RETRY_WAIT_TIME_S), GetTask(retry + 1)); in GetTask()
/ohos5.0/foundation/ability/ability_lite/services/abilitymgr_lite/src/client/
H A Dapp_spawn_client.cpp78 int retry = 0; in CallingInnerSpawnProcess() local
79 while (result != EC_SUCCESS && retry < RETRY_TIMES_MAX) { in CallingInnerSpawnProcess()
80 ++retry; in CallingInnerSpawnProcess()
81 PRINTI("AppManager", "invoke fail: %{public}d, retry times: %{public}d", result, retry); in CallingInnerSpawnProcess()
/ohos5.0/base/sensors/miscdevice/services/miscdevice_service/hdi_connection/adapter/src/
H A Dhdi_light_connection.cpp40 int32_t retry = 0; in ConnectHdi() local
41 while (retry < GET_HDI_SERVICE_COUNT) { in ConnectHdi()
47 retry++; in ConnectHdi()
48 MISC_HILOGW("Connect hdi service failed, retry:%{public}d", retry); in ConnectHdi()
/ohos5.0/base/tee/tee_client/services/cadaemon/src/tui_daemon/
H A Dtui_event.cpp361 int32_t retry = 0; in TuiRegisteCallBack() local
364 retry++; in TuiRegisteCallBack()
365 if (retry >= RETRY_TIMES) { in TuiRegisteCallBack()
406 int32_t retry = 0; in TuiRegisteDisplayListener() local
409 retry++; in TuiRegisteDisplayListener()
410 if (retry >= RETRY_TIMES) { in TuiRegisteDisplayListener()
/ohos5.0/foundation/barrierfree/accessibility/services/aams/src/
H A Daccessibility_common_event.cpp81 int32_t retry = RETRY_SUBSCRIBER; in SubscriberEvent() local
88 HILOG_DEBUG("SubscriberEvent failed, retry %{public}d", retry); in SubscriberEvent()
89 retry--; in SubscriberEvent()
92 } while (retry); in SubscriberEvent()
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/
H A Ddms_continue_recv_manager.cpp235 …undleNameId, uint8_t continueTypeId, const int32_t state, const int32_t delay, const int32_t retry) in PostOnBroadcastBusiness() argument
237 auto feedfunc = [this, senderNetworkId, bundleNameId, continueTypeId, state, retry]() mutable { in PostOnBroadcastBusiness()
238 DealOnBroadcastBusiness(senderNetworkId, bundleNameId, continueTypeId, state, retry); in PostOnBroadcastBusiness()
249 uint16_t bundleNameId, uint8_t continueTypeId, const int32_t state, const int32_t retry) in RetryPostBroadcast() argument
251 HILOGI("Retry post broadcast, current retry times %{public}d", retry); in RetryPostBroadcast()
252 if (retry == DBMS_RETRY_MAX_TIME) { in RetryPostBroadcast()
256 …oadcastBusiness(senderNetworkId, bundleNameId, continueTypeId, state, DBMS_RETRY_DELAY, retry + 1); in RetryPostBroadcast()
308 uint16_t bundleNameId, uint8_t continueTypeId, const int32_t state, const int32_t retry) in DealOnBroadcastBusiness() argument
315 HILOGW("get distributedBundleInfo failed, try = %{public}d", retry); in DealOnBroadcastBusiness()
317 return RetryPostBroadcast(senderNetworkId, bundleNameId, continueTypeId, state, retry); in DealOnBroadcastBusiness()
/ohos5.0/base/sensors/medical_sensor/frameworks/native/medical_sensor/src/
H A Dmedical_service_client.cpp59 int32_t retry = 0; in InitServiceClient() local
60 while (retry < GET_SERVICE_MAX_COUNT) { in InitServiceClient()
64 … HiLog::Debug(LABEL, "%{public}s get service success, retry : %{public}d", __func__, retry); in InitServiceClient()
73 HiLog::Warn(LABEL, "%{public}s get service failed, retry : %{public}d", __func__, retry); in InitServiceClient()
75 retry++; in InitServiceClient()
/ohos5.0/base/request/request/services/src/task/
H A Dconfig.rs87 pub(crate) retry: bool,
279 retry: false, in default()
394 pub fn retry(&mut self, retry: bool) -> &mut Self { in retry() method
395 self.inner.common_data.retry = retry; in retry()
411 parcel.write(&(self.common_data.retry))?; in serialize()
/ohos5.0/foundation/communication/dsoftbus/adapter/common/bus_center/common_event/
H A Dlnn_common_event_monitor.cpp129 static int32_t retry = 0; in LnnSubscribeCommonEvent() local
130 if (retry > RETRY_MAX) { in LnnSubscribeCommonEvent()
147 retry++; in LnnSubscribeCommonEvent()
/ohos5.0/base/update/updater/services/include/applypatch/
H A Dupdater_env.h35 …terEnv(Hpackage::PkgManager::PkgManagerPtr pkgManager, PostMessageFunction postMessage, bool retry) in UpdaterEnv() argument
36 : UScriptEnv(pkgManager), postMessage_(postMessage), isRetry_(retry) {} in UpdaterEnv()
/ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr_endpoint/source/
H A Dendpoint.c287 uint8 retry = 0; in SAMGR_ProcPolicy() local
289 while (retry < MAX_REGISTER_RETRY_TIMES) { in SAMGR_ProcPolicy()
290 ++retry; in SAMGR_ProcPolicy()
299 saName->service, saName->feature, saInfo.handle, saInfo.token, retry, ret); in SAMGR_ProcPolicy()
363 uint32 retry = 0; in Receive() local
364 while (retry < MAX_RETRY_TIMES) { in Receive()
372 ++retry; in Receive()
555 uint32 retry = 0; in RegisterRemoteEndpoint() local
556 while (retry < MAX_RETRY_TIMES) { in RegisterRemoteEndpoint()
557 ++retry; in RegisterRemoteEndpoint()
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/include/softbus_adapter/
H A Dsoftbus_adapter.h44 int32_t DealSendSoftbusEvent(std::shared_ptr<DSchedDataBuffer> buffer, const int32_t retry = 0);
45 int32_t RetrySendSoftbusEvent(std::shared_ptr<DSchedDataBuffer> buffer, const int32_t retry);

1234567