task 启动增加 name判断

diff --git a/code/sdk/drivers/peripheral/slip/cat1Service/cat1_ai_server.cpp b/code/sdk/drivers/peripheral/slip/cat1Service/cat1_ai_server.cpp
index 1fdb886..fb7ba1d 100644 (file)
--- a/code/sdk/drivers/peripheral/slip/cat1Service/cat1_ai_server.cpp
+++ b/code/sdk/drivers/peripheral/slip/cat1Service/cat1_ai_server.cpp
@@ -612,11 +612,16 @@ errcode_t chat_server_init(void)
 {
     int osThreadGetState_t= osThreadGetState(chat_taskcfg.task_handle);
 
+    const char *buf= osThreadGetName(chat_taskcfg.task_handle);
+
     WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP,"chat osThreadGetState_t %d!\r\n",osThreadGetState_t);
-    if(osThreadGetState_t!=osThreadReady &&  osThreadGetState_t!=osThreadError && osThreadGetState_t !=osThreadInactive)
+     if(strcmp("chat_server_init",buf)==0)
     {
-         WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP,"osThreadGetState is %d!\r\n",osThreadGetState_t);
-         return ERRCODE_FAIL;
+        if(osThreadGetState_t!=osThreadReady &&  osThreadGetState_t!=osThreadError && osThreadGetState_t !=osThreadInactive)
+        {
+            WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP,"osThreadGetState is %d!\r\n",osThreadGetState_t);
+            return ERRCODE_FAIL;
+        }
     }
 
     if(chat_client || is_bk_websocket_chat )
@@ -994,13 +999,13 @@ void bk_websocket_asr(void *data) {
                 }
                 break;
             }
-          if(type==WS_TEXT)
+            if(type==WS_TEXT)
             {
-            if(false== aer_result_analysis(asr_recv_buf))
-            {
-                printf("WS_lwip_close false== aer_result_analysis(asr_recv_buf)\r\n");
-                break;
-            }
+                if(false== aer_result_analysis(asr_recv_buf))
+                {
+                    printf("WS_lwip_close false== aer_result_analysis(asr_recv_buf)\r\n");
+                    break;
+                }
             }
             if(type==WS_PONG)
             {
@@ -1030,15 +1035,21 @@ void bk_websocket_asr(void *data) {
 
 errcode_t asr_server_init(void)
 {
-     int osThreadGetState_t= osThreadGetState(asr_taskcfg.task_handle);
+    int osThreadGetState_t= osThreadGetState(asr_taskcfg.task_handle);
 
-    WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP,"chat osThreadGetState_t %d!\r\n",osThreadGetState_t);
-    if(osThreadGetState_t!=osThreadReady && osThreadGetState_t!=osThreadError && osThreadGetState_t !=osThreadInactive)
+    const char *buf= osThreadGetName(asr_taskcfg.task_handle);
+
+    WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP,"chat osThreadGetState_t %d %s!\r\n",osThreadGetState_t,buf);
+    if(strcmp("asr_server_init",buf)==0)
     {
-         WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP,"osThreadGetState is %d!\r\n",osThreadGetState_t);
-         return ERRCODE_FAIL;
+        if(osThreadGetState_t!=osThreadReady && osThreadGetState_t!=osThreadError && osThreadGetState_t !=osThreadInactive)
+        {
+            WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP,"osThreadGetState is %d!\r\n",osThreadGetState_t);
+            return ERRCODE_FAIL;
+        }
     }
 
+
     if(is_bk_websocket_asr || asr_client!=NULL)
     {
         WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP,"cat1_tcp_server_init is connet!\r\n");
@@ -1414,11 +1425,16 @@ errcode_t tts_server_init(void)
 {
     int osThreadGetState_t= osThreadGetState(tts_taskcfg.task_handle);
 
+    const char *buf= osThreadGetName(tts_taskcfg.task_handle);
+
     WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP,"tts osThreadGetState_t %d!\r\n",osThreadGetState_t);
-    if(osThreadGetState_t!=osThreadReady && osThreadGetState_t!=osThreadError && osThreadGetState_t !=osThreadInactive)
+    if(strcmp("tts_server_init",buf)==0)
     {
-         WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP,"osThreadGetState is %d!\r\n",osThreadGetState_t);
-         return ERRCODE_FAIL;
+        if(osThreadGetState_t!=osThreadReady && osThreadGetState_t!=osThreadError && osThreadGetState_t !=osThreadInactive)
+        {
+            WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP,"osThreadGetState is %d!\r\n",osThreadGetState_t);
+            return ERRCODE_FAIL;
+        }
     }
 
     if(tts_client!=NULL || is_bk_websocket_tts)
@@ -1543,6 +1559,7 @@ static void time_sync_func(void)
     {
         if(chat_client_ping)
         {
+
             chat_server_deinit();
             lwip_close_websocket_client(chat_client);
             chat_client=NULL;