好像一直不能回到线程里面

发布于 2021-08-04 19:19:57 浏览：958 订阅该版

rt_ipc_list_resume_all 程序移植在这个函数里面出不去
```c
                    if(p_cmd != NULL)//列表中有该命令
                    {
                        /* 调用相关命令的处理函数 */
                        func_cmd_ret = p_cmd->func(strueclient.recv_buf,strueclient.recvlen,strueclient.curr_line);
                        /* 将接收缓存清空 */
                        memset(strueclient.recv_buf, 0x00, strueclient.bufsize);
                        strueclient.recvlen = 0; //接收长度设置为0
                        if( func_cmd_ret == OK ) //命令处理结束
                        {
                            if(strueclient.cmd_notice) //判断当前命令信号量是不是空
                            {   /* 接收成功释放信号量 */
                                rt_sem_release(strueclient.cmd_notice);
                            }
                            strueclient.curr_line = 0;//将当前命令接收行清零
                            if(strueclient.lock != NULL)
                            {
                                rt_mutex_take(strueclient.lock, RT_WAITING_FOREVER);//等待一行数据处理完成
                                rt_mutex_release(strueclient.lock);
                            }
                        }
                    }
                    
                    
                    
                            if( module_4g.data_interaction_steps == INTERACTION_STEPS_32FUNCTION_CODE )//32功能码
        {
            for(uint8_t i = 0;;i++)
            {
                if(i >= 5)//该指令出错重复5次
                {
                    if(module_4g.flag_module_error == FLAG_NETWPRK_ERROR_OK)
                    {
                        module_4g.flag_module_error = FLAG_NETWPRK_ERROR_CURR;//发送当前值失败
                    }
                    return -ERROR;//返回出错标志
                }
                creat_at_cmd("AT+QISEND");
                /* 声明一个变量,用于记录数据长度 */
                int data_len = 0;
                data_len = send_32functioncode((uint8_t*)sen4g_buf,TX4G_LEN);      //将当前值装载到缓存里面,用于发送
                if(data_len > 0 )
                {
                    txbuf_len = ( uint16_t )data_len;//将数据长度给二进制直接发送缓存的数据长度
                }
                else
                {
                    break;
                }
                /* 重新开始发送,清相关标志 */
                module_4g.flag_module_error = FLAG_NETWPRK_ERROR_OK;
                module_4g.flag_steps = STEPS_NULL; 
                thread_get_mutex(); //互斥锁保护
                //执行指令,发送当前值
                cmd_resel = execute_at_cmd("=1,%d",data_len);
                delete_at_cmd();//删除相关的指令
                if( (module_4g.flag_steps == STEPS_OK) && (cmd_resel == OK) )//判断指令执行结果
                {   //数据发送成功,先将相关标志
                    module_4g.flag_module_error = FLAG_NETWPRK_ERROR_OK;//错误状态标志位
                    module_4g.flag_steps = STEPS_NULL;  //将指令执行反馈清零
                    cmd_resel = 0;
                    //创建信号量,等待服务器返回数据如果
                    if(module_4g.sem_data_sever != NULL)
                    {   //当前的信号量不为空,先删除相关的信号量
                        rt_sem_delete(module_4g.sem_data_sever);
                    }
                    //创建一个信号量等待接受服务器返回
                    module_4g.sem_data_sever = rt_sem_create("32func",0,RT_IPC_FLAG_FIFO);
                    receive_mutex();//解除保护锁,解除后接收线程会取服务器数据.
                    rt_err_t res_sem_sever;
                    res_sem_sever = rt_sem_take(module_4g.sem_data_sever,rt_tick_from_millisecond(1000));//等待信号量的到来
                    if( res_sem_sever == RT_EOK )
                    {   //接收成功推出循环
                        if(module_4g.data_interaction_flag == INTERACTION_FLAG_SUCCESS)//数据解析成功
                        {   
                            PowerDown_DataSave.Flag_Function_32code = 1;//32功能码发送后成功获取到地址号和公司号,将标志配置到1,并添加到掉电数据的保存上取
                            rt_sem_delete(module_4g.sem_data_sever);//删除信号量
                            module_4g.sem_data_sever = NULL;
                            module_4g.data_interaction_flag = INTERACTION_FLAG_NULL;
                            PowerDown_DataSave.Flag_Function_32code = 32;//将标志改为32
                            break;
                        }
                        else if(module_4g.data_interaction_flag == INTERACTION_FLAG_CRC_ERROR )//数据CRC校验出错
                        {
                            module_4g.flag_module_error = FLAG_NETWPRK_ERROR_CRC;
                        }
                    
                    }
                    rt_sem_delete(module_4g.sem_data_sever);//删除信号量data_inter
                    module_4g.sem_data_sever = NULL;
                }
                receive_mutex();//释放互斥量,告诉接收线程命令接收处理完成
            }
            /* 执行完之后,发送当前值 */
            module_4g.data_interaction_steps = INTERACTION_STEPS_CURRENT_DATA;
        }
```