src/main/Logger.h

Go to the documentation of this file.

#ifndef LOGGER_H_
#define LOGGER_H_

#include <string>
#include <queue>
#include <fstream>
#include <iostream>
#include <pthread.h>

#include "Settings.h"
#include "functions.h"

using namespace std;

enum logType {
        GET,
        SET,
        SET_NUMERIC,
        INCREMENT,
        SAVE_SPACE,
        LOAD_SPACE,
        DESTROY_SPACE,
        CREATE_SPACE,
        CLEAN_SPACE,
        SELECT_SPACE,
        INITIALIZE,
        FINALIZE,
        LOGIN,
        SOFT_QUOTA_EXCEEDED,
        HARD_QUOTA_REACHED,
        LRU_ENTRY_REMOVED,
        ENTRY_TIMED_OUT,
        QUOTA_USED_BY_USER,
        QUOTA_USED_BY_SPACE,
        BUFFER_OVERFLOW,
        LOAD_CONFIG,
        ERROR,
        CLEAR_STATS,
        GC_START_RUN,
        GC_END_RUN,
        GC_START_COLLECTING_FROM_SPACE,
        SET_PARAMETERS,
        GC_WALK,
        TIME_RECORD
};

const int logTypeLevel[] = { 3, 3, 3, 3, 1, 1, 1, 1, 1, 3, 1, 1, 1, 1, 1, 3, 3, 2, 2, 1, 1, 2, 3, 3, 3, 3, 1, 1, 1 };

struct Log {

        logType type;

        time_t time;

        string firstSParam;

        string secondSParam;

        unsigned firstUParam;

        unsigned secondUParam;

        Log(logType type, const string& firstSParam, const string& secondSParam, unsigned firstUParam,
                        unsigned secondUParam);
};

class Logger {

public:
        static bool stop;

private:
        unsigned bufferLength;
        unsigned interval;
        int logLevel;
        bool dumpToFile;
        queue<Log> logBuffer;
        string directory;
        string fileName;
        ostream * output;
        //saveLogsStr saveThreadStruct;
        pthread_t threadID;
        pthread_mutex_t mutex;
        bool isNotFullAndSatisfactoryLevel(int level);
        void logBufferOverflow();
        void push(Log log);

public:

        Logger();

        void setParameters(Settings config);

        ~Logger();

        void saveLogs();

        void operator()();

        void logGet(const string& key, const string& spaceName);
        void logSet(const string& key, const string& spaceName, unsigned timeout);
        void logSetNumeric(const string& key, const string& spaceName, unsigned timeout);
        void logIncrement(const string& key, const string& spaceName, unsigned step, unsigned timeout);
        void logSaveSpace(const string& spaceName, const string& fileName);
        void logLoadSpace(const string& spaceName, const string& fileName);
        void logDestroySpace(const string& spaceName);
        void logCreateSpace(const string& spaceName, const string& userName, unsigned softQuota, unsigned hardQuota);
        void logCleanSpace(const string& spaceName);
        void logSelectSpace(const string& spaceName);
        void logInitialize();
        void logFinalize();
        void logLogin(const string& userName);
        void logSoftQuotaExceeded(const string& spaceName);
        void logHardQuotaReached(const string& spaceName);
        void logLRUEntryRemoved(const string& key, const string& spaceName);
        void logEntryTimedOut(const string& key, const string& spaceName);
        void logQuotaUsedByUser(const string& userName, unsigned quota);
        void logQuotaUsedBySpace(const string& spaceName, unsigned quota);
        void logLoadConfig(const string& confDir, unsigned logLevel);
        void logError(const string& error);
        void logClearStats(const string &spaceName);
        void logGCStartRun();
        void logGCEndRun();
        void logGCStartCollectingFromSpace(const string &spaceName);
        void logGCWalk(const string & message);
        void logTimeRecord(const string & discipline, unsigned int miliseconds);

};

void * loggerThread(void * arg);

void loggerHandler(int n);

#endif /* LOGGER_H_ */

---