Method fetch

bmf/sdk/cpp_sdk/src/module_functor.cpp:108–127

}

std::vector<Packet> ModuleFunctor::fetch(int idx) {
    std::vector<Packet> pkts;
    auto oid = self->oids[idx];
    while (!self->task.output_queue_empty(oid)) {
        Packet pkt;
        self->task.pop_packet_from_out_queue(oid, pkt);
        if (pkt && pkt.timestamp() == BMF_EOF) {
            self->eofs[idx] = true;
            break;
        }

        pkts.push_back(pkt);
    }

    if (self->eofs[idx] && pkts.size() == 0) {
        throw ProcessDone("Receive EOF packet");
    }

    return pkts;
}

std::vector<Packet>
ModuleFunctor::operator()(const std::vector<Packet> &inputs) {