C++ cannot call data push mode

[x850044053wwt]

GraphMode中没有数据推送模式枚举。源码中添加对应枚举后，c++没有对应python中的Graph::run_wo_block。执行Graph::run()之后，线程阻塞，无法继续调用FillPacket

[JackLau1222]

may you provide the cpp demo code?

[x850044053wwt]

nlohmann::json graph_para = { {"dump_graph", 1} };
auto graph = bmf::builder::Graph(bmf::builder::PushdataMode, JsonParam(graph_para));
auto video_stream = graph.InputStream("blob_video", "", "");
nlohmann::json option = { { "video_codec", "h264" },
                          {  "video_time_base", "1,30000" },
                          {  "push_raw_stream", 1 } };
auto decode_stream = video_stream.Decode(JsonParam(option));
option = { { "output_path", "D:/output.mp4" },
           { "video_params", {
           {  "codec", "h264" },
           {  "width", 640 },
           {  "height", 480 },
           {  "crf", "23" },
           {  "preset", "veryfast" } } } };
decode_stream.EncodeAsVideo(JsonParam(option));
graph.Start();

[JackLau1222]

nlohmann::json graph_para = { {"dump_graph", 1} };
auto graph = bmf::builder::Graph(bmf::builder::PushdataMode, JsonParam(graph_para));
auto video_stream = graph.InputStream("blob_video", "", "");
nlohmann::json option = { { "video_codec", "h264" },
                          {  "video_time_base", "1,30000" },
                          {  "push_raw_stream", 1 } };
auto decode_stream = video_stream.Decode(JsonParam(option));
option = { { "output_path", "D:/output.mp4" },
           { "video_params", {
           {  "codec", "h264" },
           {  "width", 640 },
           {  "height", 480 },
           {  "crf", "23" },
           {  "preset", "veryfast" } } } };
decode_stream.EncodeAsVideo(JsonParam(option));
graph.Start();

Hi, sorry for being late. I just took some time to fix this bug. I noticed that your code didn’t handle the data push correctly. You can refer to my use case for guidance. If you manage to resolve this issue, feel free to submit a patch. I’ll be happy to review and merge it for you.

Here is the my test case:

#include <builder.hpp>
#include "nlohmann/json.hpp"
#include <bmf/sdk/bmf.h>

int main() {
    std::string output_path = "./push_data_output.mp4";

    auto graph = bmf::builder::Graph(bmf::builder::PushDataMode);
    auto video_stream = graph.InputStream("outside_raw_video", "", "");
    nlohmann::json encode_para = {{"output_path", output_path},
                                  {"video_params",
                                   {{"codec", "h264"},
                                    {"width", 640},
                                    {"height", 480},
                                    {"crf", 23},
                                    {"preset", "veryfast"},
                                    {"vsync", "vfr"}}}};
    auto video = graph.Encode(video_stream, bmf_sdk::JsonParam(encode_para));

    graph.Start();

    int count = 50;
    int pts_ = 0;
    while (count > 0) {
        auto frame = VideoFrame(640, 480, PixelInfo(PixelFormat::PF_YUV420P));
        frame.set_pts(pts_);
        pts_++;
        auto packet = Packet(frame);
        count--;
        graph.FillPacket(video_stream.GetName(), packet);
        std::cout << "push data into inputstream" << std::endl;
    }
    auto packet = Packet::generate_eof_packet();
    graph.FillPacket(video_stream.GetName(), packet);

    // graph.Close();

    return 0;
}

BTW, you may need to modify some APIs in C++ so that you can run this case normally