Revision 1f7ffcff src/urt_topic.c

View differences:

src/urt_topic.c
54 54 
 * @return  Returns URT_STATUS_OK on success.
55 55 
 *          Returns URT_STATUS_TOPIC_DUPLICATE if another topic with the same identifier already exists.
56 56 
 */
57 
urt_status_t urtTopicInit(urt_topic_t* topic, urt_topicid_t id) {return URT_STATUS_OK;}
57 
urt_status_t urtTopicInit(urt_topic_t* topic, urt_topicid_t id)
58 
{
59 
  urt_topic_t.next = NULL;
60 
  urt_topic_t.id = id;
61 
  //add later: urtmutexinit, urteventsourceinit
62 
  urt_topic_t.numHrtSubscribers = 0;
63 
  //add later: condvar, message init, latest message
64 
  #if (URT_CFG_PUBSUB_QOS_RATECHECKS)
65 
    urt_topic_t.hrtSubscribers = nullptr;
66 
    //add later: timer init;
67 
  #endif /* URT_CFG_PUBSUB_QOS_RATECHECKS */
68 
  #if (URT_CFG_PUBSUB_PROFILING)
69 
    urt_topic_t.numMessagesPublished = 0;
70 
    urt_topic_t.numMessagesDiscarded = 0;
71 
    urt_topic_t.numSubscribers = 0;
72 
  #endif /* URT_CFG_PUBSUB_PROFILING */
73 
  //add later: close circular message buffer,...
74 
  return URT_STATUS_OK;
75 
}

Also available in: Unified diff