Skip to content

E
evsuits
提交 ed80379a authored 作者: blu's avatar blu
浏览文件
操作

init

上级 a1b5acad
隐藏空白字符变更
内嵌 并排
正在显示 包含 166 行增加 和 86 行删除
opencv-motion-detect/Makefile
浏览文件 @ ed80379a
#DEBUG=-g
DEBUG=-g
CC = gcc
CPP = g++
CPPFLAGS = $(DEBUG) -Wall -std=gnu++1z
......
opencv-motion-detect/database.cpp
浏览文件 @ ed80379a
......@@ -56,13 +56,28 @@ namespace LVDB {
break;
}else{
json &modules = ipc["modules"];
if(modules.count(moduleName) == 0){
string modname = moduleName.substr(0,4);
string sub;
if(modname == "evml") {
sub = moduleName.substr(4, moduleName.size());
}else{
modname = moduleName;
}
if(modules.count(modname) == 0){
break;
}else{
json &module = modules[moduleName];
json &module = modules[modname];
for(auto &inst: module) {
if(inst.count("sn") != 0 && inst["sn"] == sn && inst.count("iid") != 0 && inst["iid"] == iid) {
return &inst;
if(!sub.empty()) {
if(inst.count("type") != 0 && inst["type"] == sub) {
return &inst;
}
// continue
}else{
return &inst;
}
}
}
}
......@@ -74,6 +89,72 @@ namespace LVDB {
return ret;
}
int traverseConfigureModules(json &config, cb_traverse_configration_module cb, string moduleName){
int ret = 0;
if(config.count("data") == 0) {
return -1;
}
if(cb == NULL) {
return -2;
}
json &data = config["data"];
for(auto &[k,v]: data.items()){
json &mgr = data[k];
if(mgr.count("ipcs") == 0) {
break;
}else{
json &ipcs = mgr["ipcs"];
for(auto &ipc:ipcs) {
if(ipc.count("modules") == 0) {
continue;
}else{
string modname, sub;
if(!moduleName.empty()){
modname = moduleName.substr(0,4);
if(modname == "evml") {
sub = moduleName.substr(4, moduleName.size());
}else{
modname = moduleName;
}
}
json &modules = ipc["modules"];
if(!modname.empty()) {
if(modules.count(modname) == 0) {
return -3;
}else{
json &module = modules[modname];
if(!sub.empty()) {
for(auto &m:module) {
if(m.count("type") != 0 && m["type"] == sub) {
ret = cb(modname, m);
if(ret <0) {
spdlog::error("failed to traverse and callback config on module: {}", m.dump());
return ret;
}
}
}
}
}
}else{
for(auto &[mn, mod]:modules.items()) {
for(auto &m:mod) {
ret = cb(mn,m);
if(ret <0) {
spdlog::error("failed to traverse and callback config on module: {}", m.dump());
return ret;
}
}
}
}
}
}
}
}
return 0;
}
int _getDB(string fileName, DB** pdb) {
static bool bmk = false;
int ret = 0;
......
opencv-motion-detect/evmgr.cpp
浏览文件 @ ed80379a
......@@ -72,6 +72,21 @@ private:
spdlog::error("failed to get local configuration");
exit(1);
}
// set all module status to 0
ret = LVDB::traverseConfigureModules(config, [](string modname, json &m)->int{
if(m.count("status") != 0)
{
cout << modname <<" ," << m.dump() << endl;
m["status"] = 0;
}
return 0;
});
if(ret < 0) {
spdlog::error("evmgr {} failed to set module status to 0", devSn);
}else{
//spdlog::info("new config: {}", config.dump());
LVDB::setLocalConfig(config);
}
int opt_notify = ZMQ_NOTIFY_DISCONNECT|ZMQ_NOTIFY_CONNECT;
string proto, addr;
......@@ -243,7 +258,7 @@ togo_sleep_continue:
}
else {
// message to mgr
spdlog::info("evmgr {} subsystem report msg received: {}; {}; {}", devSn, zmqhelper::body2str(body[0]), zmqhelper::body2str(body[1]), zmqhelper::body2str(body[2]));
// spdlog::info("evmgr {} subsystem report msg received: {}; {}; {}", devSn, zmqhelper::body2str(body[0]), zmqhelper::body2str(body[1]), zmqhelper::body2str(body[2]));
if(meta == "pong"||meta == "ping") {
// update status
spdlog::info("evmgr {}, ping msg from {}", devSn, selfId);
......
opencv-motion-detect/evmlmotion.cpp
浏览文件 @ ed80379a
......@@ -99,19 +99,18 @@ private:
tsLastBoot = info["lastboot"];
tsUpdateTime=info["updatetime"];
spdlog::info("evmgr info: sn = {}, lastboot = {}, updatetime = {}", info["sn"].get<string>(), ctime(&tsLastBoot), ctime(&tsUpdateTime));
spdlog::info("evmlmotion info: sn = {}, lastboot = {}, updatetime = {}", info["sn"].get<string>(), ctime(&tsLastBoot), ctime(&tsUpdateTime));
devSn = info["sn"];
ret = LVDB::getLocalConfig(config);
if(ret < 0) {
spdlog::error("failed to get local configuration");
exit(1);
}
while(!inited) {
// TODO: req config
bool found = false;
try {
ret = LVDB::getLocalConfig(config);
if(ret < 0) {
spdlog::error("failed to get local configuration");
exit(1);
}
spdlog::info("config: {:s}", config.dump());
json evmlmotion;
json evmgr;
......@@ -162,7 +161,7 @@ private:
// TODO: multiple protocols support
if(evmlmotion.count("path") == 0) {
spdlog::warn("evslicer {} {} no params for path, using default: {}", selfId, URLOUT_DEFAULT);
spdlog::warn("evslicer {} no params for path, using default: {}", selfId, URLOUT_DEFAULT);
urlOut = URLOUT_DEFAULT;
}
else {
......@@ -174,6 +173,42 @@ private:
spdlog::error("failed mkdir {}", urlOut);
return -1;
}
// setup sub
pSubCtx = zmq_ctx_new();
pSub = zmq_socket(pSubCtx, ZMQ_SUB);
ret = zmq_setsockopt(pSub, ZMQ_SUBSCRIBE, "", 0);
if(ret != 0) {
spdlog::error("evmlmotion {} failed set setsockopt: {}", selfId, urlPub);
return -1;
}
ret = zmq_connect(pSub, urlPub.c_str());
if(ret != 0) {
spdlog::error("evmlmotion {} failed connect pub: {}", selfId, urlPub);
return -2;
}
// setup dealer
pDealerCtx = zmq_ctx_new();
pDealer = zmq_socket(pDealerCtx, ZMQ_DEALER);
spdlog::info("evmlmotion {} connect to router {}", selfId, urlRouter);
ret = zmq_setsockopt(pDealer, ZMQ_IDENTITY, selfId.c_str(), selfId.size());
ret += zmq_setsockopt (pDealer, ZMQ_ROUTING_ID, selfId.c_str(), selfId.size());
if(ret < 0) {
spdlog::error("evpusher {} {} failed setsockopts router: {}", selfId, urlRouter);
return -3;
}
if(ret < 0) {
spdlog::error("evmlmotion {} failed setsockopts router: {}", selfId, urlRouter);
return -3;
}
ret = zmq_connect(pDealer, urlRouter.c_str());
if(ret != 0) {
spdlog::error("evmlmotion {} failed connect dealer: {}", selfId, urlRouter);
return -4;
}
//ping
ret = ping();
}
catch(exception &e) {
spdlog::error("evmlmotion {} exception in EvPuller.init {:s} retrying", selfId, e.what());
......@@ -209,58 +244,6 @@ private:
return ret;
}
int setupMq()
{
int ret = 0;
// setup sub
pSubCtx = zmq_ctx_new();
pSub = zmq_socket(pSubCtx, ZMQ_SUB);
ret = zmq_setsockopt(pSub, ZMQ_SUBSCRIBE, "", 0);
if(ret != 0) {
spdlog::error("evmlmotion {} failed set setsockopt: {}", selfId, urlPub);
return -1;
}
ret = zmq_connect(pSub, urlPub.c_str());
if(ret != 0) {
spdlog::error("evmlmotion {} failed connect pub: {}", selfId, urlPub);
return -2;
}
// setup dealer
pDealerCtx = zmq_ctx_new();
pDealer = zmq_socket(pDealerCtx, ZMQ_DEALER);
spdlog::info("evmlmotion {} try create req to {}", selfId, urlRouter);
ret = zmq_setsockopt(pDealer, ZMQ_IDENTITY, selfId.c_str(), selfId.size());
ret += zmq_setsockopt (pDealer, ZMQ_ROUTING_ID, selfId.c_str(), selfId.size());
if(ret < 0) {
spdlog::error("evpusher {} {} failed setsockopts router: {}", selfId, urlRouter);
return -3;
}
if(ret < 0) {
spdlog::error("evmlmotion {} failed setsockopts router: {}", selfId, urlRouter);
return -3;
}
ret = zmq_connect(pDealer, urlRouter.c_str());
if(ret != 0) {
spdlog::error("evmlmotion {} failed connect dealer: {}", selfId, urlRouter);
return -4;
}
//ping
ret = ping();
// TODO: don't need this anymore, since I've used the draft feature of ZOUTER_NOTIFICATION instead
// thPing = thread([&,this]() {
// while(true) {
// this_thread::sleep_for(chrono::seconds(EV_HEARTBEAT_SECONDS-2));
// ping();
// }
// });
// thPing.detach();
return ret;
}
int getInputFormat()
{
int ret = 0;
......@@ -639,7 +622,6 @@ public:
{
evtQueue = queue;
init();
setupMq();
getInputFormat();
setupStream();
};
......
opencv-motion-detect/evpuller.cpp
浏览文件 @ ed80379a
......@@ -168,17 +168,16 @@ private:
spdlog::info("evpuller info: sn = {}, lastboot = {}, updatetime = {}", info["sn"].get<string>(), ctime(&tsLastBoot), ctime(&tsUpdateTime));
devSn = info["sn"];
ret = LVDB::getLocalConfig(config);
if(ret < 0) {
spdlog::error("failed to get local configuration");
exit(1);
}
while(!inited) {
// TODO: req config
bool found = false;
string user, passwd, addr;
try {
ret = LVDB::getLocalConfig(config);
if(ret < 0) {
spdlog::error("failed to get local configuration");
exit(1);
}
spdlog::info("config dump: {:s}", config.dump());
json data = config["data"];
// first try to check mgr with same sn
......
opencv-motion-detect/evpusher.cpp
浏览文件 @ ed80379a
......@@ -63,19 +63,18 @@ private:
tsLastBoot = info["lastboot"];
tsUpdateTime=info["updatetime"];
spdlog::info("evmgr info: sn = {}, lastboot = {}, updatetime = {}", info["sn"].get<string>(), ctime(&tsLastBoot), ctime(&tsUpdateTime));
spdlog::info("evpusher info: sn = {}, lastboot = {}, updatetime = {}", info["sn"].get<string>(), ctime(&tsLastBoot), ctime(&tsUpdateTime));
devSn = info["sn"];
ret = LVDB::getLocalConfig(config);
if(ret < 0) {
spdlog::error("failed to get local configuration");
exit(1);
}
while(!inited) {
// TODO: req config
bool found = false;
try {
ret = LVDB::getLocalConfig(config);
if(ret < 0) {
spdlog::error("failed to get local configuration");
exit(1);
}
spdlog::info("config: {:s}", config.dump());
json evpusher;
json evmgr;
......
opencv-motion-detect/evslicer.cpp
浏览文件 @ ed80379a
......@@ -72,19 +72,19 @@ private:
tsLastBoot = info["lastboot"];
tsUpdateTime=info["updatetime"];
spdlog::info("evmgr info: sn = {}, lastboot = {}, updatetime = {}", info["sn"].get<string>(), ctime(&tsLastBoot), ctime(&tsUpdateTime));
spdlog::info("evslicer info: sn = {}, lastboot = {}, updatetime = {}", info["sn"].get<string>(), ctime(&tsLastBoot), ctime(&tsUpdateTime));
devSn = info["sn"];
ret = LVDB::getLocalConfig(config);
if(ret < 0) {
spdlog::error("failed to get local configuration");
exit(1);
}
// TODO: read local slices list and last index
while(!inited) {
// TODO: req config
bool found = false;
try {
ret = LVDB::getLocalConfig(config);
if(ret < 0) {
spdlog::error("failed to get local configuration");
exit(1);
}
spdlog::info("config: {:s}", config.dump());
json evslicer;
json evmgr;
......
opencv-motion-detect/inc/database.h
浏览文件 @ ed80379a
......@@ -41,7 +41,10 @@ namespace LVDB {
// log
int getLog(json &log, json &writeOptions, string fileName);
int setLog(json &log, json &readOptions, string fileName);
int setLog(json &log, json &readOptions, string fileName);
typedef int(*cb_traverse_configration_module)(string modname, json &mod);
int traverseConfigureModules(json &config, cb_traverse_configration_module cb, string moduleName = "");
}
#endif
\ No newline at end of file
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论