Commit 999cbb39 authored by 黄振令's avatar 黄振令

【修改内容】对于使用nanomsg发送方式修改为长等待,保证数据收到

parent 0772aad7
......@@ -97,13 +97,23 @@ static void watcher_cb (struct ev_loop *loop ,struct ev_io *w, int revents)
}
//for test ipc connect or not
if (loop_ctrl->isconnect == 0 ){
/*if (loop_ctrl->isconnect == 0 ){
loop_ctrl->isconnect =1;
if (strncmp(validDat,MAGIC, strlen(MAGIC)) == 0){
kk_ipc_send(loop_ctrl->type, validDat, bytes);
kk_ipc_send_ex(loop_ctrl->type, validDat, bytes, chlMark);
nn_freemsg(dat);
return;
}
}*/
if (strncmp(validDat,MAGIC, strlen(MAGIC)) == 0){
if (loop_ctrl->isconnect == 0){
kk_ipc_send_ex(loop_ctrl->type, validDat, bytes, chlMark);
loop_ctrl->isconnect =1;
}
nn_freemsg(dat);
return;
}else if (IPC_MID2PLAT == loop_ctrl->type){//
loop_ctrl->isconnect =0;
}
if (loop_ctrl->cb != NULL){
......@@ -400,9 +410,9 @@ int kk_ipc_send_ex(ipc_type type, void* data, int len, char* chalMark)
memcpy(buf + filterlen, data, len);
if (type == IPC_MID2PLAT){
nn_send(Mloop_ctrl.ab.n, &buf, NN_MSG, NN_DONTWAIT);
nn_send(Mloop_ctrl.ab.n, &buf, NN_MSG, 0);//NN_DONTWAIT
}else{
nn_send(Bloop_ctrl.ba.n, &buf, NN_MSG, NN_DONTWAIT);
nn_send(Bloop_ctrl.ba.n, &buf, NN_MSG, 0);
}
}
......
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