stream.h

 
#ifndef ASRTC_STREAM_H
#define ASRTC_STREAM_H
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include "../asrtl/allocator.h"
#include "../asrtl/chann.h"
#include "../asrtl/stream_proto.h"
 
#include <stdint.h>
 
#define ASRT_STREAM_MAX_SCHEMAS 255
 
struct asrt_stream_schema
{
        uint8_t                      schema_id;    
        uint8_t                      field_count;  
        uint16_t                     record_size;  
        enum asrt_strm_field_type_e* fields;       
        struct asrt_stream_record*   first;        
        struct asrt_stream_record*   last;         
        uint32_t                     count;        
};
 
struct asrt_stream_record
{
        struct asrt_stream_record* next;
        uint8_t*                   data;  
};
 
struct asrt_stream_schemas
{
        struct asrt_stream_schema* schemas;       
        uint32_t                   schema_count;  
        struct asrt_allocator      alloc;         
};
 
struct asrt_stream_server
{
        struct asrt_node      node;
        struct asrt_u8d2msg   err_msg;
        struct asrt_allocator alloc;
 
        struct asrt_stream_schema* lookup[ASRT_STREAM_MAX_SCHEMAS];  
};
 
enum asrt_status asrt_stream_server_init(
    struct asrt_stream_server* server,
    struct asrt_node*          prev,
    struct asrt_allocator      alloc );
 
struct asrt_stream_schemas asrt_stream_server_take( struct asrt_stream_server* server );
 
void asrt_stream_schemas_free( struct asrt_stream_schemas* schemas );
 
void asrt_stream_server_clear( struct asrt_stream_server* server );
 
void asrt_stream_server_deinit( struct asrt_stream_server* server );
 
#ifdef __cplusplus
}
#endif
 
#endif  // ASRT_STREAM_H