mip_parser.hpp

Go to the documentation of this file.

#pragma once
 
#include "mip_packet.hpp"
 
#include <mip/mip_parser.h>
 
 
namespace mip
{
 
class Parser : public C::mip_parser
{
public:
    Parser(uint8_t* buffer, size_t bufferSize, C::mip_packet_callback callback, void* callbackObject, Timeout timeout) { C::mip_parser_init(this, buffer, bufferSize, callback, callbackObject, timeout); }
    Parser(uint8_t* buffer, size_t bufferSize, bool (*callback)(void*,const PacketView*,Timestamp), void* callbackObject, Timeout timeout) { C::mip_parser_init(this, buffer, bufferSize, (C::mip_packet_callback)callback, callbackObject, timeout); }
 
    Parser(uint8_t* buffer, size_t bufferSize, Timeout timeout) { C::mip_parser_init(this, buffer, bufferSize, nullptr, nullptr, timeout); }
 
    template<class T, bool (T::*Callback)(const PacketView&, Timestamp)>
    void setCallback(T& object);
 
    void reset() { C::mip_parser_reset(this); }
 
    size_t parse(const uint8_t* inputBuffer, size_t inputCount, Timestamp timestamp, unsigned int maxPackets=0) { return C::mip_parser_parse(this, inputBuffer, inputCount, timestamp, maxPackets); }
 
    Timeout timeout() const { return C::mip_parser_timeout(this); }
    void setTimeout(Timeout timeout) { return C::mip_parser_set_timeout(this, timeout); }
};
 
 
template<class T, bool (T::*Callback)(const PacketView&, Timestamp)>
void Parser::setCallback(T& object)
{
    C::mip_packet_callback callback = [](void* obj, const C::mip_packet_view* pkt, Timestamp timestamp)->bool
    {
        return (static_cast<T*>(obj)->*Callback)(PacketView(pkt), timestamp);
    };
 
    C::mip_parser_set_callback(this, callback, &object);
}
 
template<class Function>
bool parseMipDataFromSource(C::mip_parser& parser, Function reader, size_t maxPackets)
{
    uint8_t* ptr;
    size_t maxCount = C::mip_parser_get_write_ptr(&parser, &ptr);
 
    size_t count;
    Timestamp timestamp;
    if( !reader(ptr, maxCount, &count, &timestamp) )
        return false;
 
    assert(count <= maxCount);
 
    C::mip_parser_process_written(&parser, count, timestamp, maxPackets);
 
    return true;
}
 
} // namespace mip