#include <iostream>
|
#include <unistd.h>
|
#include <sys/time.h>
|
#include <uuid/uuid.h>
|
#include <vector>
|
#include <boost/interprocess/shared_memory_object.hpp>
|
#include <boost/interprocess/mapped_region.hpp>
|
|
#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;
|
|
std::string path = "/opt/erlang/main/";
|
std::string nodeName = "main@192.168.1.124";
|
std::string cookie = "abc";
|
ErlangTool::ErlangDbTool *erlangDbTool;
|
auto erlNode = appConfig.getStringProperty("erlNode");
|
auto erlCookie = appConfig.getStringProperty("erlCookie");
|
auto erlPath = appConfig.getStringProperty("erlPath");
|
auto erlFatherNode = appConfig.getStringProperty("erlFatherNode");
|
if (erlNode.size() > 0 && erlCookie.size() > 0) {
|
string str_tmp = "DataWebserver";
|
erlangDbTool = new ErlangTool::ErlangDbTool(erlPath, erlNode, erlCookie, str_tmp);
|
if (erlangDbTool->initErlang() == 1) {
|
erlangDbTool->startNodeDb(erlFatherNode);
|
} else {
|
DBG("not is startNodeDb");
|
}
|
}
|
|
|
// ErlangTool::ErlangDbTool erlangDbTool(path, nodeName, cookie);
|
//
|
//
|
//
|
// bool ret = erlangDbTool->initErlang();
|
|
/**
|
* chushihua jiedian jiaru jiqun
|
*/
|
// erlangDbTool->startNodeDb(" ", " ");
|
// erlangDbTool->startNodeDb("za@192.168.50.216", " ");
|
//---------end--------------
|
|
|
|
// erlangDbTool->removeNode();
|
// auto devCache = erlangDbTool->findAllNode();
|
// INFO(devCache.size());
|
// for (auto &item:devCache) {
|
// DBG(item.first);
|
// }
|
|
//erlangDbTool->test();
|
/***
|
* chuanjian shuju ku
|
*/
|
// ret = erlangDbTool->createDatabase("person", "aaa1", true, "0");
|
// ret = erlangDbTool->createDatabase("person", "aaa2", true, "1");
|
// ret = erlangDbTool->createDatabase("car", "bbb1", false, "0");
|
// ret = erlangDbTool->createDatabase("car", "aaa4", true, "0");
|
// erlangDbTool->createDatabase("car","sycarYa32",false,"0");
|
// erlangDbTool->createDatabase("car","syperYa1",true,"1");
|
// erlangDbTool->createDatabase("person","syperYa2",false,"0");
|
//---------end--------------
|
|
// auto dbCache = erlangDbTool->findAllDatabase();
|
// auto bwCache = erlangDbTool->findAllTypeInfo();
|
//
|
// for (auto &item : dbCache) {
|
// INFO(item.first << " " << item.second.uuid);
|
// }
|
|
// return 0;
|
/***
|
* add Feature
|
*/
|
// for (int i = 0; i < 100; i++) {
|
//
|
// uuid_t uu;
|
// char str[36];
|
// uuid_generate(uu);
|
// uuid_unparse(uu, str);
|
//
|
// string uuid;
|
// string str2(str);
|
//// str2.append(str);
|
// str2.append(str2).append(str2).append(str2).append(str2).append(str2);
|
// auto size = str2.size();
|
//
|
//
|
//
|
//// struct timeval t1, t2;
|
//// gettimeofday(&t1, NULL);
|
//
|
// ret = erlangDbTool->addPerson(uuid, "aaa1", move(str2));
|
//// cout << i << " ret " << ret << " size " << size << " uuid " << uuid << endl;
|
//
|
//// 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 << std::endl;
|
//
|
// }
|
//---------end--------------
|
|
// return 0;
|
|
|
|
std::vector<SyncDB::AddPersonInfo> tmpPer;
|
SyncDB::AddPersonInfo addPersonInfo;
|
addPersonInfo.feature = "testFea22";
|
addPersonInfo.personPic = "testPic33";
|
addPersonInfo.idcard = "testidcard44";
|
for (int i = 0; i < 3; ++i) {
|
addPersonInfo.personid = std::to_string(i * 2);
|
tmpPer.push_back(addPersonInfo);
|
}
|
// auto resaddPersons = erlangDbTool->addPersons("077b251e-8698-5852-be8c-8c2d8334a162", tmpPer);
|
|
auto resUpdPersRet = erlangDbTool->singlePersonUpdate("12", "11", "testUpCardid", "testUpPic", "testUpFea");
|
|
// auto resPerEit = erlangDbTool->personIsExistOnClu("1");
|
|
|
/***
|
* jiazai renlian
|
*/
|
struct timeval t1, t2;
|
gettimeofday(&t1, NULL);
|
|
/***
|
* load fea
|
*/
|
auto cache = erlangDbTool->loadFaceFeaData2("测试中文12553");
|
|
for (auto &item : cache) {
|
DBG(item.first);
|
}
|
|
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;
|
|
|
|
|
|
// auto size = sizeof(cache[0]) * cache.size();
|
//
|
// try {
|
//
|
// BISTL::shared_memory_object::remove("aaa8");
|
//
|
// BISTL::BiMapFeaData biMapFeaData("aaa8", 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("aaa8");
|
// }
|
// printf("getchar\n");
|
getchar();
|
//--------end-----------
|
|
// erlangDbTool->deleteDatabase("person","aaa9", true);
|
|
|
// struct timeval t1, t2;
|
// gettimeofday(&t1, NULL);
|
|
// 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 << std::endl;
|
|
|
|
|
return 0;
|
}
|
|
|
int main3() {
|
|
// char cc = '1';
|
// for (int i = 0; i < 100; i++) {
|
// cc++;
|
// printf("%c \n", cc);
|
// }
|
|
|
uuid_t uu;
|
char str[36];
|
uuid_generate(uu);
|
uuid_unparse(uu, str);
|
|
string uuid;
|
string str2(str);
|
// str2.append(str);
|
str2.append(str2).append(str2).append(str2).append(str2).append(str2).append(str2).append(str2).append(str2).append(
|
str2).append(str2).append(str2).append(str2).append(str2).append(str2);
|
auto size = str2.size();
|
|
try {
|
|
BISTL::shared_memory_object::remove("SharedMemory");
|
// init
|
BISTL::managed_shared_memory segment(BISTL::create_only, "SharedMemory", 65536);
|
|
const BISTL::void_allocator alloc_inst(segment.get_segment_manager());
|
|
BISTL::bi_map_Feature_Info *mymap =
|
segment.construct<BISTL::bi_map_Feature_Info>("MyMap")(std::less<BISTL::char_string>(), alloc_inst);
|
|
|
for (int i = 0; i < 100; ++i) {
|
char tmp[16] = "";
|
sprintf(tmp, "test%d", i);
|
BISTL::char_string key_object(tmp, alloc_inst);
|
BISTL::Feature_Info v(tmp, "feature", "create_by", "create_time", "update_time", alloc_inst);
|
// v.id = key_object;
|
// v.feature = key_object;
|
BISTL::ValueType value(key_object, v);
|
mymap->insert(value);
|
}
|
|
for (BISTL::bi_map_Feature_Info::iterator it = mymap->begin(); it != mymap->end(); it++) {
|
|
std::cout << it->second.m_id << std::endl;
|
std::cout << it->second.m_feature << std::endl;
|
// it->second.id;
|
}
|
printf("\n");
|
|
// BISTL::shared_memory_object::remove("SharedMemory");
|
}
|
catch (const std::exception &e) {
|
printf("Exception:%s\n", e.what());
|
BISTL::shared_memory_object::remove("SharedMemory");
|
}
|
printf("getchar\n");
|
getchar();
|
return 0;
|
}
|
