sys_sx1278.c 483 B

12345678910111213141516171819
  1. #include "sys_sx1278.h"
  2. #include "json_queue.h"
  3. #include "sys_mqtt.h"
  4. #include "malloc.h"
  5. //sx1278发送线程,其可能存在两处数据源,即轮询发送的采集信息,一个是mqtt下发的数据源,从队列中读取出数据
  6. void sx1278_send_task(void *pdata)
  7. {
  8. uint8_t err;
  9. StringInfo *message=NULL; //接收队列消息结构体
  10. int length;
  11. while(1)
  12. {
  13. message=(StringInfo *)OSQPend(JsonQ,1000,&err);
  14. length=message->stringLength;
  15. printf("sx1278_task_recv : %s",message->p);
  16. myfree(SRAMEX ,message->p);
  17. }
  18. }