StreamAlignerStatus.hpp

Go to the documentation of this file.

#ifndef __AGGREGATOR__STREAMALIGNERSTATUS_HPP__
#define __AGGREGATOR__STREAMALIGNERSTATUS_HPP__

#include <base/Time.hpp>
#include <vector>

namespace aggregator 
{
    struct StreamStatus
    {
        size_t buffer_size;
        size_t buffer_fill;
        size_t samples_received;
        size_t samples_processed;
        size_t samples_dropped_buffer_full;
        size_t samples_dropped_late_arriving;
        size_t samples_backward_in_time;
        base::Time latest_data_time;
        base::Time earliest_data_time;  
        base::Time latest_sample_time;
        bool active;
        std::string name;
        int64_t priority;
        
        StreamStatus() : buffer_size(0), buffer_fill(0), samples_received(0), 
                        samples_processed(0), samples_dropped_buffer_full(0), 
                        samples_dropped_late_arriving(0), 
                        samples_backward_in_time(0), active(true), priority(0)
        {
        }
    };

    struct StreamAlignerStatus
    {
        base::Time time;
        std::string name;
        base::Time current_time;
        base::Time latest_time;
        size_t samples_dropped_late_arriving;
        std::vector<StreamStatus> streams;
        
        StreamAlignerStatus() : samples_dropped_late_arriving(0)
        {
        }       
    };

}

std::ostream &operator<<(std::ostream &os, const aggregator::StreamAlignerStatus &status);
std::ostream &operator<<(std::ostream &os, const aggregator::StreamStatus &status);
std::ostream& counters(std::ostream& os, const aggregator::StreamStatus& status);
std::ostream& timers(std::ostream& os, const aggregator::StreamStatus& status, base::Time current_time);

#endif