topic.h

Go to the documentation of this file.

 
// ALLOW FORMATTING
#ifndef TOPIC_H
#define TOPIC_H
 
#include "FreeRTOS.h"
#include "queue.h"
 
#include "stdbool.h"
 
#define WAIT_ARTICLE xQueueReceive
 
typedef QueueHandle_t SubInbox_t;
typedef QueueHandle_t PubInbox_t;

typedef struct {
  uint8_t length;
  uint8_t data[];
} Message;

#define SUBSCRIBE_TOPIC(topic, inbox, length, size)                      \
  SubInbox_t __attribute__((section("." #topic "_subscription"))) inbox; \
  inbox = xQueueCreate(length, size);

#define CREATE_MESSAGE(name, length_) \
  struct {                            \
    uint8_t length;                   \
    uint8_t data[length_];            \
  } name = {.length = length_};

typedef struct PublicTopic {
  PubInbox_t commentInbox; 
} Topic;
 
bool Topic_comment(Topic *topic, uint8_t *comment);
 
#endif