| | |
|---|
| | | if (m_onSyncingStateChanged != nullptr) { |
|---|
| | | m_onSyncingStateChanged(m_nSyncStatus); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | void CRecipesManager::syncTimeout() |
|---|
| | | { |
|---|
| | | lock(); |
|---|
| | | m_nSyncStatus = SS_TIMEOUT; |
|---|
| | | m_nTimeoutCount = 0; |
|---|
| | | unlock(); |
|---|
| | | |
|---|
| | | if (m_onSyncingStateChanged != nullptr) { |
|---|
| | | m_onSyncingStateChanged(m_nSyncStatus); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | short CRecipesManager::decodeRecipeListReport(const char* pszData, size_t size) |
|---|
| | |
|---|
| | | |
|---|
| | | } |
|---|
| | | else if (reportType == RT_REQUEST_FROM_EAS) { |
|---|
| | | int nRet = pRecipeList->addRecipePacket(toatlGroupCount, currentGroupCount, pszIdsData, 250 * 2); |
|---|
| | | int nRet = pRecipeList->addRecipePacket(totalMasterRecipeCount, toatlGroupCount, currentGroupCount, pszIdsData, 250 * 2); |
|---|
| | | if (MRLRC_CURRENT_RECIPE_COMPLETE == nRet) { |
|---|
| | | lock(); |
|---|
| | | for (auto item : m_mapRecipes) { |
|---|
| | |
|---|
| | | if (m_nSyncStatus == SS_SYNCING) { |
|---|
| | | m_nTimeoutCount++; |
|---|
| | | if (m_nTimeoutCount > 10) { |
|---|
| | | m_nSyncStatus = SS_TIMEOUT; |
|---|
| | | unlock(); |
|---|
| | | syncTimeout(); |
|---|
| | | TRACE("CRecipesManager::TimeoutCheckWorkingProc 超时退出\n"); |
|---|
| | | lock(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
