| | |
| | | #include <basic/util/app/AppUtil.h> |
| | | //#include <sstream> |
| | | #include <algorithm> |
| | | AppPipeController::AppPipeController(int index, const Json::Value &json): |
| | | videoCaptureElement(json["rtsp"].asString(), 25,3000,appPref.getIntData("gpu.index")), |
| | | index(index), videoPublishElement(appPref.getStringData("publish.basepath")+".flv", |
| | | cv::Size(appConfig.getIntProperty("pulish.width"),appConfig.getIntProperty("pulish.height")), |
| | | "flv", 25, appPref.getIntData("gpu.index")) |
| | | { |
| | | if(appConfig.getIntProperty("pulish.width") < 0 || appConfig.getIntProperty("pulish.height") < 0) |
| | | { |
| | | ERR("pulish.width: "<<appConfig.getIntProperty("pulish.width") <<" Height: "<< appConfig.getIntProperty("pulish.height")); |
| | | } |
| | | videoCaptureElement.registerConnector([&]{ |
| | | //if(!videoPublishElement.isBusy()){ |
| | | videoPublishElement.setImage(videoCaptureElement.getImage()); |
| | | //videoPublishElement.submit(); |
| | | //} |
| | | |
| | | AppPipeController::AppPipeController(int index, const Json::Value &json) : |
| | | videoCaptureElement(json["rtsp"].asString(), 25, 3000, appPref.getIntData("gpu.index")), |
| | | index(index), videoPublishElement(appPref.getStringData("publish.basepath") + ".flv", |
| | | cv::Size(appConfig.getIntProperty("pulish.width"), |
| | | appConfig.getIntProperty("pulish.height")), |
| | | "flv", 25, appPref.getIntData("gpu.index")) { |
| | | if (appConfig.getIntProperty("pulish.width") < 0 || appConfig.getIntProperty("pulish.height") < 0) { |
| | | ERR("pulish.width: " << appConfig.getIntProperty("pulish.width") << " Height: " |
| | | << appConfig.getIntProperty("pulish.height")); |
| | | } |
| | | videoCaptureElement.registerConnector([&] { |
| | | //if(!videoPublishElement.isBusy()){ |
| | | videoPublishElement.setImage(videoCaptureElement.getImage()); |
| | | // videoPublishElement.submit(); |
| | | //} |
| | | }); |
| | | |
| | | registerElement(videoCaptureElement); |
| | | registerElement(videoPublishElement); |
| | | // registerElement(videoPublishElement); |
| | | |
| | | //videoCaptureElement.setOutPutInterval(3); |
| | | } |
| | | |
| | | std::string AppPipeController::getRtmp() |
| | | { |
| | | std::string AppPipeController::getRtmp() { |
| | | std::string ret = videoPublishElement.getPath(); |
| | | size_t pos = ret.find(".flv"); |
| | | ret = ret.substr(0,pos); |
| | | ret = ret.substr(0, pos); |
| | | INFO(ret); |
| | | return ret; |
| | | } |