mip_parser.h

Go to the documentation of this file.

#pragma once
 
#include "mip_packet.h"
#include "mip_offsets.h"
 
#include "mip_types.h"
 
#ifdef __cplusplus
namespace mip {
namespace C {
extern "C" {
#endif
 
 
 
 
 
typedef bool (*mip_packet_callback)(void* user, const mip_packet_view* packet, mip_timestamp timestamp);
 
 
typedef struct mip_parser
{
    mip_timestamp       _start_time;                       
    mip_timeout         _timeout;                          
 
    mip_packet_callback _callback;                         
    void*               _callback_object;                  
 
#ifdef MIP_ENABLE_DIAGNOSTICS
    uint32_t            _diag_bytes_read;                  
    uint32_t            _diag_bytes_skipped;               
    uint32_t            _diag_packet_bytes;                
    uint32_t            _diag_valid_packets;               
    uint32_t            _diag_invalid_packets;             
    uint32_t            _diag_timeouts;                    
#endif // MIP_ENABLE_DIAGNOSTICS
 
    uint16_t            _buffered_length;                  
    uint8_t             _buffer[MIP_PACKET_LENGTH_MAX];    
 
} mip_parser;
 
 
 
#define MIP_PARSER_DEFAULT_TIMEOUT_MS 100  
 
 
void mip_parser_init(mip_parser* parser, mip_packet_callback callback, void* callback_object, mip_timeout timeout);
size_t mip_parser_parse(mip_parser* parser, const uint8_t* input_buffer, size_t input_length, mip_timestamp timestamp);
void mip_parser_flush(mip_parser* parser);
 
void mip_parser_reset(mip_parser* parser);
 
uint_least16_t mip_parser_get_write_ptr(mip_parser* parser, uint8_t** ptr_out);
 
//
// Accessors
//
 
mip_timeout mip_parser_timeout(const mip_parser* parser);
void mip_parser_set_timeout(mip_parser* parser, mip_timeout timeout);
 
void mip_parser_set_callback(mip_parser* parser, mip_packet_callback callback, void* callback_object);
mip_packet_callback mip_parser_callback(const mip_parser* parser);
void* mip_parser_callback_object(const mip_parser* parser);
 
mip_timestamp mip_parser_current_timestamp(const mip_parser* parser);
 
 
//
// Diagnostics
//
 
#ifdef MIP_ENABLE_DIAGNOSTICS
 
uint32_t mip_parser_diagnostic_bytes_read(const mip_parser* parser);
uint32_t mip_parser_diagnostic_bytes_skipped(const mip_parser* parser);
uint32_t mip_parser_diagnostic_packet_bytes(const mip_parser* parser);
 
uint32_t mip_parser_diagnostic_valid_packets(const mip_parser* parser);
uint32_t mip_parser_diagnostic_invalid_packets(const mip_parser* parser);
uint32_t mip_parser_diagnostic_timeouts(const mip_parser* parser);
 
#endif // MIP_ENABLE_DIAGNOSTICS
 
 
//
// Misc
//
 
mip_timeout mip_timeout_from_baudrate(uint32_t baudrate);
 
 
#ifdef __cplusplus
} // extern "C"
} // namespace C
} // namespace mip
#endif