Home
last modified time | relevance | path

Searched refs:retry (Results 1 - 25 of 77) sorted by relevance

1234

/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()
/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()
/foundation/communication/dsoftbus/adapter/common/bus_center/driver/
H A Dlnn_hdf_driver_monitor.c125 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 Ddistributed_module_config.cpp59 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 Dsoftbus_adapter.cpp96 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()
/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()
/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> 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/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()
/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()
/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);
/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()
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/
H A Ddms_continue_recv_manager.cpp239 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 Dabilityms_slite_client.cpp35 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 Dabilityms_client.cpp39 int retry = RETRY_TIMES; in Initialize() local
41 while (retry--) { in Initialize()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/
H A Dsync_event.h26 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);
/foundation/ability/dmsfwk/services/dtbschedmgr/include/mission/
H A Ddms_continue_recv_manager.h96 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 Dbus_center_manager.c126 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 Dclient_adaptor.cpp52 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()
/foundation/systemabilitymgr/samgr_lite/samgr_endpoint/source/
H A Dsamgr_small_ipc_adapter.c45 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()
H A Dendpoint.c285 // retry until success or 20 seconds. in SAMGR_ProcPolicy()
287 uint8 retry = 0; in SAMGR_ProcPolicy() local
289 while (retry < MAX_REGISTER_RETRY_TIMES) { in SAMGR_ProcPolicy()
290 ++retry; in SAMGR_ProcPolicy()
298 HILOG_INFO(HILOG_MODULE_SAMGR, "Register server sa<%s, %s> id<%u, %u> retry:%d ret:%d!", 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 in RegisterRemoteEndpoint() local
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dcloud_test.cpp59 const bool retry = true; in HWTEST_F() local
65 SyncEvent::EventInfo eventInfo1(mode, wait, retry, query, async); in HWTEST_F()
72 EXPECT_EQ(evt.AutoRetry(), retry); in HWTEST_F()
/foundation/communication/dsoftbus/adapter/common/bus_center/wlan/
H A Dlnn_wifiservice_monitor.cpp258 static int32_t retry = 0; in LnnSubscribeWifiService() local
259 if (retry > RETRY_MAX) { in LnnSubscribeWifiService()
277 retry++; in LnnSubscribeWifiService()
/foundation/CastEngine/castengine_wifi_display/services/network/server/
H A Dudp_server.cpp135 int32_t retry = 0; in OnServerReadable() local
154 if (firstRead && retry < 5) { // 5: retry 5 times in OnServerReadable()
155 SHARING_LOGE("first read error %{public}d : %{public}s retry: %{public}d", errno, strerror(errno), in OnServerReadable()
156 retry); in OnServerReadable()
158 retry++; in OnServerReadable()
/foundation/communication/netmanager_base/services/netmanagernative/include/netsys/
H A Dnetsys_client.h50 int64_t Poll(int sock, short event, int *retry);

Completed in 11 milliseconds

1234