commit 2c21d620ad3d66c7f91bca66ad84ed6c708b337b
author liuyang <leo.liu@mobiletek.cn> Mon Jul 29 14:05:55 2024 +0800
committer liuyang <leo.liu@mobiletek.cn> Mon Jul 29 14:05:55 2024 +0800
tree 396a0ef27ba02a1a8bcf0bb644283d3618e9e7ed
parent 6a3437fe417968f8f8f5327eb01c5469ca26c78f

data_call_async_thread

Change-Id: I5e313946ae33c2c65ad73215be7572e8edbe30d7

mbtk/liblynq_lib/src/lynq_data_call.c

diff --git a/mbtk/liblynq_lib/src/lynq_data_call.c b/mbtk/liblynq_lib/src/lynq_data_call.c
index 5e0ccdb..73e4692 100644
--- a/mbtk/liblynq_lib/src/lynq_data_call.c
+++ b/mbtk/liblynq_lib/src/lynq_data_call.c
@@ -215,9 +215,11 @@
 
 static void* data_call_async_thread(void* arg)
 {
-    qser_data_call_error_e err;
+    LOGE("[qser_data] entry data_call_async_thread.");
+    qser_data_call_error_e err = QSER_DATA_CALL_ERROR_NONE;
     
     qser_data_call_s qser_data_backup = {0};
+    qser_data_call_info_s info = {0};
     if(arg != NULL)
     {
         memcpy(&qser_data_backup, (qser_data_call_s *)arg, sizeof(qser_data_call_s));
@@ -230,6 +232,7 @@
     qser_data_call_state_s state = {0};
     qser_state_init(&state);
     state.profile_idx = qser_data_backup.profile_idx;
+    snprintf(state.name, 16, "ccinet%d", qser_data_backup.profile_idx);
     state.ip_family = qser_data_backup.ip_family;
     
     int ret = qser_data_call_start(&qser_data_backup, &err);
@@ -237,29 +240,23 @@
     {
         LOGE("[qser_data] qser_data_call_start() fail.");
         state.err = err;
-        if(qser_net_status_cb != NULL)
-        {
-            qser_net_status_cb(&state);
-        }
     }
-
-    qser_data_call_info_s info = {0};
-    ret = qser_data_call_info_get(qser_data_backup.profile_idx, qser_data_backup.ip_family, &info, &err);
-    if(ret != QSER_RESULT_SUCCESS)
+    else
     {
-        LOGE("[qser_data] qser_data_call_info_get() fail.");
-        state.err = err;
-        if(qser_net_status_cb != NULL)
+        state.state = QSER_DATA_CALL_CONNECTED;
+        ret = qser_data_call_info_get(qser_data_backup.profile_idx, qser_data_backup.ip_family, &info, &err);
+        if(ret != QSER_RESULT_SUCCESS)
         {
-            qser_net_status_cb(&state);
+            LOGE("[qser_data] qser_data_call_info_get() fail.");
+            state.err = err;
+        }
+        else
+        {
+            memcpy(&(state.v4), &(info.v4.addr), sizeof(struct v4_address_status));
+            memcpy(&(state.v6), &(info.v6.addr), sizeof(struct v6_address_status));
         }
     }
-    
-    snprintf(state.name, 16, "ccinet%d", qser_data_backup.profile_idx);
-    state.state = QSER_DATA_CALL_CONNECTED;
-    state.err = err;
-    memcpy(&(state.v4), &(info.v4.addr), sizeof(struct v4_address_status));
-    memcpy(&(state.v6), &(info.v6.addr), sizeof(struct v6_address_status));
+  
     if(qser_net_status_cb != NULL)
     {
         qser_net_status_cb(&state);