timeddiskbuffer.h

#ifndef TIMEDDISKBUFFER_H
#define TIMEDDISKBUFFER_H

#include <cvd/diskbuffer2.h>

namespace CVD
{

namespace Exceptions
{
    namespace TimedDiskBuffer
    {
        struct All : public CVD::Exceptions::VideoBuffer::All
        {
            using CVD::Exceptions::VideoBuffer::All::All;
        };
        struct IncompatibleListLengths : public All
        {
            IncompatibleListLengths();
        };
    }
}

template <class T>
class TimedDiskBuffer : public CVD::DiskBuffer2<T>
{
    public:
    TimedDiskBuffer(const std::vector<std::string>& names, const std::vector<double>& times, CVD::VideoBufferFlags::OnEndOfBuffer eob = CVD::VideoBufferFlags::RepeatLastFrame);

    virtual CVD::DiskBuffer2Frame<T>* get_frame();

    protected:
    std::vector<double> file_times;
};

template <class T>
inline TimedDiskBuffer<T>::TimedDiskBuffer(const std::vector<std::string>& names, const std::vector<double>& times, CVD::VideoBufferFlags::OnEndOfBuffer eob)
    : CVD::DiskBuffer2<T>(names, 1, eob)
{
    if(times.size() != names.size())
        throw Exceptions::TimedDiskBuffer::IncompatibleListLengths();
    file_times = times;
}

//
// GET FRAME
//
template <class T>
inline CVD::DiskBuffer2Frame<T>* TimedDiskBuffer<T>::get_frame()
{
    int current_frame = this->next_frame;
    if(current_frame < 0)
        current_frame = 0;
    // get a frame from the super class
    CVD::DiskBuffer2Frame<T>* vf = CVD::DiskBuffer2<T>::get_frame();
    vf->timestamp(file_times[current_frame]);
    return vf;
}
}

#endif