Revision 017b2ac7
| inc/urt_node.h | ||
|---|---|---|
| 61 | 61 |
#endif /* URT_CFG_PUBSUB_PROFILING || URT_CFG_RPC_PROFILING */ |
| 62 | 62 |
}urt_node_t; |
| 63 | 63 |
|
| 64 |
|
|
| 65 |
/** |
|
| 66 |
* @brief |
|
| 67 |
* |
|
| 68 |
* @param[in] node . |
|
| 69 |
* @param[in] cause . |
|
| 70 |
* @param[in] arg . |
|
| 71 |
* |
|
| 72 |
* @return . |
|
| 73 |
* |
|
| 74 |
*/ |
|
| 75 |
typedef void (*urt_nodeShutdownCallback_t)(urt_node_t* node, urt_status_t cause, void* arg); |
|
| 76 |
|
|
| 77 |
|
|
| 78 |
/** |
|
| 79 |
* @brief |
|
| 80 |
* |
|
| 81 |
* @param[in] node . |
|
| 82 |
* @param[in] arg . |
|
| 83 |
* |
|
| 84 |
* @return . |
|
| 85 |
* |
|
| 86 |
*/ |
|
| 87 |
typedef urt_osEventMask_t (*urt_nodeSetupCallback_t)(urt_node_t* node, void* arg); |
|
| 88 |
|
|
| 89 |
|
|
| 90 |
/** |
|
| 91 |
* @brief |
|
| 92 |
* |
|
| 93 |
* @param[in] node . |
|
| 94 |
* @param[in] events . |
|
| 95 |
* @param[in] arg . |
|
| 96 |
* |
|
| 97 |
* @return . |
|
| 98 |
*/ |
|
| 99 |
typedef urt_osEventMask_t (*urt_nodeLoopCallback_t)(urt_node_t* node, urt_osEventMask_t events, void* arg); |
|
| 100 |
|
|
| 64 | 101 |
/******************************************************************************/ |
| 65 | 102 |
/* MACROS */ |
| 66 | 103 |
/******************************************************************************/ |
| inc/urt_service.h | ||
|---|---|---|
| 73 | 73 |
|
| 74 | 74 |
urt_status_t urtServiceInit(urt_service_t* service, urt_serviceid_t id, urt_servicefunc_t* callback); |
| 75 | 75 |
urt_status_t urtServiceCall(urt_service_t* service, void* arg, void* ret, urt_delay_t timeout); |
| 76 |
|
|
| 77 |
urt_status_t urt_servicefunc_t(void* arg, void* ret, urt_delay_t timeout); |
|
| 76 | 78 |
#if defined(__cplusplus) |
| 77 | 79 |
} |
| 78 | 80 |
#endif /* defined(__cplusplus) */ |
| inc/urt_subscriber.h | ||
|---|---|---|
| 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); |
|
| 163 | 165 |
#if defined(__cplusplus) |
| 164 | 166 |
} |
| 165 | 167 |
#endif /* defined(__cplusplus) */ |
Also available in: Unified diff