accumulator.hpp

Go to the documentation of this file.

#pragma once
 
#include "./../types.hpp"
 
class Accumulator
{   
    counter_t Accumulate = 0; 
    unsigned int Update_count = 0; 
 
public:
    unsigned int Buffer_count = 0; 
    
    void do_accumulate(unsigned int buffer_cnt)
    {
        Buffer_count = buffer_cnt;
        Update_count = buffer_cnt;
    }
 
    template <typename LinCorrType>
    void inline pipe(LinCorrType &channel, const counter_t datum)
    {
        Accumulate += datum;
        Update_count--;
                
        if(Update_count == 0)
        {
            channel.push_datum(Accumulate); //Push to Channel
            Accumulate = 0; // Reset Sccumulate
            Update_count = Buffer_count; //Recharge Local Counter
        }
    }
 
};