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

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

发布于 2019-09-13 14:11:07 浏览：1128 订阅该版

接下来便是完善异步通信IPC实验。在part1的实验基础上，在main中创建了一个mylog任务，当然也可以输出添加到rtt中（等完成这周任务再说吧，因为这周的任务都压到今天完成了，时间有些紧哦，还得过节啊:dizzy:），再mylog中等待申请消息；然后在温湿度和pm2.5任务中添加系统函数用于消息邮箱的发送，现在总结如下。
          1. mylog任务
               1.1   mylog任务的主体                
```static void mylog_thread_entry(void* parameter)
{		
        rt_err_t uwRet = RT_EOK;
        MSG*  r_str;
	
       /* 任务都是一个无限循环，不能返回 */
       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) /* 如果接收完成并且正确 */
              {
                         rt_kprintf ( "[%s] data is %d  <br>",r_str->str, r_str->sensor);		
               }
               else
                           rt_kprintf ( "mbox err code 0x%x  <br>",uwRet);
<div>
</div><div>             rt_free(r_str);
</div>             rt_thread_delay(20);     //每20ms扫描一次	
       }
}```

1.2   在main中创建mylog任务
```int main(void)
{ 
      int err;
      rt_err_t mberr;
  
      /* alarm led init */
      alarm_led_init();
      /* alarm beep init */
       alarm_beep_init();
		 
       err = temp_humi_init_th();            // 创建温湿度任务
 
       err = gp2y1014au_init_th1();       // 创建pm2.5任务
	
        mberr = rt_mb_init(&mb, "mb_log", /* 邮箱名字 */
                      &mb_pool[0],      sizeof(mb_pool)/4  , /* 邮箱大小 */
                      RT_IPC_FLAG_FIFO);/* 信号量模式 FIFO(0x00)*/
<div>       </div><div>        if (mberr != RT_NULL)
</div>                   rt_kprintf("create mbox is ok!  <br>");
	
        mylog_thread =                          /* 线程控制块指针 */
                   rt_thread_create( "mylog",              /* 线程名字 */
                   mylog_thread_entry,   /* 线程入口函数 */
                   RT_NULL,             /* 线程入口函数参数 */
                   512,                 /* 线程栈大小 */
                   3,                   /* 线程的优先级 */
                    20);                 /* 线程时间片 */
                   
         /* 启动线程，开启调度 */
         if (mylog_thread != RT_NULL)
                 rt_thread_startup(mylog_thread);
         else
                  return -1;

return RT_EOK;
}```           2.   温湿度数据的发送
```    while (1)
    {
           rt_thread_delay(20);   //  添加了一个系统延时，用于消除上电运行时系统会输出温/湿度为0，见下图1所示。
			
           res = rt_device_read(dev, 0, &sensor_data, 1);
            if (res != 1)
            {
                   rt_kprintf("read data failed! result is %d<br>", res);
                   rt_device_close(dev);
                   return;
            }
           else
           {
                    if (sensor_data.data.temp >= 0)
                    {
                              msgTemp = (MSG*)rt_malloc(sizeof(MSG));
                              msgTemp->sensor = (sensor_data.data.temp & 0xffff) >> 0;      // get temp
                              strcpy(msgTemp->str,"Temp");
<div>                             </div><div>                              uwRet = rt_mb_send(&mb,(rt_uint32_t)msgTemp); 
</div>                              //									if(RT_EOK == uwRet)
                                        //											rt_kprintf ( "Temp mbox is ok<br>" );
                              //									else
                                        //											rt_kprintf ( "Temp mbox is not ok<br>" );		
									
                             rt_thread_delay(20);
									
                             msgTemp->sensor = (sensor_data.data.temp & 0xffff0000) >> 16; // get humi
                             strcpy(msgTemp->str,"Humi");
<div>                           </div><div>                             uwRet = rt_mb_send(&mb,(rt_uint32_t)msgTemp); 
</div>                             //									if(RT_EOK == uwRet)
                                        //											rt_kprintf ( "Humi mbox is ok<br>" );
                             //									else
                                      //											rt_kprintf ( "Humi mbox is not ok<br>" );
									
                            //									rt_free(msgTemp);
									
                       }
              }
				
             rt_thread_delay(1000);
    }```[align=center]![输出.png](/uploads/201909/13/135816ehem6jzibh8aa8t5.png)
图1    上电时会输出温/湿度为0[align=center]![改进输出.png](/uploads/201909/13/135856qy2jbkbcbjsdsj2j.png)[align=center]图2 改进后的输出效果         3. PM2.5数据的发送```while(1)
		{					
          /* 使能设备 */
          rt_adc_enable(adc_dev, ADC_DEV_CHANNEL);
	 
          rt_pin_write(LED_DATA_PIN, PIN_LOW);
          rt_hw_us_delay(280);               /* 采样时间 280us */

value = rt_adc_read(adc_dev, ADC_DEV_CHANNEL);		 /* 读取AD的值 */
		
          rt_hw_us_delay(40);                /* 测量完后脉冲保持时间 40us */
		
          rt_pin_write(LED_DATA_PIN, PIN_HIGH);
		
          rt_hw_us_delay(9680);                /* LED脉冲周期 10ms。 此处为了凑LED脉冲周期，以防止连续读值时，周期无法满足 */ 
				
          /* 关闭通道 */
          err = rt_adc_disable(adc_dev, ADC_DEV_CHANNEL);
			
          rt_thread_delay(20);        // 添加后，会消除一个错误，见下图3所示
			
          msgPM25 = (MSG*)rt_malloc(sizeof(MSG));
          msgPM25->sensor = (int)(0.17*value-0.1);      // get PM2.5 value
          strcpy(msgPM25->str,"PM2.5");

uwRet = rt_mb_send(&mb,(rt_uint32_t)msgPM25);

//				if(RT_EOK == uwRet)
                  //						rt_kprintf ( "PM2.5 mbox is ok<br>" );
          //				else
                  //						rt_kprintf ( "PM2.5 mbox is not ok<br>" );		
									
         //				rt_free(msgPM25);
         rt_thread_delay(1500);
		}```[align=center]![PM通信问题.png](/uploads/201909/13/140326zfpidwqbxpw3qip5.png)[align=center]图3     有问题的PM2.5 输出             4. 留存的问题。在温湿度和PM2.5任务中，使用消息邮箱通信时，为了发送消息，故此使用malloc动态开辟了一段内存区，按理说使用完毕后应该是使用free释放掉的，但是当添加free语句后会报如下图4的错误（不使用free语句，系统运行正确。当然没有测试系统一直运行会不会出现内存溢出等现象，等有时间了可以测一下:lol），一直还么可有搞明白。[align=center]![遗留问题.png](/uploads/201909/13/140929gh3q5i8wizr2dv6i.png)[align=center]图4  遗留问题