Revision 5c6cb22f inc/urt_subscriber.h

View differences:

inc/urt_subscriber.h
22 22 
#ifndef URTWARE_SUBSCRIBER_H
23 23 
#define URTWARE_SUBSCRIBER_H
24 24 

  		




  25
  
  
    
#include <urt_types.h>


  		




  26
  25
  
    
#include <urtware.h>


  		




  27
  26
  
    

  		




  28
  27
  
    
/******************************************************************************/


  		




  ......




  70
  69
  
    
}urt_nrtsubscriber_t;


  		




  71
  70
  
    

  		




  72
  71
  
    
/**


  		




  73
  
  
    
 * @brief  nrt subscriber


  		




  
  72
  
    
 * @brief  srt subscriber


  		




  74
  73
  
    
 */


  		




  75
  74
  
    
typedef struct urt_srtsubscriber


  		




  76
  75
  
    
{


  		




  77
  76
  
    
  urt_basesubscriber_t base;


  		




  78
  
  
    
  urt_srtusefulnessfunc_t* usefulnesscb;


  		




  
  77
  
    
  void* cbparams;


  		




  
  78
  
    
  urt_usefulness_f* usefulnesscb;


  		




  79
  79
  
    
  #if (URT_CFG_PUBSUB_PROFILING)


  		




  80
  80
  
    
    urt_delay_t minLatency;


  		




  81
  81
  
    
    urt_delay_t maxLatency;


  		




  ......




  83
  83
  
    
}urt_srtsubscriber_t;


  		




  84
  84
  
    

  		




  85
  85
  
    
/**


  		




  86
  
  
    
 * @brief  nrt subscriber


  		




  
  86
  
    
 * @brief  frt subscriber


  		




  87
  87
  
    
 */


  		




  88
  88
  
    
typedef struct urt_frtsubscriber


  		




  89
  89
  
    
{


  		




  ......




  106
  106
  
    
typedef struct urt_hrtsubscriber


  		




  107
  107
  
    
{


  		




  108
  108
  
    
  urt_basesubscriber_t base;


  		




  109
  
  
    
  urt_hrtsubscriber_t* next;


  		




  
  109
  
    
  struct urt_hrtsubscriber* next;


  		




  110
  110
  
    
  #if (URT_CFG_PUBSUB_QOS_DEADLINECHECKS)


  		




  111
  111
  
    
    urt_delay_t deadlineOffset;


  		




  112
  112
  
    
    urt_osTimer_t qosDeadlineTimer;


  		




  ......




  142
  142
  
    
  urt_status_t urtNrtSubscriberUnsubscribe(urt_nrtsubscriber_t* subscriber);


  		




  143
  143
  
    

  		




  144
  144
  
    
  void urtSrtSubscriberInit(urt_srtsubscriber_t* subscriber);


  		




  145
  
  
    
  urt_status_t urtSrtSubscriberSubscribe(urt_srtsubscriber_t* subscriber, urt_topic_t* topic, urt_message_t* message, urt_srtusefulnessfunc_t* usefulnesscb, void* cbparams);


  		




  
  145
  
    
  urt_status_t urtSrtSubscriberSubscribe(urt_srtsubscriber_t* subscriber, urt_topic_t* topic, urt_message_t* message, urt_usefulness_f* usefulnesscb, void* cbparams);


  		




  146
  146
  
    
  urt_status_t urtSrtSubscriberFetchNextMessage(urt_srtsubscriber_t* subscriber, void* payload, size_t bytes, urt_delay_t* latency);


  		




  147
  147
  
    
  urt_status_t urtSrtSubscriberFetchLatestMessage(urt_srtsubscriber_t* subscriber, void* payload, size_t bytes, urt_delay_t* latency);


  		




  148
  148
  
    
  float urtSrtSubscriberCalculateUsefulness(urt_srtsubscriber_t* subscriber, urt_delay_t latency);


  		




  ......




  160
  160
  
    
  urt_status_t urtHrtSubscriberFetchNextMessage(urt_hrtsubscriber_t* subscriber, void* payload, size_t bytes, urt_delay_t* latency);


  		




  161
  161
  
    
  urt_status_t urtHrtSubscriberFetchLatestMessage(urt_hrtsubscriber_t* subscriber, void* payload, size_t bytes, urt_delay_t* latency);


  		




  162
  162
  
    
  urt_status_t urtHrtSubscriberUnsubscribe(urt_hrtsubscriber_t* subscriber);


  		




  163
  
  
    

  		




  164
  
  
    
  float urt_srtusefulnessfunc_t (urt_delay_t dt, void* params);


  		




  165
  163
  
    
#if defined(__cplusplus)


  		




  166
  164
  
    
}


  		




  167
  165
  
    
#endif /* defined(__cplusplus) */


  		












Also available in:  Unified diff