求助,消息队列接收到消息

发布于 2021-08-25 11:07:47 浏览：930 订阅该版

2 个回答

游走在01的海洋 2021-08-25

In the end, it's not the years in your life that count. It's the life in your years.

陈云鹏 2021-08-25

这家伙很懒，什么也没写！

```c
/*模块初始化*/
void commonfunction_init(void)
{
    commonfunction_struct_init();
    mq_comfun = rt_mq_create("mq_comfun", sizeof(cmd_struct), 10, RT_IPC_FLAG_FIFO);
    if(mq_comfun != RT_NULL)
        rt_kprintf("\nmq_comfun mq create\n");
//    timer_comfun = rt_timer_create("timer_comfun", rtc_timer_ok, NULL, 1000, RT_TIMER_FLAG_PERIODIC+RT_TIMER_FLAG_ACTIVATED);
    INT8U tmr[] = {21,3,24,15,36,0};
    rtc_sample(tmr);
    confun_data.workmode = WORKMODE_HANDLE;
    for(int i=0; i<CtrDeviceCount; i++)
    {
        if(setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrMode == 0)
        {
            confun_data.CtrDeviceValue[i] = 0;
            confun_data.CtrDeviceValue_old[i] = 0;
        }
        else {
            confun_data.CtrDeviceValue[i] = 2;
            confun_data.CtrDeviceValue_old[i] = 2;
        }
    }
}

void msg_process_thread_entry(void * parameter)
{
    cmd_struct r_queue;
    rt_err_t uwRet = RT_EOK;
    commonfunction_init();
    while(1)
    {
        //获取队列信息
        uwRet = rt_mq_recv(mq_comfun, (void*)&r_queue, sizeof(cmd_struct), RT_WAITING_FOREVER);
        if(RT_EOK == uwRet)
        {
            rt_kprintf("=========================\n");
            rt_kprintf("mq_comfun receive msg:%d:%d\n", r_queue.cmd, r_queue.value);
            if(r_queue.cmd == set_value_refresh)
            {
            }
            else if((r_queue.cmd == hmi_value_MODE) || (r_queue.cmd == gps_value_MODE))
            {
                if(confun_data.workmode != r_queue.value)
                {
//                    confun_data.modechage = r_queue.value;
//                    confun_data.workmode = WORKMODE_CHANGE;
                    confun_data.workmode = r_queue.value;
                }
            }
            else if (r_queue.cmd == hmi_value_RTC) {
                confun_data.RTCFlag = r_queue.value;
            }
            else if((r_queue.cmd == hmi_value_RemoteCtrl)||(r_queue.cmd == gps_value_remoteCtrl))
            {
                sendmessage_device(sys_value_RemoteCtrl, r_queue.value);
            }
            else if((r_queue.cmd>=hmi_device_button1) && (r_queue.cmd<=hmi_device_button100))
            {
                if(confun_data.workmode == WORKMODE_HANDLE)
                {
                    INT8U ide = r_queue.cmd-hmi_device_button1;

if(setup_data.Parameter.value_struct.parameter.CtrDevices[ide].Enable)
                    {

if(setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrMode == 0)
                        {
                            if((confun_data.CtrDeviceValue[ide] == 0) || (confun_data.CtrDeviceValue[ide] == 2))
                            {
                                confun_data.CtrDeviceValue[ide] = 1;                //0:关，1：开，2：停，3，无效
                            }
                            else if(confun_data.CtrDeviceValue[ide] == 1)
                            {
                                confun_data.CtrDeviceValue[ide] = 0;
                            }
//                            confun_data.CtrDeviceValue[ide] = ((INT8U)(r_queue.value)==1)?1:0;
                            sendmessage_mq(mq_hmi, ide+device1, confun_data.CtrDeviceValue[ide]);
                            sendmessage_mq(mq_gprs, ide+device1, confun_data.CtrDeviceValue[ide]);
                            sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint1, confun_data.CtrDeviceValue[ide]);
                        }
                        else {
                            if((confun_data.CtrDeviceValue[ide] == 2)&&((confun_data.CtrDeviceValue_old[ide] == 2)||(confun_data.CtrDeviceValue_old[ide] == 0)))
                            {
                                confun_data.CtrDeviceValue[ide] = 1;
                                confun_data.CtrDeviceValue_old[ide] = 2;
                            }
                            else if((confun_data.CtrDeviceValue[ide] == 2) && (confun_data.CtrDeviceValue_old[ide] == 1))
                            {
                                confun_data.CtrDeviceValue[ide] = 0;
                                confun_data.CtrDeviceValue_old[ide] = 2;
                            }
                            else if (confun_data.CtrDeviceValue[ide] == 0) {
                                confun_data.CtrDeviceValue[ide] = 2;
                                confun_data.CtrDeviceValue_old[ide] = 0;
                            }
                            else if (confun_data.CtrDeviceValue[ide] == 1) {
                                confun_data.CtrDeviceValue[ide] = 2;
                                confun_data.CtrDeviceValue_old[ide] = 1;
                            }
//                            confun_data.CtrDeviceValue[ide] = (INT8U)(r_queue.value);
                            sendmessage_mq(mq_hmi, ide+device1, confun_data.CtrDeviceValue[ide]);
                            sendmessage_mq(mq_gprs, ide+device1, confun_data.CtrDeviceValue[ide]);
                            if(confun_data.CtrDeviceValue[ide]==0)
                            {
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint1, 0);
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint2, 1);
                            }
                            else if (confun_data.CtrDeviceValue[ide] == 1) {
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint1, 1);
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint2, 0);
                            }
                            else if (confun_data.CtrDeviceValue[ide] == 2) {
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint1, 0);
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint2, 0);
                            }
                        }
                    }
                }
            }
            else if((r_queue.cmd>=gps_device1) && (r_queue.cmd<=gps_device100))
            {
                if(confun_data.workmode == WORKMODE_HANDLE)
                {
                    INT8U ide = r_queue.cmd-gps_device1;

if(setup_data.Parameter.value_struct.parameter.CtrDevices[ide].Enable)
                    {

if(setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrMode == 0)
                        {
                            confun_data.CtrDeviceValue[ide] = (r_queue.value==1)?1:0 ;                //0:关，1：开，2：停，3，无效
                            sendmessage_mq(mq_hmi, ide+device1, confun_data.CtrDeviceValue[ide]);
                            sendmessage_mq(mq_gprs, ide+device1, confun_data.CtrDeviceValue[ide]);
                            sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint1, confun_data.CtrDeviceValue[ide]);
                        }
                        else {
                            confun_data.CtrDeviceValue[ide] = r_queue.value ;                //0:关，1：开，2：停，3，无效
                            sendmessage_mq(mq_hmi, ide+device1, confun_data.CtrDeviceValue[ide]);
                            sendmessage_mq(mq_gprs, ide+device1, confun_data.CtrDeviceValue[ide]);
                            if(confun_data.CtrDeviceValue[ide]==0)
                            {
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint2, 0);
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint1, 0);
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint2, 1);
                            }
                            else if (confun_data.CtrDeviceValue[ide] == 1) {
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint1, 0);
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint2, 0);
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint1, 1);
                            }
                            else if (confun_data.CtrDeviceValue[ide] == 2) {
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint1, 0);
                                sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[ide].CtrPoint2, 0);
                            }
                        }
                    }
                }
            }
            else if (r_queue.cmd==IO_IN) {
                if(confun_data.workmode == WORKMODE_HANDLE)
                {
                    for(int i=0; i<100; i++)
                    {
                        if(setup_data.Parameter.value_struct.parameter.CtrDevices[i].Enable)
                        {
                            if(setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrMode==0)
                            {
                                if(r_queue.value == setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint1)
                                {
                                    if(confun_data.CtrDeviceValue[i]==0)
                                        confun_data.CtrDeviceValue[i] = 1;                //0:关，1：开，2：停，3，无效
                                    else
                                        confun_data.CtrDeviceValue[i] = 0;                //0:关，1：开，2：停，3，无效
                                    sendmessage_mq(mq_hmi, i+device1, confun_data.CtrDeviceValue[i]);
                                    sendmessage_mq(mq_gprs, i+device1, confun_data.CtrDeviceValue[i]);
                                    sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint1, confun_data.CtrDeviceValue[i]);
                                }
                            }
                            else if (setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrMode==1) {
                                if(r_queue.value == setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint1)
                                {
                                    confun_data.CtrDeviceValue[i] = 1 ;                //0:关，1：开，2：停，3，无效
                                    sendmessage_mq(mq_hmi, i+device1, confun_data.CtrDeviceValue[i]);
                                    sendmessage_mq(mq_gprs, i+device1, confun_data.CtrDeviceValue[i]);
                                    if(confun_data.CtrDeviceValue[i]==0)
                                    {
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint2, 0);
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint1, 0);
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint2, 1);
                                    }
                                    else if (confun_data.CtrDeviceValue[i] == 1) {
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint1, 0);
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint2, 0);
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint1, 1);
                                    }
                                    else if (confun_data.CtrDeviceValue[i] == 2) {
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint1, 0);
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint2, 0);
                                    }
                                }
                                else if (r_queue.value == setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint2) {
                                    confun_data.CtrDeviceValue[i] = 0 ;                //0:关，1：开，2：停，3，无效
                                    sendmessage_mq(mq_hmi, i+device1, confun_data.CtrDeviceValue[i]);
                                    sendmessage_mq(mq_gprs, i+device1, confun_data.CtrDeviceValue[i]);
                                    if(confun_data.CtrDeviceValue[i]==0)
                                    {
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint2, 0);
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint1, 0);
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint2, 1);
                                    }
                                    else if (confun_data.CtrDeviceValue[i] == 1) {
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint1, 0);
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint2, 0);
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint1, 1);
                                    }
                                    else if (confun_data.CtrDeviceValue[i] == 2) {
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint1, 0);
                                        sendmessage_mq(mq_relay, setup_data.Parameter.value_struct.parameter.CtrDevices[i].CtrPoint2, 0);
                                    }
                                }
                            }
                        }
                    }
                }
           }
            rt_thread_delay(100);
        }
    }
}
```

