Method process

bmf/sdk/cpp_sdk/test/test_module_functor.cpp:83–97

    void mark_done() { done_ = true; }

    int process(Task &task) override {
        if (done_) {
            task.set_timestamp(DONE);
        }

        Packet pkt0, pkt1;
        task.pop_packet_from_input_queue(0, pkt0);
        task.pop_packet_from_input_queue(1, pkt1);

        auto result = pkt0.get<int>() + pkt1.get<int>();

        task.fill_output_packet(0, Packet(result));

        return 0;
    }
};

REGISTER_MODULE_CLASS(FunctorSource)