diff --git a/services/distributedhardwarefwkservice/include/resourcemanager/db_adapter.h b/services/distributedhardwarefwkservice/include/resourcemanager/db_adapter.h index f2d052d1f267c6ff8d8f7f09814e7fb57bc40b81..64a9260b495b810d7542d0d064c1b762d42fe29b 100644 --- a/services/distributedhardwarefwkservice/include/resourcemanager/db_adapter.h +++ b/services/distributedhardwarefwkservice/include/resourcemanager/db_adapter.h @@ -73,6 +73,7 @@ private: void UnRegisterKvStoreDeathListener(); void RegisterManualSyncListener(); void UnRegisterManualSyncListener(); + void HandleManualSync(const std::string &deviceId); DistributedKv::Status GetKvStorePtr(); private: diff --git a/services/distributedhardwarefwkservice/src/resourcemanager/db_adapter.cpp b/services/distributedhardwarefwkservice/src/resourcemanager/db_adapter.cpp index bc69c925ba69e769657ab43302e75e90d2032583..f0c1ea5b86126abb71787029e709eff66072573c 100644 --- a/services/distributedhardwarefwkservice/src/resourcemanager/db_adapter.cpp +++ b/services/distributedhardwarefwkservice/src/resourcemanager/db_adapter.cpp @@ -142,19 +142,24 @@ void DBAdapter::SyncCompleted(const std::map manualSyncCountMap_[deviceId] = 0; } else { manualSyncCountMap_[deviceId]++; - if (manualSyncCountMap_[deviceId] >= MANUAL_SYNC_TIMES) { - manualSyncCountMap_[deviceId] = 0; - } else { - auto retryTask = [this, deviceId] { - this->ManualSync(deviceId); - usleep(MANUAL_SYNC_INTERVAL); - }; - DHContext::GetInstance().GetEventBus()->PostTask(retryTask, "retryTask", 0); - } + HandleManualSync(deviceId); } } } +void DBAdapter::HandleManualSync(const std::string &deviceId) +{ + if (manualSyncCountMap_[deviceId] >= MANUAL_SYNC_TIMES) { + manualSyncCountMap_[deviceId] = 0; + } else { + auto retryTask = [this, deviceId] { + this->ManualSync(deviceId); + usleep(MANUAL_SYNC_INTERVAL); + }; + DHContext::GetInstance().GetEventBus()->PostTask(retryTask, "retryTask", 0); + } +} + int32_t DBAdapter::GetDataByKey(const std::string &key, std::string &data) { DHLOGI("Get data by key: %s", GetAnonyString(key).c_str()); diff --git a/utils/src/dh_utils_tool.cpp b/utils/src/dh_utils_tool.cpp index 19d3b580bd978f804e51c6f6afc56c90c7b5ddd8..136675f89fa38186827d5282ef97dfe0dc267d52 100644 --- a/utils/src/dh_utils_tool.cpp +++ b/utils/src/dh_utils_tool.cpp @@ -50,7 +50,10 @@ std::string GetRandomID() static std::uniform_int_distribution dist(0ULL, 0xFFFFFFFFFFFFFFFFULL); uint64_t ab = dist(rd); uint64_t cd = dist(rd); - uint32_t a, b, c, d; + uint32_t a; + uint32_t b; + uint32_t c; + uint32_t d; std::stringstream ss; ab = (ab & 0xFFFFFFFFFFFF0FFFULL) | 0x0000000000004000ULL; cd = (cd & 0x3FFFFFFFFFFFFFFFULL) | 0x8000000000000000ULL;