AMiRo-OS

#include "subscriber.h"

void urtNrtSubscriberInit (urt_nrtsubscriber_t* subscriber) {}

urt_status_t urtNrtSubscriberSubscribe (urt_nrtsubscriber_t* subscriber, urt_topic_t* topic, urt_message_t* messages) {

  return 0;

}

urt_status_t urtNrtSubscriberFetchNextMessage (urt_nrtsubscriber_t* subscriber, void* payload, size_t bytes, urt_delay_t* latency) {

  return 0;

}

urt_status_t urtNrtSubscriberFetchLatestMessage (urt_nrtsubscriber_t* subscriber, void* payload, size_t bytes, urt_delay_t* latency) {

  return 0;

}

urt_status_t urtNrtSubscriberUnsubscribe (urt_nrtsubscriber_t* subscriber) {

  return 0;

}

int main () {

 return 0;

}

#ifndef SUBSCRIBER_H_

#define SUBSCRIBER_H_

#define URT_CFG_PUBSUB_PROFILING 0

// Base subscriber which is included in each specialised subscriber

struct urt_basesubscriber_t {

  urt_topic_t *topic;

  urt_osEventListener_t evtListener;

  urt_message_t *lastMessage;

  urt_osTime_t lastMessageTime;

  #if (URT_CFG_PUBSUB_PROFILING)

    uint64_t sumLatencies;

    uint64_t numMessagesReceived;

  #endif /* URT_CFG_PUBSUB_PROFILING */

};

struct urt_nrtsubscriber_t {

  struct urt_basesubscriber_t base;

  #if (URT_CFG_PUBSUB_PROFILING)

    urt_delay_t minLatency;

    urt_delay_t maxLatency;

  #endif /* URT_CFG_PUBSUB_PROFILING */

};

#endif /* SUBSCRIBER_H_ */