commit 036b6cfdeed080b34413119e29abd37156a7ffa7
author q.huang <q.huang@exm.com> Tue Jan 10 14:29:20 2023 +0800
committer xf.li <xf.li@mobiletek.cn> Thu Feb 16 04:33:01 2023 -0800
tree d3818f66bb66b5d2f0e9e4e46eeb3f5ac2c7a13a
parent e0832cc9c92e4d87802c7841d40c653deb70effe

[feature][T8TSK-135] RIL3.0 soceket broadcast optimistion 4

Change-Id: Ia50de7c8bb4eebf52b139b92e21e9c8cef18ebe3

lib/liblynq-network/lynq_network.cpp

diff --git a/lib/liblynq-network/lynq_network.cpp b/lib/liblynq-network/lynq_network.cpp
index cca772f..98e33f6 100755
--- a/lib/liblynq-network/lynq_network.cpp
+++ b/lib/liblynq-network/lynq_network.cpp
@@ -54,8 +54,8 @@
     int ret;

 

     init_network_timer_all();

-

-    ret = lynq_urc_socket_start();

+	

+    ret = lynq_start_all_urc_socket_thread();

     if(ret != 0)

     {

         LYERRLOG("init socket urc fail!!!");

@@ -63,11 +63,11 @@
         return LYNQ_E_INNER_ERROR;

     }

 

-    ret = lynq_server_socket_start();

+    ret = lynq_start_all_rc_socket_thread();

     if(ret !=0)

     {

         LYERRLOG("init socket client fail!!!");

-        lynq_close_urc_thread();

+        lynq_close_all_urc_socket_thread();

         g_module_init_flag = MODULE_CLOSED;  

         return LYNQ_E_INNER_ERROR;

     }

@@ -85,8 +85,8 @@
     }  

     g_module_init_flag = MODULE_SWITCHING;

 

-    lynq_close_urc_thread();

-    lynq_close_rc_thread();    

+    lynq_close_all_urc_socket_thread();

+    lynq_close_all_rc_socket_thread();    

     deinit_network_timer_all();

 

     g_module_init_flag = MODULE_CLOSED;

@@ -1113,6 +1113,20 @@
     return;

 }

 

+bool is_support_urc(int urc_id)

+{

+    switch(urc_id)

+    {

+        case RIL_UNSOL_RESPONSE_VOICE_NETWORK_STATE_CHANGED:

+        case RIL_UNSOL_RESPONSE_PS_NETWORK_STATE_CHANGED:

+        case RIL_UNSOL_RESPONSE_IMS_NETWORK_STATE_CHANGED:

+        case RIL_UNSOL_SIGNAL_STRENGTH:

+            return true;                

+        default:

+            return false;

+    }    

+}

+

 void urc_msg_process(Parcel *p)

 { 

     int resp_type; 

@@ -1121,10 +1135,11 @@
     int urc_LTE_signalstrength = 0;

     int urc_WCDMA_signalstrength = 0;

 

+    int size=p->dataSize();

     p->readInt32(&resp_type);

     p->readInt32(&s_module_wait_urc_id);

     p->readInt32(&s_module_urc_slot_id);

-    LYINFLOG("urc id = %d, slot_id = %d",s_module_wait_urc_id,s_module_urc_slot_id);

+    LYINFLOG("%s urc id = %d, slot_id = %d, size is %d, msg is %s",__func__, s_module_wait_urc_id,s_module_urc_slot_id,size,requestToString(s_module_wait_urc_id));

     switch(s_module_wait_urc_id)

     {

         case RIL_UNSOL_RESPONSE_VOICE_NETWORK_STATE_CHANGED: