diff --git a/main.c b/main.c index d722b17..ac2e7ef 100644 --- a/main.c +++ b/main.c @@ -2491,7 +2491,7 @@ void *thread_mqtt_recv(void *arg){ DEBUG_TX("flashInterval:%s\n",mqtt_parm.msg_flashInterval); get_string_from_json_string_by_key_unescape(msg_data, "lightDuration", mqtt_parm.msg_lightDuration, sizeof(mqtt_parm.msg_lightDuration)); DEBUG_TX("lightDuration:%s\n",mqtt_parm.msg_lightDuration); - pthread_mutex_lock(&lightsn_buffer_mutex); + //pthread_mutex_lock(&lightsn_buffer_mutex); if (!is_3015_collecting) { is_3015_collecting = true; first_3015_time = time(NULL); @@ -2518,7 +2518,7 @@ void *thread_mqtt_recv(void *arg){ LOG_I("buffered sn: %s, color: %s, sound: %s, flash: %s\n", lightsn_buffer[lightsn_buffer_count], color_buffer[lightsn_buffer_count], sound_buffer[lightsn_buffer_count], flash_buffer[lightsn_buffer_count]); lightsn_buffer_count++; } - pthread_mutex_unlock(&lightsn_buffer_mutex); + //pthread_mutex_unlock(&lightsn_buffer_mutex); mqtt_service_reply(stationsn, mqtt_parm.msg_messageId, "ok", 1, productid); }else if(strcmp(mqtt_parm.msg_type,"3022")==0){ LOG_I("3022 updata lable\n");