| /foundation/window/window_manager/wmserver/src/ |
| H A D | window_common_event.cpp | 58 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()
|
| /foundation/communication/netmanager_base/services/netmanagernative/src/netsys/ |
| H A D | netsys_tcp_client.c | 60 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 D | netsys_udp_transfer.cpp | 35 int retry = 0; in ProcUdpData() local
39 if (errno == EAGAIN && retry < MAX_POLL_RETRY) { in ProcUdpData()
40 ++retry; in ProcUdpData()
|
| /foundation/communication/dsoftbus/adapter/common/bus_center/driver/ |
| H A D | lnn_hdf_driver_monitor.c | 125 static int32_t retry = 0; in DelayInitFunction() local
128 if (retry >= MAX_BIND_HDF_RETRY_COUNT) { in DelayInitFunction()
133 LNN_LOGE(LNN_INIT, "get hdf dsoftbus service fail=%{public}d", retry); in DelayInitFunction()
135 ++retry; in DelayInitFunction()
139 LNN_LOGI(LNN_INIT, "init hdf driver monitor=%{public}d, result=%{public}d", retry, rc); in DelayInitFunction()
145 ++retry; in DelayInitFunction()
|
| /foundation/distributeddatamgr/pasteboard/framework/framework/device/ |
| H A D | distributed_module_config.cpp | 59 uint32_t retry = 0; in GetRetryTask()
61 while (retry < RETRY_TIMES) { in GetRetryTask()
62 ++retry; in GetRetryTask()
66 "dp load err, retry:%{public}d, status_:%{public}d" in GetRetryTask()
68 retry, status_, status); in GetRetryTask()
77 retry, status_, status); in GetRetryTask()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/ |
| H A D | softbus_adapter.cpp | 96 int32_t SoftbusAdapter::DealSendSoftbusEvent(std::shared_ptr<DSchedDataBuffer> buffer, const int32_t retry) in DealSendSoftbusEvent() argument
118 return RetrySendSoftbusEvent(buffer, retry); in DealSendSoftbusEvent()
123 int32_t SoftbusAdapter::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()
127 HILOGE("meet max retry time!"); in RetrySendSoftbusEvent()
130 auto feedfunc = [this, buffer, retry]() mutable { in RetrySendSoftbusEvent()
131 DealSendSoftbusEvent(buffer, retry + 1); in RetrySendSoftbusEvent()
|
| /device/soc/hisilicon/hi3516dv300/sdk_linux/drv/mpp/component/hdmi/src/mkp/hal/ctrl/hisiv100/ |
| H A D | hdmi_hal_ddc.c | 210 hi_u32 i, retry, data_size;
in ddc_read() local
216 retry = cfg->issue_timeout < DDC_DEFAULT_TIMEOUT_ISSUE ? DDC_DEFAULT_TIMEOUT_ISSUE : cfg->sda_timeout;
in ddc_read()
224 ((i < retry) && (hdmi_reg_pwd_fifo_empty_get() || (hdmi_reg_pwd_fifo_data_out_get() == 0))) &&
in ddc_read()
236 if ((i >= retry) || ((time_curr - time_start) > DDC_DEFAULT_RETRY_TIMEOUT_ISSUE)) {
in ddc_read()
238 hdmi_warn("read fifo retry=%u ms, size=%u, timeout:%u!\n",
in ddc_read()
239 retry, len, (time_curr - time_start));
in ddc_read()
241 hdmi_info("read fifo retry=%u ms, size=%u, timeout:%u!\n",
in ddc_read()
242 retry, len, (time_curr - time_start));
in ddc_read()
268 hi_u32 i, retry, data_size;
in ddc_write() local
274 retry in ddc_write()
[all...] |
| /foundation/ability/ability_lite/services/abilitymgr_lite/src/client/ |
| H A D | app_spawn_client.cpp | 78 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()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/ |
| H A D | sync_event.cpp | 19 SyncEvent::EventInfo::EventInfo(int32_t mode, int32_t wait, bool retry, std::shared_ptr<GenQuery> query, GenAsync async) 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> query, GenAsync async) in EventInfo() argument
25 : retry_(retry), mode_(syncParam.mode), wait_(syncParam.wait), query_(std::move(query)), in EventInfo()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/src/ |
| H A D | account_delegate_normal_impl.cpp | 139 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()
|
| /foundation/barrierfree/accessibility/services/aams/src/ |
| H A D | accessibility_common_event.cpp | 81 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()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/include/softbus_adapter/ |
| H A D | softbus_adapter.h | 44 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);
|
| /foundation/communication/dsoftbus/adapter/common/bus_center/common_event/ |
| H A D | lnn_common_event_monitor.cpp | 129 static int32_t retry = 0; in LnnSubscribeCommonEvent() local
130 if (retry > RETRY_MAX) { in LnnSubscribeCommonEvent()
147 retry++; in LnnSubscribeCommonEvent()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
| H A D | dms_continue_recv_manager.cpp | 239 uint16_t bundleNameId, uint8_t continueTypeId, const int32_t state, const int32_t delay, const int32_t retry) in PostOnBroadcastBusiness()
241 auto feedfunc = [this, senderNetworkId, bundleNameId, continueTypeId, state, retry]() mutable { in PostOnBroadcastBusiness()
242 DealOnBroadcastBusiness(senderNetworkId, bundleNameId, continueTypeId, state, retry); in PostOnBroadcastBusiness()
253 uint16_t bundleNameId, uint8_t continueTypeId, const int32_t state, const int32_t retry) in RetryPostBroadcast()
255 HILOGI("Retry post broadcast, current retry times %{public}d", retry); in RetryPostBroadcast()
256 if (retry == DBMS_RETRY_MAX_TIME) { in RetryPostBroadcast()
257 HILOGE("meet max retry time!"); in RetryPostBroadcast()
260 PostOnBroadcastBusiness(senderNetworkId, bundleNameId, continueTypeId, state, DBMS_RETRY_DELAY, retry + 1); in RetryPostBroadcast()
312 uint16_t bundleNameId, uint8_t continueTypeId, const int32_t state, const int32_t retry) in DealOnBroadcastBusiness()
238 PostOnBroadcastBusiness(const std::string& senderNetworkId, uint16_t bundleNameId, uint8_t continueTypeId, const int32_t state, const int32_t delay, const int32_t retry) PostOnBroadcastBusiness() argument
252 RetryPostBroadcast(const std::string& senderNetworkId, uint16_t bundleNameId, uint8_t continueTypeId, const int32_t state, const int32_t retry) RetryPostBroadcast() argument
311 DealOnBroadcastBusiness(const std::string& senderNetworkId, uint16_t bundleNameId, uint8_t continueTypeId, const int32_t state, const int32_t retry) DealOnBroadcastBusiness() argument
[all...] |
| /foundation/ability/ability_lite/frameworks/abilitymgr_lite/src/slite/ |
| H A D | abilityms_slite_client.cpp | 35 int retry = RETRY_TIMES;
in Initialize() local
36 while (retry--) {
in Initialize()
57 int32_t retry = RETRY_TIMES;
in SendRequestToAms() local
58 while (retry--) {
in SendRequestToAms()
|
| /foundation/ability/ability_lite/frameworks/abilitymgr_lite/src/ |
| H A D | abilityms_client.cpp | 39 int retry = RETRY_TIMES; in Initialize() local
41 while (retry--) { in Initialize()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | sync_event.h | 26 API_EXPORT EventInfo(int32_t mode, int32_t wait, bool retry, std::shared_ptr<GenQuery> query, GenAsync async);
27 API_EXPORT EventInfo(const SyncParam &syncParam, bool retry, std::shared_ptr<GenQuery> query, GenAsync async);
|
| /device/soc/rockchip/common/sdk_linux/drivers/staging/blackbox/ |
| H A D | blackbox_storage.c | 131 static int retry; in get_log_by_pstore() local
137 retry++; in get_log_by_pstore()
138 if (retry >= RETRY_MAX_COUNT) { in get_log_by_pstore()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/include/mission/ |
| H A D | dms_continue_recv_manager.h | 96 const int32_t state, const int32_t retry);
102 const int32_t state, const int32_t delay = 0, const int32_t retry = 0);
106 const int32_t state, const int32_t retry = 0);
|
| /foundation/communication/dsoftbus/core/bus_center/service/src/ |
| H A D | bus_center_manager.c | 126 static int32_t retry = 0; in BusCenterServerDelayInit() local
127 if (retry > RETRY_MAX) { in BusCenterServerDelayInit()
152 retry++; in BusCenterServerDelayInit()
|
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/ |
| H A D | client_adaptor.cpp | 52 int retry = 0;
in GetDistributedDataManager() local
53 while (++retry <= GET_SA_RETRY_TIMES) {
in GetDistributedDataManager()
59 LOG_INFO("get distributed data manager %{public}d", retry);
in GetDistributedDataManager()
|
| /device/soc/rockchip/rk2206/sdk_liteos/platform/network/ |
| H A D | config_network.c | 243 unsigned int retry = 15; in SetWifiScan() local
255 while (retry) { in SetWifiScan()
259 retry--; in SetWifiScan()
267 if (retry == 0) { in SetWifiScan()
396 unsigned int retry = 15; in SetWifiModeOn() local
400 while (retry) { in SetWifiModeOn()
428 retry--; in SetWifiModeOn()
|
| /device/soc/rockchip/common/kernel/drivers/net/wireless/rockchip_wlan/rkwifi/bcmdhd_wifi6/ |
| H A D | dhd_linux_platdev.c | 727 int retry = POWERUP_MAX_RETRY; in dhd_wifi_platform_load_pcie() local
742 " %d retry left\n", in dhd_wifi_platform_load_pcie()
743 adapter->name, retry)); in dhd_wifi_platform_load_pcie()
752 "%d retry left\n", in dhd_wifi_platform_load_pcie()
753 adapter->name, retry)); in dhd_wifi_platform_load_pcie()
760 } while (retry--); in dhd_wifi_platform_load_pcie()
762 if (retry < 0) { in dhd_wifi_platform_load_pcie()
763 DHD_ERROR(("failed to power up %s, max retry reached**\n", in dhd_wifi_platform_load_pcie()
846 int retry = POWERUP_MAX_RETRY; in dhd_wifi_platform_load_sdio() local
882 DHD_ERROR(("failed to power up %s, %d retry lef in dhd_wifi_platform_load_sdio()
[all...] |
| /device/soc/hisilicon/hi3861v100/sdk_liteos/boot/loaderboot/common/ |
| H A D | transfer.c | 241 if (ctx->retry > 0) { in upload_send_file_info()
308 if (ctx->retry > 0) { in upload_send_data()
433 ctx->retry = 0; in upload_serial_ymodem()
441 ctx->retry = 0; in upload_serial_ymodem()
454 if (++ctx->retry == RETRY_COUNT) { in upload_serial_ymodem()
463 ctx->retry = 0; in upload_serial_ymodem()
|
| /foundation/systemabilitymgr/samgr_lite/samgr_endpoint/source/ |
| H A D | samgr_small_ipc_adapter.c | 45 uint32 retry = 0;
in ClientRegisterRemoteEndpoint() local
46 while (retry < MAX_RETRY_TIMES) {
in ClientRegisterRemoteEndpoint()
47 ++retry;
in ClientRegisterRemoteEndpoint()
109 uint32 retry = 0;
in Receive() local
110 while (retry < MAX_RETRY_TIMES) {
in Receive()
120 ++retry;
in Receive()
|