Commit 15537303 authored by 黄振令's avatar 黄振令

【修改内容】网关与主机未连接,去发送tcp,增加保护

【提交人】huang.zhenling
parent 1ed830cc
...@@ -534,7 +534,7 @@ typedef struct { ...@@ -534,7 +534,7 @@ typedef struct {
ipc_cb* cb; ipc_cb* cb;
} kk_tcp_client_t; } kk_tcp_client_t;
static kk_tcp_client_t g_client_ctrl; static kk_tcp_client_t g_client_ctrl = {NULL, -1, 0,{0},0, NULL};
static int _init_client(){ static int _init_client(){
memset(&g_client_ctrl, 0 ,sizeof(kk_tcp_client_t)); memset(&g_client_ctrl, 0 ,sizeof(kk_tcp_client_t));
...@@ -639,7 +639,7 @@ static void loop_tcp_client_thread(void *arg){ ...@@ -639,7 +639,7 @@ static void loop_tcp_client_thread(void *arg){
int kk_tcp_client_send(char* data, int len){ int kk_tcp_client_send(char* data, int len){
int ret = 0; int ret = 0;
int cnt = 0; int cnt = 0;
if ( data != NULL){ if ( data != NULL && g_client_ctrl.isConnect == 1){
while(g_client_ctrl.sd == -1 && cnt < 5){ while(g_client_ctrl.sd == -1 && cnt < 5){
printf("[%s] tcp don't connect, sleep 1s !!!! \n",__FUNCTION__); printf("[%s] tcp don't connect, sleep 1s !!!! \n",__FUNCTION__);
sleep(1); sleep(1);
...@@ -662,7 +662,7 @@ int kk_tcp_client_send(char* data, int len){ ...@@ -662,7 +662,7 @@ int kk_tcp_client_send(char* data, int len){
} }
int kk_tcp_client_init(char ip[MAX_IP_LEN], int port, ipc_cb cb) int kk_tcp_client_init(char ip[MAX_IP_LEN], int port, ipc_cb cb)
{ {
kk_tcp_client_deinit(); //kk_tcp_client_deinit();
_init_client(); _init_client();
g_client_ctrl.port = port; g_client_ctrl.port = port;
memcpy(g_client_ctrl.ip, ip, strlen(ip)); memcpy(g_client_ctrl.ip, ip, strlen(ip));
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment