adtf_remote_logging_intf.h

Go to the documentation of this file.

#pragma once
 
#include <adtf_utils.h>
#include <adtfucom3/adtf_ucom3.h>
 
namespace adtf
{
namespace remote
{
namespace ant
{

class ILogging
{
    public:
        ADTF_IID(ILogging, "logging.ant.remote.adtf");

        static constexpr const tChar* const DEFAULT_NAME = "logging";
 
    public:
        virtual size_t CreateLogBuffer(tTimeStamp nTimeout) = 0;

        virtual tResult ReleaseLogBuffer(size_t nBufferID) = 0;

        virtual const char* GetBufferContent(size_t nBufferID) = 0;
};

inline tResult parse_logging_rpc_buffer(const char* strInput, adtf::util::log::logger oLogger)
{
    while (*strInput != '\0')
    {
        const char* pItemStart = strInput;
        adtf::util::cParserHelper::SeekChars(strInput, "\t", true);
        if (*strInput == '\0')
        {
            break;
        }
 
        tTimeStamp nTimeStamp = adtf::util::cString(pItemStart, strInput - pItemStart).AsInt64();
 
 
        strInput += 1;
        pItemStart = strInput;
        adtf::util::cParserHelper::SeekChars(strInput, "\t", true);
        if (*strInput == '\0')
        {
            break;
        }
 
        uint32_t  value = adtf::util::cString(pItemStart, strInput - pItemStart).AsUInt32();
        if (value > std::numeric_limits<uint8_t>::max())
        {
            // The given value is too large to be downcasted to uint8_t. And it is surely no
            // valid loglevel. We cannot process this request.
            RETURN_ERROR_DESC(ERR_INVALID_ARG, "Detected value which is greater than the maximum possible value of nLogLevel");
        }
        
        // after the above check we are safe to convert the value to uint8_t.
        uint8_t nLogLevel = static_cast<uint8_t>(value);
        strInput += 1;
        pItemStart = strInput;
        adtf::util::cParserHelper::SeekChars(strInput, "\t", true);
        if (*strInput == '\0')
        {
            break;
        }
 
        adtf::util::cString strMessage = adtf::util::cString(pItemStart, strInput - pItemStart).Unescape();
 
        strInput += 1;
        pItemStart = strInput;
        adtf::util::cParserHelper::SeekChars(strInput, "\n", true);
        if (*strInput == '\0')
        {
            break;
        }
 
        adtf::util::cString strSource = adtf::util::cString(pItemStart, strInput - pItemStart).Unescape();
 
        if (nTimeStamp == 0 && nLogLevel == 0)
        {
            break;
        }
        oLogger({nTimeStamp, nLogLevel, strMessage, strSource});
    }
    RETURN_NOERROR;
}
 
}
 
using ant::ILogging;
using ant::parse_logging_rpc_buffer;
 
}
}