diff --git a/main/tasks/stratum_task.c b/main/tasks/stratum_task.c index ae9391a8a..379cb5a53 100644 --- a/main/tasks/stratum_task.c +++ b/main/tasks/stratum_task.c @@ -595,12 +595,19 @@ void stratum_task(void * pvParameters) stratum_close_connection(GLOBAL_STATE); break; } else if (stratum_api_v1_message.method == STRATUM_RESULT) { + float response_time_ms = STRATUM_V1_get_response_time_ms(stratum_api_v1_message.message_id, receive_time_us); if (stratum_api_v1_message.response_success) { ESP_LOGI(TAG, "message result accepted"); - SYSTEM_notify_accepted_share(GLOBAL_STATE); + if (response_time_ms >= 0) { + ESP_LOGI(TAG, "Stratum response time: %.1f ms", response_time_ms); + GLOBAL_STATE->SYSTEM_MODULE.response_time = response_time_ms; + SYSTEM_notify_accepted_share(GLOBAL_STATE); + } } else { ESP_LOGW(TAG, "message result rejected: %s", stratum_api_v1_message.error_str); - SYSTEM_notify_rejected_share(GLOBAL_STATE, stratum_api_v1_message.error_str); + if (response_time_ms >= 0) { + SYSTEM_notify_rejected_share(GLOBAL_STATE, stratum_api_v1_message.error_str); + } } } else if (stratum_api_v1_message.method == STRATUM_RESULT_SETUP) { // Reset retry attempts after successfully receiving data. @@ -617,12 +624,6 @@ void stratum_task(void * pvParameters) ESP_LOGE(TAG, "setup message rejected: %s", stratum_api_v1_message.error_str); } } - - float response_time_ms = STRATUM_V1_get_response_time_ms(stratum_api_v1_message.message_id, receive_time_us); - if (response_time_ms >= 0) { - ESP_LOGI(TAG, "Stratum response time: %.1f ms", response_time_ms); - GLOBAL_STATE->SYSTEM_MODULE.response_time = response_time_ms; - } } if (stratum_api_v1_message.error_str) {