sync_node.h

Go to the documentation of this file.

#ifndef MF_FLOW_SYNC_NODE_H_
#define MF_FLOW_SYNC_NODE_H_

#include <memory>
#include "filter_node.h"
#include "../queue/frame.h"
#include "../queue/timed_ring.h"

namespace mf { namespace flow {

class sync_node;


class sync_node_output : public node_output {
private:
    std::unique_ptr<timed_ring> ring_;

public:
    using node_type = sync_node;

    using node_output::node_output;
    
    void setup() override;
    
    void pull(time_span) override;
    timed_frame_array_view begin_read(time_unit duration) override;
    void end_read(time_unit duration) override;
    time_unit end_time() const override;
    
    frame_view begin_write_frame(time_unit& t) override;
    void end_write_frame(bool was_last_frame) override;
    void cancel_write_frame() override;
};



class sync_node final : public filter_node {
public:
    explicit sync_node(graph& gr) : filter_node(gr) { }
    
    void internal_setup() final override;
    void launch() final override;
    void stop() final override;
        
    bool process_next_frame() override;

    node_input& add_input(time_unit past_window, time_unit future_window) override {
        return add_input_<node_input>(past_window, future_window);
    }
    
    sync_node_output& add_output(const frame_format& format) override {
        return add_output_<sync_node_output>(format);
    }
};


}}

#endif