stream.h

 
#ifndef ASRT_STREAM_H
#define ASRT_STREAM_H
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include "../asrtl/chann.h"
#include "../asrtl/stream_proto.h"
 
#include <stdint.h>
 
typedef void ( *asrt_stream_done_cb )( void* ptr, enum asrt_status status );
 
 
struct asrt_stream_pending_define
{
        uint8_t                            schema_id;
        uint8_t                            field_count;
        enum asrt_strm_field_type_e const* fields;
};
 
struct asrt_stream_pending_done
{
        enum asrt_status send_status;
};
 
enum asrt_stream_client_state
{
        ASRT_STRM_IDLE        = 0,
        ASRT_STRM_DEFINE_SEND = 1,  
        ASRT_STRM_WAIT        = 2,  
        ASRT_STRM_DONE        = 3,  
        ASRT_STRM_ERROR       = 4,  
};
 
struct asrt_stream_client
{
        struct asrt_node node;
 
        enum asrt_stream_client_state state;
        enum asrt_strm_err_e          err_code;  
 
        asrt_stream_done_cb done_cb;      
        void*               done_cb_ptr;  
 
        struct asrt_strm_define_msg define_msg;
        struct asrt_strm_data_msg   data_msg;
 
        union
        {
                struct asrt_stream_pending_define define;
                struct asrt_stream_pending_done   done;
        } op;
};
 
enum asrt_status asrt_stream_client_init(
    struct asrt_stream_client* client,
    struct asrt_node*          prev );
 
void asrt_stream_client_deinit( struct asrt_stream_client* client );
 
enum asrt_status asrt_stream_client_define(
    struct asrt_stream_client*         client,
    uint8_t                            schema_id,
    enum asrt_strm_field_type_e const* fields,
    uint8_t                            field_count,
    asrt_stream_done_cb                done_cb,
    void*                              done_cb_ptr );
 
enum asrt_status asrt_stream_client_emit(
    struct asrt_stream_client* client,
    uint8_t                    schema_id,
    uint8_t const*             data,
    uint16_t                   data_size,
    asrt_stream_done_cb        done_cb,
    void*                      done_cb_ptr );
 
enum asrt_status asrt_stream_client_reset( struct asrt_stream_client* client );
 
#ifdef __cplusplus
}
#endif
 
#endif  // ASRT_STREAM_H