_topic.h

Go to the documentation of this file.

 
// ALLOW FORMATTING
#ifndef PRIVATETOPIC_H
#define PRIVATETOPIC_H
 
#include "topic.h"
 
#include "stdbool.h"
 
#define WAIT_COMMENT xQueueReceive

#define DECLARE_TOPIC(topic)                                 \
  PrivateTopic topic;                                        \
  extern const SubInbox_t __##topic##_subscriptions_start[]; \
  extern const SubInbox_t __##topic##_subscriptions_end[];

#define INIT_TOPIC(topic, commentInboxSize, messageSize)                                    \
  topic.public.commentInbox = xQueueCreate(commentInboxSize, messageSize);                  \
  if (topic.public.commentInbox == NULL)                                                    \
    while (1);                                                                              \
  topic.subscriptions    = __##topic##_subscriptions_start;                                 \
  topic.numSubscriptions = __##topic##_subscriptions_end - __##topic##_subscriptions_start;

#define CREATE_TOPIC(topic, commentInboxSize, messageSize) \
  DECLARE_TOPIC(topic)                                     \
  __attribute__((constructor)) static void startTopic() {  \
    INIT_TOPIC(topic, commentInboxSize, messageSize)       \
  }

typedef struct PrivateTopic {
  Topic public;                    
  const SubInbox_t *subscriptions; 
  size_t numSubscriptions;         
} PrivateTopic;
 
bool Topic_publish(PrivateTopic *topic, uint8_t *article);
 
#endif