解决修改参数和推流画面跳跃问题

chenshijun

2019-04-16 f946a62d3921e86b44ff8e2973138304b9cd53cd

 QiaoJiaSystem/VideoToImageMulth/main.cpp

@@ -59,23 +59,40 @@
    ENABLEGLOG(GET_STR_CONFIG("logPath").c_str());
#endif

    if (argc < 4) {
    if (argc < 6) {
        assert("t_value.size()");
    }
    {
//            std::string rtmpAddr = appConfig.getStringProperty("srsAddr");
//            std::string publish_basepath = rtmpAddr + "" ;
//            appPref.setStringData("publish.basepath", publish_basepath);
//        appPref.setIntData("pulish.width", 640);
//        appPref.setIntData("pulish.height", 480);
    }
//    int arg1 = atoi(argv[1]);
//
//    int gindx = abs(arg1) % 2;
//    int GB28181_Enable = arg1 < 0 ? 1 : 0;
//
//    DBG(gindx);
//    appPref.setIntData("GB28181_Enable", GB28181_Enable);
//    appPref.setIntData("gpu.index", gindx);
//
//
//    //todo
//    appPref.setIntData("CamStart", arg1);
//    appPref.setIntData("CamStep", atoi(argv[2]));
//    appPref.setIntData("RpcVTIMPort", atoi(argv[3]));

    int arg1 = atoi(argv[1]);
    appPref.setIntData("GB28181_Enable", atoi(argv[1]));
    appPref.setIntData("gpu.index", atoi(argv[2]));
    appPref.setIntData("CamStartNO", atoi(argv[3]));
    appPref.setIntData("CamEndNO", atoi(argv[4]));
    appPref.setIntData("RpcVTIMPort", atoi(argv[5]));//触发录像

    int gindx = abs(arg1) % 2;
    int GB28181_Enable = abs(arg1) % 2;
    DBG(gindx);
    appPref.setIntData("GB28181_Enable", GB28181_Enable);
    appPref.setLongData("gpu.index", gindx);
    appPref.setIntData("show.image", 0);

    //todo
    appPref.setIntData("CamStart", arg1);
    appPref.setIntData("CamStep", atoi(argv[2]));
    appPref.setIntData("RpcServerPort", atoi(argv[3]));
    int GB28181_Enable = appPref.getIntData("GB28181_Enable");
    if (GB28181_Enable) {
        //#todo search from db
        MysqlDBServerCfg mysqlDBServerCfg;
@@ -96,8 +113,13 @@
            BaseSqliteDao::setLDBTool(&ldbTool);
            t_value = VssLocalSettingTblSqliteDao::instance()->findAllVssLocalSettingTblList();
        }
        DBG("t_value.size():" << t_value.size());
        DBG("t_value[\"data\"].size():" << t_value["data"].size());//todo   bug here t_value["data"].size() = 0
        if (t_value.size() == 1 && t_value["data"].size() > 1) {
            assert("t_value.size()");
        }
        if (t_value["data"].size() == 0) {
            assert("t_value[\"data\"].size()");
        }
        DBG(t_value["data"].begin()->toStyledString());
        auto &t_cfg = *t_value["data"].begin();
@@ -143,8 +165,12 @@
    }
    DBG("test start");

    // #todo
//    BasicMsg::Nsq::NsqMsgConsumer nsqMsgConsumer("127.0.0.1", "4150", "test3", "ch2");
    //

    appPref.setStringData("user.loop.absolute.path", appConfig.getStringProperty("cutPath"));
    IceRpcServer<RtspAnalysManager> server("RtspAnalysServer", appPref.getIntData("RpcServerPort"), "tcp");
    IceRpcServer<RtspAnalysManager> server("RtspAnalysServer", appPref.getIntData("RpcVTIMPort"), "tcp");
    server.setMessageSizeMax(1024 * 1024 * 50);
    server.setPoolInitSize(1);
    server.setPoolMaxSize(1);