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

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

发布于 2019-10-31 20:47:52 浏览：758 订阅该版

任务 1：实现异步日志（熟悉 IPC：邮箱的使用）
使用邮箱，实现每个传感器数据使用异步打印数据。设立2个按键，通过按下不同按键，通过邮箱，向mylog任务发送各自对应的按键消息。通过这几周的学习，让我明白了rt-thread的更更多知识，此部分主要学习邮箱的使用，在 RT-Thread 中，邮箱控制块是操作系统用于管理邮箱的一个数据结构，由结构体 struct rt_mailbox 表示。另外一种 C 表达方式 rt_mailbox_t，表示的是邮箱的句柄，在 C 语言中的实现是邮箱控制块的指针。

#define THREAD_PRIORITY      10
#define THREAD_TIMESLICE     5

static struct rt_mailbox mb;
static char mb_pool[128];

static char mb_str1[] = "I'm a mail!";
static char mb_str2[] = "this is another mail!";

ALIGN(RT_ALIGN_SIZE)
static char thread1_stack[1024];
static struct rt_thread thread1;

static void mylog_entry(void *parameter)
{
     char *str;

while (1)
     {
        //rt_kprintf("try to recv a mail<br>");

/* 从邮箱中收取邮件 */
         if (rt_mb_recv(&mb, (rt_uint32_t *)&str, RT_WAITING_FOREVER) == RT_EOK)
        {
             rt_kprintf("%s<br>", str);
             rt_thread_mdelay(1000);
         }
     }
    /* 执行邮箱对象脱离 */
     rt_mb_detach(&mb);
}

ALIGN(RT_ALIGN_SIZE)
static char thread2_stack[1024];
 static struct rt_thread thread2;

static void mylog(void)
{
        //rt_mb_send(&mb, (rt_uint32_t)&mb_str1);
    rt_uint8_t count;

count = 0;
    while (count < 10000)
     {
        count ++;

rt_mb_send(&mb, (rt_uint32_t)&mb_str1);

rt_thread_mdelay(200);
     }

}

int mylog_init(void)
{
    rt_err_t result;

/* 初始化一个 mailbox */
     result = rt_mb_init(&mb,
                         "mbt",                      /* 名称是 mbt */
                              &mb_pool[0],                /*邮箱用到的内存池是 mb_pool */
                              sizeof(mb_pool) / 4,        /* 邮箱中的邮件数目,因为一封邮件占 4 字节 */
                         RT_IPC_FLAG_FIFO);          /* 采用 FIFO 方式进行线程等待 */
    if (result != RT_EOK)
     {
        rt_kprintf("init mailbox failed.<br>");
         return -1;
    }

rt_thread_init(&thread1,
                    "thread1",
                   mylog_entry,
                    RT_NULL,
                   &thread1_stack[0],
                    sizeof(thread1_stack),
                    THREAD_PRIORITY, THREAD_TIMESLICE);
    rt_thread_startup(&thread1);
    mylog();
    return 0;
}
任务 2：系统跑起来（熟悉 IPC：事件集的使用）
现在我们的系统还只是各个模块能运行，模块间没关联。现在要做的就是实现整个体统：每次系统中只有一种传感器模块在获取数据，每秒获取一次。key1 按下（奇数次），温湿度传感器开始读数据。
当数据正常时，在每秒的开始，闪烁两下，表示正常读取数据。当读取的数据超过设定的范围时，led 一直常亮，表示报警。key1 再次按下（偶数次），温湿度传感器停止读数据。led 熄灭。此部分主要为事件集的使用，在 RT-Thread 中，事件集控制块是操作系统用于管理事件的一个数据结构，由结构体 struct rt_event 表示。另外一种 C 表达方式 rt_event_t，表示的是事件集的句柄，在 C 语言中的实现是事件集控制块的指针。
while(1)

{

r_str = (MSG*)rt_malloc(sizeof(MSG));/* 等待接邮箱消息 */

uwRet = rt_mb_recv(&mb, /* 邮箱对象句柄 */

(rt_uint32_t*)&r_str, /* 接收邮箱消息 */
RT_WAITING_FOREVER);/* 指定超时事件,一直等 */
if(RT_EOK == uwRet) /* 如果接收完成并且正确 */
{
if(strcmp(r_str->str, "Temp")==0)
 {
 if(r_str->sensor > 25)
{
 alarm_led_blink(led1);

}
else
{
 alarm_led_on(led1);
 }
 }
else if(strcmp(r_str->str, "Humi")==0)
{
if(r_str->sensor > 50)
{
alarm_led_blink(led2);
}
else
{
 alarm_led_on(led2);
}
}
 else if(strcmp(r_str->str, "PM2.5")==0)
{
if(r_str->sensor > 300)
{
 alarm_led_blink(led3);
 }
else
 {
 alarm_led_on(led2);
}
}
else
rt_kprintf ( "mbox err code 0x%x  <br>",uwRet);
rt_free(r_str);
 rt_thread_delay(500);     //每20ms扫描一次        
}