DiagnosticUtils.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef _DIAGNOSTIC_UTILS_H_
#define _DIAGNOSTIC_UTILS_H_

#include <string>
#include <vector>

#include <stdint.h>

namespace fesa
{

namespace DiagnosticUtils
{

const std::string fwkDiagLoggerNamePrefix = "FESA.DIAG.FWK.";
const std::string userDiagLoggerNamePrefix = "FESA.DIAG.USR.";

// const std::string topicNames[] = {
//     "GetActionProfiling",
//     "SetActionProfiling",
//     "RTActionProfiling",
//     "EventProfiling",
//     "NotificationProfiling",
//     "GetActionTracking",
//     "SetActionTracking",
//     "RTActionTracking",
//     "EventTracking",
//     "NotificationTracking",
//     "PersistencyTracking",
//     "TransactionTracking",
//     "SubscriptionTracking",
//     "SignalHandlerTracking",
//     "RDATracking",
//     "StartUpTracking"
// };

const std::string getActionProfilingStr = "GetActionProfiling";
const std::string setActionProfilingStr = "SetActionProfiling";
const std::string rtActionProfilingStr = "RTActionProfiling";
const std::string eventProfilingStr = "EventProfiling";
const std::string notificationProfilingStr = "NotificationProfiling";
const std::string getActionTrackingStr = "GetActionTracking";
const std::string setActionTrackingStr = "SetActionTracking";
const std::string rtActionTrackingStr = "RTActionTracking";
const std::string eventTrackingStr = "EventTracking";
const std::string notificationTrackingStr = "NotificationTracking";
const std::string persistencyTrackingStr = "PersistencyTracking";
const std::string transactionTrackingStr = "TransactionTracking";
const std::string subscriptionTrackingStr = "SubscriptionTracking";
const std::string signalHandlerTrackingStr = "SignalHandlerTracking";
const std::string rdaTrackingStr = "RDATracking";
const std::string startUpTrackingStr = "StartUpTracking";

typedef std::vector<std::pair<int, std::string> > DiagnosticTopics;


struct DiagStateCounter
{
    uint32_t last_;
    uint32_t current_;
    uint32_t max_;
};

enum State
{
    initDiag = 1 << 0,
    startDiag = 1 << 1,
    stopDiag = 1 << 2,
    requestState = 1 << 3,
    updateFwkTopic = 1 << 4,
    updateCustomTopic = 1 << 5,
    updateTsPeriod = 1 << 6
};

enum FrameworkTopic
{
    getActionProfiling = 1 << 0,
    setActionProfiling = 1 << 1,
    rtActionProfiling = 1 << 2,
    eventProfiling = 1 << 3,
    notificationProfiling = 1 << 4,
    getActionTracking = 1 << 5,
    setActionTracking = 1 << 6,
    rtActionTracking = 1 << 7,
    eventTracking = 1 << 8,
    notificationTracking = 1 << 9,
    persistencyTracking = 1 << 10,
    transactionTracking = 1 << 11,
    subscriptionTracking = 1 << 12,
    signalHandlerTracking = 1 << 13,
    rdaTracking = 1 << 14,
    startUpTracking = 1 << 15
};

enum Side
{
    framework = 0,
    user = 1,
};

enum Action
{
    undefined = 0,
    start = 1,
    stop = 2
};

enum Source
{
    main = 0,
    rt = 1,
    server = 2,
    event = 3,
    notification = 4
};

struct DiagnosticMessage
{
    Side side;
    std::string type;
    Source source;
    std::string fesaClass;
    std::string thread;
    int64_t count;
    std::string name;
    Action action;
    std::string msg;

    DiagnosticMessage() :
        side(framework),
        type("TRACE"),
        source(main),
        fesaClass(""),
        thread(""),
        count(0),
        name(""),
        action(undefined),
        msg("")
    {
    }
};

std::string convertFwkTopicToString(FrameworkTopic topic);

std::string convertActionToString(Action action);

std::string convertSideToString(Side side);

std::string convertSourceToString(Source source);

std::string formatMessage(const DiagnosticMessage& diagMsg);

} // DiagnosticUtils

} // fesa

#endif // _DIAGNOSTIC_UTILS_H