From e15c4888f720b8781260b901ac82d058f8f7c3b5 Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期三, 27 三月 2019 14:34:37 +0800
Subject: [PATCH] 移植nsq到项目中,将最短最长时长的参数修改成nsq配置

---
 QiaoJiaSystem/FaceSearchServer/FaceDBCompareServer.cpp |   11 +++++++++--
 1 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/QiaoJiaSystem/FaceSearchServer/FaceDBCompareServer.cpp b/QiaoJiaSystem/FaceSearchServer/FaceDBCompareServer.cpp
index 368c9c2..1c7ca29 100644
--- a/QiaoJiaSystem/FaceSearchServer/FaceDBCompareServer.cpp
+++ b/QiaoJiaSystem/FaceSearchServer/FaceDBCompareServer.cpp
@@ -54,10 +54,13 @@
 
 //#todo map 1->2 modify 2->1
 bool FaceDBCompareServer::compare(thread::id key, AlarmData *alarmData, int topN) {
+    m_dbRWLocks_Lock.wrlock();
     if (m_dbRWLocks.find(key) == m_dbRWLocks.end()) {
         m_dbRWLocks[key] = RWLock();
     }
     RWLock &t_rwl = m_dbRWLocks[key];
+    DBG("m_dbRWLocks ok");
+    m_dbRWLocks_Lock.unlock();
 //    ClockTimer clockTimer("compare ");
     RWLock t_rwLock;
 
@@ -116,7 +119,9 @@
     int maxSearchFaces = alarmData->num;
 
     t_rwl.wrlock();
+    DBG("topResult[key] before");
     auto &t_topResult = topResult[key];
+    DBG("topResult[key] ok");
     t_topResult.clear();
     for (auto &item : t_compareResults) {
         auto &it = item.second;
@@ -194,9 +199,9 @@
             //            鍚屾搴�/鐗瑰緛鏄痓ase64
 //            #todo sqlite search data from file
             auto str_tab = t_json["\"tableName\""].asString();
+            DBG("str_tab is  " << str_tab);
             m_tableName = str_tab.substr(1, str_tab.length() - 2);//.append("_fea");
-
-
+            DBG("m_tableName is  " << m_tableName);
 
 //            string tet = "./syncDBClient ";
 //            string str_json = writer.write(t_json);
@@ -210,6 +215,7 @@
 //                auto mymap = biMapFeaData.getMap();
 
                 auto mymap = m_erlangDbTool->loadFaceFeaData(m_tableName);
+                DBG(m_tableName << "  db size is  " << mymap.size());
                 for (auto &item : mymap) {
                     auto &it = item.second;
                     string str2;
@@ -246,6 +252,7 @@
                 printf("Exception:%s\n", e.what());
 //                BISTL::shared_memory_object::remove(m_tableName.c_str());
             }
+            appPref.setIntData(m_tableName, 1);
 //            BISTL::shared_memory_object::remove(m_tableName.c_str());
         } else {
             //#todo get sqlite3 data

--
Gitblit v1.8.0