param.h

 
#ifndef ASRTC_PARAM_SERVER_H
#define ASRTC_PARAM_SERVER_H
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include "../asrtl/allocator.h"
#include "../asrtl/chann.h"
#include "../asrtl/flat_tree.h"
#include "../asrtl/param_proto.h"
 
typedef void ( *asrt_param_ready_ack_cb )( void* ptr, enum asrt_status status );
 
enum asrt_param_server_pending
{
        ASRT_PARAM_SERVER_PENDING_NONE = 0,   
        ASRT_PARAM_SERVER_PENDING_READY_ACK,  
        ASRT_PARAM_SERVER_PENDING_QUERY,      
};
 
struct asrt_param_server
{
        struct asrt_node     node;
        struct asrt_u8d6msg  find_by_key_err_msg;
        struct asrt_u8d6msg  query_err_msg;
        struct asrt_send_req query_msg;
        struct asrt_u8d5msg  ready_msg;
 
        struct asrt_flat_tree const*   tree;  // non-owning; must outlive each test
        struct asrt_allocator          alloc;
        uint32_t                       max_msg_size;
        int                            ack_received;
        uint8_t*                       enc_buff;  // allocated on READY_ACK tick, freed on deinit
        enum asrt_param_server_pending pending;
        union
        {
                uint32_t     max_msg_size;
                asrt_flat_id node_id;
        } pending_data;
        asrt_param_ready_ack_cb ack_cb;
        void*                   ack_cb_ptr;
        uint32_t                timeout;
        uint32_t                deadline;
};
 
enum asrt_status asrt_param_server_init(
    struct asrt_param_server* param,
    struct asrt_node*         prev,
    struct asrt_allocator     alloc );
 
void asrt_param_server_set_tree(
    struct asrt_param_server*    param,
    struct asrt_flat_tree const* tree );
 
enum asrt_status asrt_param_server_send_ready(
    struct asrt_param_server* param,
    asrt_flat_id              root_id,
    uint32_t                  timeout,
    asrt_param_ready_ack_cb   ack_cb,
    void*                     ack_cb_ptr );
 
void asrt_param_server_deinit( struct asrt_param_server* param );
 
#ifdef __cplusplus
}
#endif
 
#endif  // ASRT_PARAM_SERVER_H