node_job.h

Go to the documentation of this file.

#ifndef MF_FLOW_NODE_JOB_H_
#define MF_FLOW_NODE_JOB_H_

#include "node.h"
#include <vector>
#include <utility>

namespace mf { namespace flow {


class node_job {
private:
    using input_view_handle_type = std::pair<node_input*, timed_frame_array_view>;
    using output_view_handle_type = std::pair<node_output*, frame_view>;

    node& node_;
    time_unit time_ = -1;
    bool end_marked_ = false;
    
    std::vector<input_view_handle_type> inputs_stack_;
    std::vector<input_view_handle_type*> inputs_map_; 

    std::vector<output_view_handle_type> outputs_stack_;
    std::vector<output_view_handle_type*> outputs_map_; 

public:
    node_job(node&);
    ~node_job();
    
    void define_time(time_unit t);
    void push_input(node_input&, const timed_frame_array_view&);
    void push_output(node_output&, const frame_view&);
    node_input* pop_input();
    node_output* pop_output();
    bool end_was_marked() const noexcept { return end_marked_; }
    
    time_unit time() const noexcept { return time_; }
    void mark_end() { end_marked_ = true; }

    template<typename Input> decltype(auto) in_full(Input&);
    template<typename Input> decltype(auto) in(Input&);
    template<typename Output> decltype(auto) out(Output&);
    template<typename Param> decltype(auto) param(const Param&);
};

}}

#include "node_job.tcc"

#endif