请登录后再发布评论，点击登录

追加回复

陈云鹏 2021-08-25

这家伙很懒，什么也没写！

问题已解决,可能就是内存不足引起的

```c
void gprs_thread_entry(void* parameter)
{
    rt_err_t ret = RT_EOK;
    char uart_name[RT_NAME_MAX];
    rt_err_t uwRet = RT_EOK;
    cmd_struct r_queue;
    INT8U reply_index;
    INT8U reply_buf[100];
    INT16U crc, i;

rt_strncpy(uart_name, parameter, RT_NAME_MAX);

/* 查找系统中的串口设备 */
    gprs_serial = rt_device_find(uart_name);
    if (!gprs_serial)
    {
        rt_kprintf("find %s failed!\n", uart_name);
        ret = RT_ERROR;
        return;
    }

gprs_data.gprs_buf.data_struct = gprs_ram_default;

/*初始化接收发送管脚*/
    rt_pin_mode(PIN_GPRS_RX, PIN_MODE_OUTPUT);
    rt_pin_write(PIN_GPRS_RX, 0);
//    rt_pin_mode(PIN_GPRS_PROTOCOL, PIN_MODE_INPUT);

gprs_timer = rt_timer_create("gprs_timer", gprs_timer_tick, 0, 30000, RT_TIMER_FLAG_ONE_SHOT);
    if(gprs_timer != RT_NULL)
    {
        rt_kprintf("\ngprs_timer create \n\n");

if((gprs_data.gprs_buf.data_struct.value_prop.value==1)||(gprs_data.gprs_buf.data_struct.value_prop.value==2))
            rt_timer_start(gprs_timer);
    }

/* 以中断接收及轮询发送模式打开串口设备 */
    rt_device_open(gprs_serial, RT_DEVICE_FLAG_INT_RX);

struct serial_configure config = RT_SERIAL_CONFIG_DEFAULT;
    //在打开串口设备之后对其参数进行修改
    config.baud_rate  =  BAUD_RATE_9600;
    if(RT_EOK != rt_device_control(gprs_serial, RT_DEVICE_CTRL_CONFIG, &config))
    {
         rt_kprintf("change %s failed!\n", uart_name);
    }

gprs_data.cmm_uart_rect = comm_rec_create(   0XFF,
                                                "gprs_tmr",
                                                300,
                                                (FUNC_COM_REC *)gprs_uart_rec,
                                                (FUNC_COM_REC_OK *)gprs_comm_ok,
                                                (FUNC_COM_REC_OK *)0);

/* 设置接收回调函数 */
    rt_device_set_rx_indicate(gprs_serial, gprs_uart_input);

//创建消息队列
    mq_gprs = rt_mq_create("mq_gprs", sizeof(cmd_struct), 100, RT_IPC_FLAG_FIFO);

rt_pin_mode(PIN_LED_GPRS, PIN_MODE_OUTPUT);
    rt_pin_write(PIN_LED_GPRS, 1);

for(i=0; i<sizeof(gprs_data.gprs_buf.data_buf)/sizeof(gprs_data.gprs_buf.data_buf[0]); i++)
    {
        gprs_data.gprs_buf.data_buf[i].index = i;
    }

while(1)
    {
        //获取队列信息
        uwRet = rt_mq_recv(mq_gprs, (void*)&r_queue, sizeof(cmd_struct), RT_WAITING_FOREVER);
        if(RT_EOK == uwRet)
        {
            rt_kprintf("=========================\n");
            rt_kprintf("mq_gprs receive msg:%d:%d\n", r_queue.cmd, r_queue.value);
            if(r_queue.cmd == set_value_refresh)
            {
                gprs_data.gprs_buf.data_struct.value_remoteCtrl.value = setup_data.Parameter.value_struct.RemoteCtrl;
                gprs_data.gprs_buf.data_struct.value_remoteCtrl.para_change = 1;
                gprs_data.gprs_buf.data_struct.value_addr.value = setup_data.Parameter.value_struct.Addr;
                gprs_data.gprs_buf.data_struct.value_addr.para_change = 1;
                gprs_data.gprs_buf.data_struct.value_MODE.value = setup_data.Parameter.value_struct.StartMode;
                gprs_data.gprs_buf.data_struct.value_addr.para_change = 1;
                gprs_data.gprs_buf.data_struct.value_prop.value = setup_data.Parameter.value_struct.gprsProp;
                gprs_data.gprs_buf.data_struct.value_prop.para_change = 1;
                gprs_data.gprs_buf.data_struct.value_type.value = setup_data.Parameter.value_struct.Type;
                gprs_data.gprs_buf.data_struct.value_type.para_change = 1;
                gprs_data.gprs_buf.data_struct.value_serial1.value = (setup_data.Parameter.value_struct.SerialID[1]<<8) + setup_data.Parameter.value_struct.SerialID[0];
                gprs_data.gprs_buf.data_struct.value_serial1.para_change = 1;
                gprs_data.gprs_buf.data_struct.value_serial2.value = (setup_data.Parameter.value_struct.SerialID[3]<<8) + setup_data.Parameter.value_struct.SerialID[2];
                gprs_data.gprs_buf.data_struct.value_serial2.para_change = 1;
                gprs_data.gprs_buf.data_struct.value_serial3.value = (setup_data.Parameter.value_struct.SerialID[5]<<8) + setup_data.Parameter.value_struct.SerialID[4];
                gprs_data.gprs_buf.data_struct.value_serial3.para_change = 1;
                gprs_data.gprs_buf.data_struct.value_serial4.value = (setup_data.Parameter.value_struct.SerialID[7]<<8) + setup_data.Parameter.value_struct.SerialID[6];
                gprs_data.gprs_buf.data_struct.value_serial4.para_change = 1;
                if((gprs_data.gprs_buf.data_struct.value_prop.value==1)||(gprs_data.gprs_buf.data_struct.value_prop.value==2))
                    rt_timer_start(gprs_timer);
            }
            else if (r_queue.cmd == sys_value_RemoteCtrl) {
                gprs_data.gprs_buf.data_struct.value_remoteCtrl.value = r_queue.value;
                gprs_data.gprs_buf.data_struct.value_remoteCtrl.para_change = 1;
            }
            else if (r_queue.cmd == sys_value_MODE) {
                gprs_data.gprs_buf.data_struct.value_MODE.value = r_queue.value;
                gprs_data.gprs_buf.data_struct.value_MODE.para_change = 1;
            }
            else if (r_queue.cmd == sys_value_serial1) {
                gprs_data.gprs_buf.data_struct.value_serial1.value = r_queue.value;
                gprs_data.gprs_buf.data_struct.value_serial1.para_change = 1;
            }
            else if (r_queue.cmd == sys_value_serial2) {
                gprs_data.gprs_buf.data_struct.value_serial2.value = r_queue.value;
                gprs_data.gprs_buf.data_struct.value_serial2.para_change = 1;
            }
            else if (r_queue.cmd == sys_value_serial3) {
                gprs_data.gprs_buf.data_struct.value_serial3.value = r_queue.value;
                gprs_data.gprs_buf.data_struct.value_serial3.para_change = 1;
            }
            else if (r_queue.cmd == sys_value_serial4) {
                gprs_data.gprs_buf.data_struct.value_serial4.value = r_queue.value;
                gprs_data.gprs_buf.data_struct.value_serial4.para_change = 1;
            }
            else if (r_queue.cmd == sys_value_addr) {
                gprs_data.gprs_buf.data_struct.value_addr.value = r_queue.value;
                gprs_data.gprs_buf.data_struct.value_addr.para_change = 1;
            }
            else if (r_queue.cmd == sys_value_type) {
                gprs_data.gprs_buf.data_struct.value_type.value = r_queue.value;
                gprs_data.gprs_buf.data_struct.value_type.para_change = 1;
            }
            else if (r_queue.cmd == sys_value_prop) {
                gprs_data.gprs_buf.data_struct.value_prop.value = r_queue.value;
                gprs_data.gprs_buf.data_struct.value_prop.para_change = 1;
            }
            else if((r_queue.cmd>=device1) && (r_queue.cmd<=device100))
            {
                gprs_data.gprs_buf.data_struct.DeviceList[r_queue.cmd-device1].value = r_queue.value;
                gprs_data.gprs_buf.data_struct.DeviceList[r_queue.cmd-device1].para_change = 1;
            }

for(INT8U i=0; i<(sizeof(gprs_ram_sturct)/sizeof(dataParastruct)); i++){
                if(gprs_data.gprs_buf.data_buf[i].para_change)
                {
                    gprs_data.gprs_buf.data_buf[i].para_change = 0;

reply_index = 0;
                    reply_buf[reply_index++] = 0xCA;
                    reply_buf[reply_index++] = 0xFE;
                    reply_buf[reply_index++] = 0x01;
                    reply_buf[reply_index++] = 0x05;
                    reply_buf[reply_index++] = 0x00;
                    reply_buf[reply_index++] = 0x02;
                    reply_buf[reply_index++] = gprs_data.gprs_buf.data_buf[i].index;
                    reply_buf[reply_index++] = gprs_data.gprs_buf.data_buf[i].value;
                    crc = N_CRC16(reply_buf, reply_index);
                    reply_buf[reply_index++] = (crc >> 8) & 0x00ff;
                    reply_buf[reply_index++] = (crc >> 0) & 0x00ff;

rt_pin_write(PIN_GPRS_RX, 1);
                    rt_device_write(gprs_serial, 0, reply_buf, reply_index);
                    rt_pin_write(PIN_GPRS_RX, 0);
                    if((gprs_data.gprs_buf.data_struct.value_prop.value==1)||(gprs_data.gprs_buf.data_struct.value_prop.value==2))
                        rt_timer_start(gprs_timer);

rt_thread_delay(300);
                }
            }

rt_thread_delay(100);
        }
        else
        {
            rt_kprintf("gprs_mq receive error!");
        }
    }
    ret = ret;
    return;

}
```