#include <thread>
|
#include "AppPipeController.h"
|
#include <basic/util/file/FileUtil.h>
|
#include <basic/util/app/AppPreference.hpp>
|
#include <basic/debug/Debug.h>
|
|
using namespace std;
|
|
|
int main(int argc, char **argv) {
|
SAVE_APP_ARGS;
|
|
#ifdef GLOG
|
ENABLEGLOG("./log/");
|
#endif
|
|
// std::string src_path = "/home/bsk/development/c++/Qt/QiaoJiaSystem/build/cut/123456/34/201808/28/123456-34-201808-20180828090100";
|
std::string src_path = "/home/basic/视频/test";
|
|
|
appPref.setLongData("gpu.index", 0);
|
appPref.setIntData("show.image", 0);
|
|
//yolo server
|
appPref.setStringData("yolo.proxy", "yoloServer");
|
//#todo
|
appPref.setStringData("yolo.ip", "");
|
appPref.setIntData("yolo.port", 10003);
|
// rpcClient(appPref.getStringData("yolo.proxy"), appPref.getStringData("yolo.ip"), appPref.getLongData("yolo.port"),"tcp"),
|
|
|
//face detect server
|
appPref.setStringData("faceDete.proxy", "faceServer");
|
//#todo
|
appPref.setStringData("faceDete.ip", "");
|
appPref.setIntData("faceDete.port", 10002);
|
//rpcClient(appPref.getStringData("faceDete.proxy"), appPref.getStringData("faceDete.ip"), appPref.getLongData("faceDete.port"),"tcp"),
|
// rpcClient("faceServer","",10002,"tcp"),
|
|
|
//fece extern server
|
appPref.setStringData("faceExte.proxy", "faceExtractServer");
|
//#todo
|
appPref.setStringData("faceExte.ip", "");
|
appPref.setIntData("faceExte.port", 10008);
|
//rpcClient(appPref.getStringData("faceExte.proxy"), appPref.getStringData("faceExte.ip"), appPref.getLongData("faceExte.port"),"tcp"),
|
// "faceExtractServer", "", 10008, "tcp"),//人脸特征提取 修改成点对点通讯
|
|
|
//face search server
|
appPref.setStringData("faceSear.proxy", "faceCmServer");
|
//#todo
|
appPref.setStringData("faceSear.ip", "");
|
appPref.setIntData("faceSear.port", 10004);
|
//rpcClient(appPref.getStringData("faceSear.proxy"), appPref.getStringData("faceSear.ip"), appPref.getLongData("faceSear.port"),"tcp"),
|
// faceSearchRpcClient("faceCmServer", "", 10004, "tcp")
|
|
//loopRecord server
|
appPref.setStringData("loopRecord.proxy", "LoopRecordVideoServer");
|
//#todo
|
appPref.setStringData("loopRecord.ip", "");
|
appPref.setIntData("loopRecord.port", 10010);
|
//rpcClient(appPref.getStringData("loopRecord.proxy"), appPref.getStringData("loopRecord.ip"), appPref.getLongData("loopRecord.port"),"tcp"),
|
|
appPref.setStringData("ipAdd", "192.168.1.185");
|
appPref.setIntData("ipPort", 9200);
|
Json::Value json;
|
|
//split sdks enable
|
//#todo other sdk
|
|
json["face.enable"] = "1";
|
json["yolo.enable"] = "0";
|
json["rtsp"] = "rtsp://admin:a1234567@192.168.1.188:554/h264/ch1/main/av_stream";
|
// json["rtsp"] = "rtsp://admin:a1234567@192.168.1.188:554/h264/ch1/main/av_stream";
|
// json["rtsp"] = "/home/bsk/test/realtime/test123/201809/27/test123-2018092717/2018-09-27 17:20:57.mp4";
|
|
|
FastFdsWithLock fdfsClient;
|
// fdfsClient.fastFds = new FastFds;
|
|
//#todo from path get file list
|
file_filter_type filter = [](const char *dirName, const char *dirent) {
|
return (strstr(dirent, ".mp4") != nullptr);// add format
|
};
|
std::vector<std::string> vec = for_each_file(src_path, filter);
|
// while (true) {
|
auto size = vec.size();
|
// int size = 1;
|
int pos = 0;
|
// AppPipeController _AppPipeController("test12344", json, true);
|
// AppPipeController _AppPipeController(src_path, json);
|
// _AppPipeController.setfdfsClient(&fdfsClient);
|
// for (; pos < size;) {
|
//
|
// //#todo
|
// _AppPipeController.resetVideoCapturePath(vec[pos++]);
|
// _AppPipeController.resetVideoCapturePath(
|
// "/home/basic/work/qiaojia/cut/DS-7808N-SN0820161208AARR691369356WCVU/34/201810/11/DS-7808N-SN0820161208AARR691369356WCVU-34-20181011090000/2018-10-11 09:48:05.mp4");
|
// _AppPipeController.start();
|
// while (_AppPipeController.getRunning()) {
|
// usleep(40000);
|
// }
|
// _AppPipeController.stop();
|
// _AppPipeController.wait();
|
DBG("finish file");
|
// }
|
// }
|
|
// _AppPipeController.start();
|
// while (_AppPipeController.getRunning()) {
|
// usleep(40000);
|
// }
|
// _AppPipeController.stop();
|
// _AppPipeController.wait();
|
//
|
getchar();
|
|
return 0;
|
}
|
