RT-Thread-[第二期空气质量分析仪]第3周作业RT-Thread问答社区

[第二期空气质量分析仪]第3周作业

发布于 2019-09-08 21:39:27 浏览：1042 订阅该版

[align=center]第三周实验：实现异步日志、整个系统跑起来[align=center]
本周是这次训练营最后一周，要求在上两周的基础上使用按键控制传感器数据的采集，LED告警，并且打印日志。

任务1：实现异步日志，这个任务主要是学习通过邮箱发送、接收邮件，实现线程之间的数据通信。该任务创建了一个mylog线程，在线程中例化了一个邮箱，主程序或其他线程通过调用函数mylog发送邮件（发送通讯数据），mylog_entry中持续监测邮箱状态，当有邮件到达时，取出邮件，并且打印显示。程序中的邮件实际是一个指向结构的指针（4字节）。代码如下。
#include <rtthread.h>
#include <rtdevice.h>
#include <board.h>

static rt_thread_t mylog_thread = RT_NULL;
static char mb_poll[32];
static struct rt_mailbox mb;

struct msg
{
  char *tag;
  rt_uint32_t dat;
};

static void mylog_entry(void *parameter)
{
  struct msg *msg_ptr;
  
  while (1) {
    if (rt_mb_recv(&mb, (rt_uint32_t*)&msg_ptr, RT_WAITING_FOREVER) == RT_EOK)
    {
      rt_kprintf("[%s] data is:%d<br>", msg_ptr->tag, msg_ptr->dat);
      rt_free(msg_ptr);
    }
  }
}

rt_err_t mylog(char *tag, rt_uint32_t data)
{
  struct msg *amsg;
  
  amsg = (struct msg *)rt_malloc(sizeof(struct msg));
  amsg->tag = tag;
  amsg->dat = data;
  rt_mb_send(&mb, (rt_uint32_t)amsg);
        return RT_EOK;
}

rt_thread_t mylog_init(void)
{
  rt_err_t result;
  result = rt_mb_init(&mb, "mylog", &mb_poll[0], sizeof(mb_poll)/4, RT_IPC_FLAG_FIFO);
  if (result != RT_EOK)
  {
    rt_kprintf("init mailbox failed. <br>");
    return RT_NULL;
  }
  
 // 帖子长度所限线程建立方式省略
  mylog_thread = rt_thread_create(.....)
}

任务2：系统跑起来（熟悉 IPC：事件集的使用）该任务分成三部分，首先修改之前的按键程序，增加模块使能标志；然后在LED显示程序中，建立一个进程，例化一个事件集，并且在entry中检查事件，当有事件到达时启动LED闪烁；最后在各个传感器进程中使用mylog代替之前的rt_kprint函数，当模块使能后，每隔一秒采集一次数据，当数据正常时，发送LED闪烁事件，当数据超限时发送异步日志。按键程序（此处只给出了温湿度传感器控制按键，PM2.5于此类似）：
rt_uint8_t en_thf;

// 初始化部分省略见之前作业.....

void key_cb_thf(void *args) 
{
  rt_pin_irq_enable(KEY_PIN_THF, PIN_IRQ_DISABLE);
  en_thf = ~en_thf;
  rt_kprintf("en_thf: %d<br>", en_thf);
  rt_pin_irq_enable(KEY_PIN_THF, PIN_IRQ_ENABLE);
}

LED线程程序：
void led_alert_entry(void *parameter)
{
  rt_uint32_t e;

while(1) {
    if (rt_event_recv(&led_event, (EVENT_FLAG_AM230X|EVENT_FLAG_PM2P5),
                      RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
                      RT_WAITING_FOREVER, &e) == RT_EOK)
    {
      if (e & EVENT_FLAG_AM230X) led_blink(LED_AM230X, 100, 3);
      if (e & EVENT_FLAG_PM2P5)  led_blink(LED_PM2P5, 100, 3);
    }
  }
}

void led_blink_note(rt_uint8_t led_type)
{
  if (led_type == LED_PM2P5)  rt_event_send(&led_event, EVENT_FLAG_PM2P5);
  if (led_type == LED_AM230X) rt_event_send(&led_event, EVENT_FLAG_AM230X);
}

rt_thread_t led_init(void)
{
  rt_event_init(&led_event, "led_event", RT_IPC_FLAG_FIFO);

// 帖子长度所限LED初始化、线程建立方式省略
  led_alert_thread = rt_thread_create(.......)
}

温湿度模块entry程序（线程创建见周二作业）：（PM2.5与此类似）
void temp_humi_entry(void *parameter)
{
  rt_uint16_t humidity, temperature;

while (1) {    
    if (en_thf == MODULE_ENABLE) {
      am230x_read_temp_humi(&temperature, &humidity);
      if ((temperature > TEMP_HIGH_LIMIT) || (humidity > HUMI_HIGH_LIMIT)) {
        led_on(LED_AM230X);
        if (temperature > TEMP_HIGH_LIMIT) mylog("Temp Alarm", (rt_uint32_t)temperature);
        if (humidity > HUMI_HIGH_LIMIT)    mylog("Humi Alarm", (rt_uint32_t)humidity);
      }
      else {
        led_blink_note(LED_AM230X);
      }
    }
    else
    {
      led_off(LED_AM230X);
    }
    rt_thread_mdelay(1000);    
  }
}

问题：在例化mylog时，rt_mb_init(&mb, "mylog", &mb_poll[0], sizeof(mb_poll)/4, RT_IPC_FLAG_FIFO);，其中size字段应该是4字节的倍数，开始调用时，没有除以4，导致程序运行一段时间就assert，修改后正常。