Home
last modified time | relevance | path

Searched refs:retryTimes (Results 1 - 25 of 46) sorted by relevance

12

/foundation/filemanagement/dfs_service/utils/system/include/
H A Ddfsu_thread.h52 bool RunLoop(std::function<bool()> task, uint64_t interval, uint32_t retryTimes = UINT32_MAX) in RunLoop()
59 thread_ = std::make_unique<std::thread>([this, task, interval, retryTimes] { in RunLoop()
60 uint32_t times = retryTimes; in RunLoop()
76 bool RunLoopFlexible(std::function<bool(uint64_t &)> task, uint64_t interval, uint32_t retryTimes = UINT32_MAX) in RunLoopFlexible()
83 thread_ = std::make_unique<std::thread>([this, task, interval, retryTimes] { in RunLoopFlexible()
84 uint32_t times = retryTimes; in RunLoopFlexible()
/foundation/distributeddatamgr/preferences/frameworks/native/platform/src/
H A Dpreferences_db_adapter.cpp230 int retryTimes = DB_REPAIR_RETRY_TIMES; in TryRepairAndRebuild() local
239 (DB_REPAIR_RETRY_TIMES - retryTimes + 1), innerErr); in TryRepairAndRebuild()
248 retryTimes--; in TryRepairAndRebuild()
249 } while (retryTimes > 0); in TryRepairAndRebuild()
319 int retryTimes = CREATE_COLLECTION_RETRY_TIMES; in Put() local
334 retryTimes--; in Put()
335 } while (retryTimes > 0); in Put()
353 int retryTimes = CREATE_COLLECTION_RETRY_TIMES; in Delete() local
368 retryTimes--; in Delete()
369 } while (retryTimes > in Delete()
389 int retryTimes = CREATE_COLLECTION_RETRY_TIMES; Get() local
466 int retryTimes = CREATE_COLLECTION_RETRY_TIMES; GetAll() local
[all...]
/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/softbus/
H A Dsoftbus_session.cpp111 int retryTimes = 0; in WaitSessionOpened() local
113 while (retryTimes++ < OPEN_SESSION_RETRY_TIMES) { in WaitSessionOpened()
116 if (retryTimes % logSpan == 0) { in WaitSessionOpened()
117 LOGI("openSession, waiting for:%{public}d ms", retryTimes * OPEN_SESSION_RETRY_INTERVAL_MS); in WaitSessionOpened()
/foundation/ability/ability_lite/services/abilitymgr_lite/src/slite/
H A Dability_thread.cpp108 uint32_t retryTimes = 0; in SendScheduleMsgToAbilityThread() local
109 while (retryTimes < maxRetryTimes) { in SendScheduleMsgToAbilityThread()
116 retryTimes++; in SendScheduleMsgToAbilityThread()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/localhardwaremanager/
H A Dlocal_hardware_manager.cpp106 int32_t retryTimes = QUERY_RETRY_MAX_TIMES; in QueryLocalHardware() local
107 while (retryTimes > 0) { in QueryLocalHardware()
108 DHLOGI("Query hardwareHandler retry times left: %{public}d, dhType: %{public}#X", retryTimes, dhType); in QueryLocalHardware()
127 retryTimes--; in QueryLocalHardware()
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/http_source/monitor/
H A Ddownload_monitor.cpp167 auto retryTimes = request->GetRetryTimes(); in NeedRetry() local
169 ", retryTimes = " PUBLIC_LOG_D32 ",", clientError, serverError, retryTimes); in NeedRetry()
172 if (retryTimes > RETRY_TIMES_TO_REPORT_ERROR) { // Report error to upper layer in NeedRetry()
/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/
H A Dmedialibrary_restore.cpp80 int retryTimes = MAX_RETRY_TIMES; in CheckRestore()
88 retryTimes--; in CheckRestore()
92 } while (retryTimes > 0); in CheckRestore()
/foundation/multimedia/media_foundation/engine/plugin/plugins/demuxer/minimp4_demuxer/
H A Dminimp4_demuxer_plugin.cpp175 int retryTimes = 0; in DoReadFromSource() local
198 if (bufData->GetSize() == 0 && ioDataRemainSize_ == 0 && retryTimes < 200) { // 200 in DoReadFromSource()
200 retryTimes++; in DoReadFromSource()
203 if (retryTimes >= 200) { // 200 in DoReadFromSource()
446 int retryTimes = 0; in Sniff() local
451 if (bufData->GetSize() < sizeof(m4aCheck) && retryTimes < 50) { // 50 in Sniff()
453 retryTimes++; in Sniff()
/foundation/deviceprofile/device_info_manager/services/core/src/persistenceadapter/rdbadapter/
H A Drdb_adapter.cpp51 int32_t retryTimes = RDB_INIT_MAX_TIMES; in Init() local
52 while (retryTimes > 0) { in Init()
58 retryTimes--; in Init()
/foundation/bundlemanager/bundle_framework/services/bundlemgr/include/
H A Dinstalld_client.h249 for (int32_t retryTimes = 0; retryTimes < maxRetryTimes; retryTimes++) { in CallService()
256 APP_LOGE("CallService failed, retry times: %{public}d", retryTimes + 1); in CallService()
/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/monitor/
H A Ddownload_monitor.cpp185 auto retryTimes = request->GetRetryTimes(); in NeedRetry() local
188 ", retryTimes = " PUBLIC_LOG_D32 ",", clientError, serverError, retryTimes); in NeedRetry()
201 if (retryTimes > RETRY_THRESHOLD && !GetPlayable()) { in NeedRetry()
212 if (retryTimes > RETRY_TIMES_TO_REPORT_ERROR && !GetPlayable()) { in NeedRetry()
/foundation/resourceschedule/memmgr/services/memmgrservice/include/nandlife_controller/
H A Dnandlife_controller.h60 bool SetParameterRetry(const std::string &paramName, const std::string &paramValue, int retryTimes);
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/include/
H A Dclient_trans_proxy_file_common.h60 int32_t TryFileLock(int32_t fd, int32_t type, int32_t retryTimes);
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/
H A Ddistributed_data_storage.cpp95 int32_t retryTimes = RETRY_TIMES_WAIT_KV_DATA; in WaitKvDataService() local
108 if (--retryTimes <= 0) { in WaitKvDataService()
127 int32_t retryTimes = 0; in TryGetKvStore() local
128 while (retryTimes < RETRY_TIMES_GET_KVSTORE) { in TryGetKvStore()
134 retryTimes++; in TryGetKvStore()
H A Ddistributed_sched_mission_manager.cpp964 const std::string& localDevId, int32_t retryTimes) in RetryStartSyncRemoteMissions()
966 auto retryFunc = [this, dstDeviceId, localDevId, retryTimes]() { in RetryStartSyncRemoteMissions()
974 RetryStartSyncRemoteMissions(dstDeviceId, localDevId, retryTimes + 1); in RetryStartSyncRemoteMissions()
980 if (missionHandler_ != nullptr && retryTimes < MAX_RETRY_TIMES) { in RetryStartSyncRemoteMissions()
1055 void DistributedSchedMissionManager::RetryRegisterMissionChange(int32_t retryTimes) in RetryRegisterMissionChange() argument
1057 auto remoteDiedFunc = [this, retryTimes]() { in RetryRegisterMissionChange()
1058 HILOGI("RetryRegisterMissionChange retryTimes:%{public}d begin", retryTimes); in RetryRegisterMissionChange()
1064 RetryRegisterMissionChange(retryTimes + 1); in RetryRegisterMissionChange()
1070 if (missionHandler_ != nullptr && retryTimes < MAX_RETRY_TIME in RetryRegisterMissionChange()
963 RetryStartSyncRemoteMissions(const std::string& dstDeviceId, const std::string& localDevId, int32_t retryTimes) RetryStartSyncRemoteMissions() argument
[all...]
/foundation/CastEngine/castengine_cast_framework/client/src/
H A Dcast_session_manager.cpp77 constexpr int32_t retryTimes = 150; // The service startup timeout interval is 4s. in GetAdaptor() local
81 while ((object = samgr->CheckSystemAbility(CAST_ENGINE_SA_ID)) == nullptr && (retryTime < retryTimes)) { in GetAdaptor()
/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/download/
H A Ddownloader.h45 mutable size_t retryTimes {0};
63 while (fileContentLen == 0 && !isChunked && !isClosed && retryTimes < maxRetryTimes) { in GetFileContentLength()
65 retryTimes++; in GetFileContentLength()
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/http_lite_source/
H A Dhttp_lite_source_plugin.cpp205 int8_t retryTimes = 0; in SetSource() local
206 while (!needExit_ && position_ == downloadPos && retryTimes < 60) { // 60 in SetSource()
209 retryTimes++; in SetSource()
/foundation/ability/dmsfwk/services/dtbschedmgr/src/
H A Ddtbschedmgr_device_info_storage.cpp57 for (int32_t retryTimes = 0; retryTimes <= CONNECT_SOFTBUS_RETRY_TIMES; retryTimes++) { in Init()
61 HILOGE("retry connect softbus %{public}d times", retryTimes); in Init()
/foundation/multimedia/media_foundation/engine/plugin/plugins/demuxer/aac_demuxer/
H A Daac_demuxer_plugin.cpp81 int retryTimes = 0; in DoReadFromSource() local
107 if (bufData->GetSize() == 0 && ioDataRemainSize_ == 0 && retryTimes < 200) { // 200 in DoReadFromSource()
109 retryTimes++; in DoReadFromSource()
112 FALSE_RETURN_V_MSG_E(retryTimes < 200, Status::ERROR_NOT_ENOUGH_DATA, // 200 in DoReadFromSource()
/foundation/CastEngine/castengine_cast_framework/service/src/
H A Dcast_session_manager_service.cpp103 constexpr int retryTimes = 60 * 20; // total 60s in WaitSoftBusInit() local
106 while (ret == SoftBusErrNo::SOFTBUS_TRANS_SESSION_ADDPKG_FAILED && retryTime < retryTimes) { in WaitSoftBusInit()
116 if (retryTime == retryTimes) { in WaitSoftBusInit()
128 constexpr int32_t retryTimes = 20; in SetupSessionServer() local
129 while (result != SessionServer::SOFTBUS_OK && retryTime < retryTimes) { in SetupSessionServer()
/foundation/ability/dmsfwk/services/dtbschedmgr/src/adapter/
H A Ddnetwork_adapter.cpp158 int32_t retryTimes = 0; in AddDeviceChangeListener()
160 while (retryTimes++ < RETRY_REGISTER_CALLBACK_TIMES) { in AddDeviceChangeListener()
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/src/
H A Dclient_trans_proxy_file_common.c307 int32_t TryFileLock(int32_t fd, int32_t type, int32_t retryTimes) in TryFileLock() argument
311 while (retryTimes > 0) { in TryFileLock()
316 --retryTimes; in TryFileLock()
/foundation/deviceprofile/device_info_manager/old/services/core/src/dbstorage/
H A Ddevice_profile_storage.cpp135 int32_t retryTimes = 0; in TryGetKvStore() local
136 while (retryTimes < RETRY_TIMES_GET_KVSTORE) { in TryGetKvStore()
141 retryTimes++; in TryGetKvStore()
/foundation/multimedia/media_foundation/engine/plugin/plugins/minimp3_adapter/
H A Dminimp3_demuxer_plugin.cpp102 int retryTimes = 0; in DoReadFromSource() local
108 if (bufData->GetSize() == 0 && retryTimes < 200 && ioDataRemainSize_ == 0) { // 200 in DoReadFromSource()
109 MEDIA_LOG_DD("bufData->GetSize() == 0 retryTimes = " PUBLIC_LOG_D32, retryTimes); in DoReadFromSource()
111 retryTimes++; in DoReadFromSource()
114 FALSE_RETURN_V_MSG_E(retryTimes < 200, Status::ERROR_NOT_ENOUGH_DATA, // 200 times in DoReadFromSource()

Completed in 15 milliseconds

12