ThrottleStream.hpp

Go to the documentation of this file.

/*
 * DUNE DAQ modification notice:
 * This file has been modified from the original ATLAS ers source for the DUNE DAQ project.
 * Fork baseline commit: 8267df82a4f6fe6bf02c4014923eba19eddc4614 (2020-04-14).
 * Renamed since fork: yes (from ers/internal/ThrottleStream.h to include/ers/internal/ThrottleStream.hpp).
 *
 * Original copyright:
 * Copyright (C) 2001-2020 CERN for the benefit of the ATLAS collaboration.
 * Licensed under the Apache License, Version 2.0.
 */
 
/*
 *  ThrottleStream.h
 *  ers
 *
 *  Created by Gordon Crone on 02.08.05.
 *  Copyright 2004 CERN. All rights reserved.
 *
 */
 
#ifndef ERS_THROTTLE_STREAM_H
#define ERS_THROTTLE_STREAM_H
 
#include <map>
#include <mutex>
 
#include <ers/OutputStream.hpp>
 
namespace ers
{
    class ThrottleStream: public ers::OutputStream {
    public:
        explicit ThrottleStream(const std::string &criteria);
 
        void write(const ers::Issue &issue) override;
 
    private:
        class IssueRecord {
        public:
            IssueRecord();
            void reset();
 
            std::time_t m_lastOccurance;
            std::time_t m_lastReport;
            std::string m_lastOccuranceFormatted;
            int m_initialCounter;
            int m_threshold;
            int m_suppressedCounter;
        };
 
    private:
        void throttle(IssueRecord &record, const ers::Issue &issue);
 
        void reportSuppression(IssueRecord &record, const ers::Issue &issue);
 
        typedef std::map<std::string, IssueRecord> IssueMap;
        IssueMap m_issueMap;
 
        int m_initialThreshold;
        int m_timeLimit;
        std::mutex m_mutex;
    };
}
 
#endif