collect.h

 
#ifndef ASRTC_COLLECT_SERVER_H
#define ASRTC_COLLECT_SERVER_H
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include "../asrtl/allocator.h"
#include "../asrtl/chann.h"
#include "../asrtl/collect_proto.h"
#include "../asrtl/flat_tree.h"
#include "../asrtl/status.h"
 
typedef void ( *asrt_collect_ready_ack_cb )( void* ptr, enum asrt_status status );
 
enum asrt_collect_server_state
{
        ASRT_COLLECT_SERVER_IDLE = 0,
        ASRT_COLLECT_SERVER_READY_SENT,
        ASRT_COLLECT_SERVER_READY_ACK_RECV,
        ASRT_COLLECT_SERVER_ACTIVE,
};
 
struct asrt_collect_ready_data
{
        asrt_flat_id              root_id;
        asrt_collect_ready_ack_cb ack_cb;
        void*                     ack_cb_ptr;
        uint32_t                  timeout;
        uint32_t                  deadline;
};
 
struct asrt_collect_server
{
        struct asrt_node node;
 
        struct asrt_u8d2msg err_msg;
        struct asrt_u8d9msg ready_msg;
 
        struct asrt_allocator alloc;
        struct asrt_flat_tree tree;
        uint32_t              tree_block_cap;
        uint32_t              tree_node_cap;
 
        enum asrt_collect_server_state state;
        asrt_flat_id                   next_node_id;
 
        struct asrt_collect_ready_data cmd;
};
 
enum asrt_status asrt_collect_server_init(
    struct asrt_collect_server* server,
    struct asrt_node*           prev,
    struct asrt_allocator       alloc,
    uint32_t                    tree_block_cap,
    uint32_t                    tree_node_cap );
 
enum asrt_status asrt_collect_server_send_ready(
    struct asrt_collect_server* server,
    asrt_flat_id                root_id,
    uint32_t                    timeout,
    asrt_collect_ready_ack_cb   ack_cb,
    void*                       ack_cb_ptr );
 
struct asrt_flat_tree const* asrt_collect_server_tree( struct asrt_collect_server const* server );
 
void asrt_collect_server_deinit( struct asrt_collect_server* server );
 
#ifdef __cplusplus
}
#endif
 
#endif  // ASRT_COLLECT_SERVER_H