reac_assm.h

 
#ifndef ASRT_REAC_ASSM_H
#define ASRT_REAC_ASSM_H
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include "./collect.h"
#include "./diag.h"
#include "./param.h"
#include "./reactor.h"
#include "./stream.h"
 
struct asrt_reac_assm
{
        struct asrt_send_req_list  send_queue;
        struct asrt_reactor        reactor;
        struct asrt_diag_client    diag;
        struct asrt_collect_client collect;
        uint8_t                    param_cache_buf[256];
        struct asrt_param_client   param;
        struct asrt_stream_client  stream;
};
 
enum asrt_status asrt_reac_assm_init(
    struct asrt_reac_assm* assembly,
    char const*            desc,
    uint32_t               timeout );
 
static inline void asrt_reac_assm_tick( struct asrt_reac_assm* assembly, uint32_t now )
{
        asrt_chann_tick_successors( &assembly->reactor.node, now );
}
 
void asrt_reac_assm_deinit( struct asrt_reac_assm* assembly );
 
#ifdef __cplusplus
}
#endif
 
#endif  // ASRT_REAC_ASSM_H