NodeInteractionsContainer.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/utils/TimeSpan.h"
#include "catapult/functions.h"
#include <list>
 
namespace catapult { namespace ionet {
 
    struct NodeInteractions {
    public:
        NodeInteractions() : NodeInteractions(0, 0)
        {}
 
        explicit NodeInteractions(uint32_t numSuccesses, uint32_t numFailures)
                : NumSuccesses(numSuccesses)
                , NumFailures(numFailures)
        {}
 
    public:
        uint32_t NumSuccesses;
 
        uint32_t NumFailures;
    };
 
    class NodeInteractionsContainer {
    private:
        struct NodeInteractionsBucket {
        public:
            explicit NodeInteractionsBucket(Timestamp timestamp)
                    : CreationTime(timestamp)
                    , NumSuccesses(0)
                    , NumFailures(0)
            {}
 
        public:
            Timestamp CreationTime;
 
            uint32_t NumSuccesses;
 
            uint32_t NumFailures;
        };
 
    public:
        static utils::TimeSpan BucketDuration();
 
        static utils::TimeSpan InteractionDuration();
 
    public:
        NodeInteractions interactions(Timestamp timestamp) const;
 
    public:
        void incrementSuccesses(Timestamp timestamp);
 
        void incrementFailures(Timestamp timestamp);
 
        void pruneBuckets(Timestamp timestamp);
 
    private:
        void addInteraction(Timestamp timestamp, const consumer<NodeInteractionsBucket&>& consumer);
 
    private:
        std::list<NodeInteractionsBucket> m_buckets;
    };
}}