#include "AppPipeController.h"
|
#include <basic/util/app/AppPreference.hpp>
|
#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.getLongData("gpu.index")),
|
index(index), videoPublishElement(appPref.getStringData("publish.basepath")+".flv",
|
cv::Size(appPref.getIntData("pulish.width"),appPref.getIntData("pulish.height")),
|
"flv", 25, appPref.getLongData("gpu.index"))
|
{
|
if(appPref.getIntData("pulish.width") < 0 || appPref.getIntData("pulish.height") < 0)
|
{
|
ERR("pulish.width: "<<appPref.getIntData("pulish.width") <<" Height: "<< appPref.getIntData("pulish.height"));
|
}
|
videoCaptureElement.registerConnector([&]{
|
//if(!videoPublishElement.isBusy()){
|
videoPublishElement.setImage(videoCaptureElement.getImage());
|
//videoPublishElement.submit();
|
//}
|
|
});
|
|
registerElement(videoCaptureElement);
|
registerElement(videoPublishElement);
|
|
//videoCaptureElement.setOutPutInterval(3);
|
}
|
|
std::string AppPipeController::getRtmp()
|
{
|
std::string ret = videoPublishElement.getPath();
|
size_t pos = ret.find(".flv");
|
ret = ret.substr(0,pos);
|
INFO(ret);
|
return ret;
|
}
|