#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 <thread>
|
|
#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) {
|
ENABLEGLOG(GET_STR_CONFIG("logPath").c_str());
|
std::cout << "Hello, World!" << std::endl;
|
|
|
|
|
|
|
// string str_json(argv[1]);
|
//0096ee77-1f50-48e2-a08a-42536a754970@192.168.1.124
|
// string str_json = "{\"path\":\"/opt/erlang/0096ee77-1f50-48e2-a08a-42536a754970/\","
|
// "\"nodeName\":\"0096ee77-1f50-48e2-a08a-42536a754970@192.168.1.124\",\"cookie\":\"1234\","
|
// "\"tableName\":\"test\"}";
|
|
string str_json = "{\"personList\":[{\"idcard\":\"www\",\"name\":\"www\",\"personId\":\"1532\",\"feature\":\"13dasd\"},"
|
"{\"idcard\":\"133310998877665544\",\"name\":\"测试教师-三班班主任\",\"personId\":\"1533\","
|
"\"feature\":\"13dasd\"}],\"uuid\":\"16011ab6-c966-5114-afa5-569c91f866c3\"}";
|
|
Json::Value t_json;
|
Json::Reader reader;
|
|
if (!reader.parse(str_json, t_json)) {
|
return -1;
|
}
|
string TableUuid = t_json["uuid"].asString();
|
auto perlists = t_json["personList"];
|
|
int lsize = perlists.size();
|
for (int i = 0; i < lsize; ++i) {
|
// perlists[0]
|
}
|
for (auto &item : perlists) {
|
item["idcard"].asString();
|
item["personId"].asString();
|
item["feature"].asString();
|
int i = 0;
|
}
|
|
|
return 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();
|
|
|
ErlangTool::ErlangDbTool erlangDbTool(nodeName, cookie, "test");
|
|
|
// bool ret = erlangDbTool.initErlang();
|
ErlangTool::map_FaceDataCache cache;
|
|
std::thread thread1([&] {
|
while (1) {
|
/***
|
* jiazai renlian
|
*/
|
struct timeval t1, t2;
|
gettimeofday(&t1, NULL);
|
|
/***
|
* load fea
|
*/
|
cache = erlangDbTool.loadFaceFeaData(tableName);
|
|
gettimeofday(&t2, NULL);
|
//那么函数f运行所花的时间为
|
auto deltaT = (t2.tv_sec - t1.tv_sec) * 1000000 + t2.tv_usec - t1.tv_usec;
|
std::cout << __FILE__ << __LINE__ << " deltaT " << deltaT << "us size is " << cache.size() << std::endl;
|
|
}
|
});
|
|
std::thread thread2([&] {
|
while (1) {
|
/***
|
* jiazai renlian
|
*/
|
struct timeval t1, t2;
|
gettimeofday(&t1, NULL);
|
|
/***
|
* load fea
|
*/
|
auto cache2 = erlangDbTool.findAllNode();
|
|
gettimeofday(&t2, NULL);
|
//那么函数f运行所花的时间为
|
auto deltaT = (t2.tv_sec - t1.tv_sec) * 1000000 + t2.tv_usec - t1.tv_usec;
|
std::cout << __FILE__ << __LINE__ << " deltaT " << deltaT << "us size is " << cache2.size() << std::endl;
|
|
}
|
});
|
|
|
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.c_str(), item.second.feature.c_str(),
|
item.second.create_by.c_str(),
|
item.second.create_time.c_str(), item.second.update_time.c_str());
|
}
|
|
// auto mymap = biMapFeaData.getMap();
|
// for (auto it = mymap->begin(); it != mymap->end(); it++) {
|
// std::cout << "feature " << it->second.m_feature << std::endl;
|
// }
|
printf("\n");
|
|
}
|
catch (const std::exception &e) {
|
printf("Exception:%s\n", e.what());
|
BISTL::shared_memory_object::remove(tableName.c_str());
|
}
|
printf("getchar\n");
|
getchar();
|
|
|
return 0;
|
}
|
