/foundation/filemanagement/dfs_service/utils/system/include/ |
H A D | dfsu_thread.h | 52 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 D | preferences_db_adapter.cpp | 230 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 D | softbus_session.cpp | 111 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 D | ability_thread.cpp | 108 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 D | local_hardware_manager.cpp | 106 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 D | download_monitor.cpp | 167 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 D | medialibrary_restore.cpp | 80 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 D | minimp4_demuxer_plugin.cpp | 175 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 D | rdb_adapter.cpp | 51 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 D | installd_client.h | 249 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 D | download_monitor.cpp | 185 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 D | nandlife_controller.h | 60 bool SetParameterRetry(const std::string ¶mName, const std::string ¶mValue, int retryTimes);
|
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/include/ |
H A D | client_trans_proxy_file_common.h | 60 int32_t TryFileLock(int32_t fd, int32_t type, int32_t retryTimes);
|
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
H A D | distributed_data_storage.cpp | 95 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 D | distributed_sched_mission_manager.cpp | 964 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 D | cast_session_manager.cpp | 77 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 D | downloader.h | 45 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 D | http_lite_source_plugin.cpp | 205 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 D | dtbschedmgr_device_info_storage.cpp | 57 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 D | aac_demuxer_plugin.cpp | 81 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 D | cast_session_manager_service.cpp | 103 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 D | dnetwork_adapter.cpp | 158 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 D | client_trans_proxy_file_common.c | 307 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 D | device_profile_storage.cpp | 135 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 D | minimp3_demuxer_plugin.cpp | 102 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()
|