#include <iostream>
|
#include <unistd.h>
|
#include <sys/time.h>
|
#include <vector>
|
#include <boost/interprocess/shared_memory_object.hpp>
|
#include <boost/interprocess/mapped_region.hpp>
|
|
#include <jsoncpp/json/json.h>
|
#include <SemTool.h>
|
#include <basic/util/app/AppConfig.h>
|
#include <basic/debug/Debug.h>
|
|
#include "ErlangDbTool.h"
|
#include "ShareMemoryTool.hpp"
|
|
using namespace std;
|
|
//#erl -name b@192.168.1.164 -setcookie abc -mnesia dir '"/home/firefly/erlang"' -detached -noshell
|
int main(int argc, char **argv) {
|
std::cout << "Hello, World!" << std::endl;
|
ENABLEGLOG(GET_STR_CONFIG("logPath").c_str());
|
|
if (argc <= 1) {
|
ERR("argc size is err");
|
exit(-1);
|
}
|
|
string str_json(argv[1]);
|
// cout << str_json << endl;
|
// string str_json = "{\"path\":\"/opt/erlang/sub1/\",\"nodeName\":\"sub1@192.168.1.186\",\"cookie\":\"abc\",\"tableName\":\"test\"}";
|
|
Json::Value t_json;
|
Json::Reader reader;
|
|
if (!reader.parse(str_json, t_json)) {
|
ERR("json format error :: " << str_json);
|
return -1;
|
}
|
|
int loop = 0;
|
|
std::string path = t_json["path"].asString();//"/opt/erlang/za/";
|
std::string nodeName = t_json["nodeName"].asString();//"za@192.168.188.128";
|
std::string cookie = t_json["cookie"].asString();//"abc";
|
std::string tableName = t_json["tableName"].asString();
|
|
// SemTool semTool(t_json["key"].asInt());
|
//
|
// semTool.semaphore_p();
|
|
|
/***
|
* jiazai renlian
|
*/
|
// struct timeval t1, t2;
|
// gettimeofday(&t1, NULL);
|
|
|
std::string str_node("testNode");
|
str_node.append(to_string((int) getpid()));
|
ErlangTool::ErlangDbTool erlangDbTool(nodeName, cookie, str_node);
|
while (1) {
|
/***
|
* load fea
|
*/
|
|
auto cache = erlangDbTool.loadFaceFeaData(tableName);
|
|
// gettimeofday(&t2, NULL);
|
//那么函数f运行所花的时间为
|
// auto deltaT = (t2.tv_sec - t1.tv_sec) * 1000000 + t2.tv_usec - t1.tv_usec;
|
// DBG(" loadData " << deltaT << "us")
|
// DBG(tableName << "size is " << cache.size() << " " << loop);
|
if (cache.size() <= 0 && loop++ <= 10) {
|
usleep(100);
|
continue;
|
}
|
auto size = sizeof(cache[0]) * cache.size();
|
try {
|
BISTL::shared_memory_object::remove(tableName.c_str());
|
BISTL::BiMapFeaData biMapFeaData(tableName, size);
|
for (auto &item :cache) {
|
biMapFeaData.saveKeyOrValue(item.second.id, item.second.feature, item.second.img, item.second.idcard,
|
item.second.create_by, item.second.create_time, item.second.update_time);
|
}
|
auto mymap = biMapFeaData.getMap();
|
// for (auto it = mymap->begin(); it != mymap->end(); it++) {
|
// std::cout << "feature " << it->second.m_feature << std::endl;
|
// }
|
DBG("load ok " << tableName << "mymap size is " << mymap->size());
|
}
|
catch (const std::exception &e) {
|
printf("Exception:%s\n", e.what());
|
BISTL::shared_memory_object::remove(tableName.c_str());
|
}
|
break;
|
}
|
|
return 0;
|
}
|
