提交 c057d832 authored 作者: blu's avatar blu

upload video files

上级 68dce7c5
...@@ -44,6 +44,39 @@ private: ...@@ -44,6 +44,39 @@ private:
mutex eventQLock; mutex eventQLock;
thread thMsgProcessor; thread thMsgProcessor;
void loadConfigMap(){
// load configmap
json cnfm;
int ret = LVDB::getValue(cnfm, KEY_CONFIG_MAP);
if(ret < 0 || cnfm.size() == 0) {
this->configMap["sn2mods"] = json();
this->configMap["mod2mgr"] = json();
int iret = LVDB::setValue(this->configMap, KEY_CONFIG_MAP);
if(iret >= 0) {
}
else {
spdlog::error("evcloudsvc failed to save configmap");
exit(1);
}
}
else {
this->configMap = cnfm;
}
// populate peerData
for(auto &[k,v]: this->configMap["sn2mods"].items()){
// load config from database
json cfg;
if(LVDB::getLocalConfig(cfg, k) < 0) {
spdlog::error("evcloudsvc failed to load config for device: {}", k);
}else{
this->peerData["config"][k] = cfg;
spdlog::info("evcloudsvc loaded config for device: {}", k);
}
}
}
int sendConfig(json &config_, string sn) { int sendConfig(json &config_, string sn) {
int ret = 0; int ret = 0;
string cfg = config_.dump(); string cfg = config_.dump();
...@@ -426,37 +459,6 @@ protected: ...@@ -426,37 +459,6 @@ protected:
public: public:
void run() void run()
{ {
// load configmap
json cnfm;
int ret = LVDB::getValue(cnfm, KEY_CONFIG_MAP);
if(ret < 0 || cnfm.size() == 0) {
this->configMap["sn2mods"] = json();
this->configMap["mod2mgr"] = json();
int iret = LVDB::setValue(this->configMap, KEY_CONFIG_MAP);
if(iret >= 0) {
}
else {
spdlog::error("evcloudsvc failed to save configmap");
exit(1);
}
}
else {
this->configMap = cnfm;
}
// populate peerData
for(auto &[k,v]: this->configMap["sn2mods"].items()){
// load config from database
json cfg;
if(LVDB::getLocalConfig(cfg, k) < 0) {
spdlog::error("evcloudsvc failed to load config for device: {}", k);
}else{
this->peerData["config"][k] = cfg;
spdlog::info("evcloudsvc loaded config for device: {}", k);
}
}
svr.Get("/config", [this](const Request& req, Response& res) { svr.Get("/config", [this](const Request& req, Response& res) {
json ret; json ret;
ret["code"] = 0; ret["code"] = 0;
...@@ -579,6 +581,7 @@ public: ...@@ -579,6 +581,7 @@ public:
{ {
int ret = 0; int ret = 0;
spdlog::info("evcloudsvc boot"); spdlog::info("evcloudsvc boot");
loadConfigMap();
char *strEnv = getenv("HTTP_PORT"); char *strEnv = getenv("HTTP_PORT");
if(strEnv != nullptr) { if(strEnv != nullptr) {
httpPort = strEnv; httpPort = strEnv;
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论