fix: gil fault

Author: whybeyoung

pyWrapper.cpp

@@ -264,7 +264,6 @@ int PyWrapper::wrapperOnceExec(const char *usrTag, std::map <std::string, std::s
         }
         SetSidUsrTag(sid, usrTag);
         params["sid"] = sid;
-        py::gil_scoped_acquire acquire;
         // 执行python exec 推理
         py::object r = _wrapperOnceExec(params, reqData, usrTag);
         // 此段根据python的返回 ，回写 respData
@@ -352,7 +351,6 @@ int PyWrapper::wrapperOnceExecAsync(const char *usrTag, std::map <std::string, s
         int ret = 0;
         SetSidUsrTag(sid, usrTag);
         params["sid"] = sid;
-        py::gil_scoped_acquire acquire;
         // 执行python exec 推理
         py::object r = _wrapperOnceExecAsync(params, reqData, sid);
         // 此段根据python的返回 ，回写 respData
@@ -433,7 +431,6 @@ PyWrapper::wrapperCreate(const char *usrTag, std::map <std::string, std::string>
 int PyWrapper::wrapperWrite(char *handle, DataListCls reqData, std::string sid) {
     try {
         int ret = 0;
-        py::gil_scoped_acquire acquire;
         // 执行python exec 推理
         py::object r = _wrapperWrite(handle, reqData, sid);
         ret = r.cast<int>();
@@ -453,7 +450,6 @@ int PyWrapper::wrapperWrite(char *handle, DataListCls reqData, std::string sid)
 int PyWrapper::wrapperRead(char *handle, pDataList *respData, std::string sid) {
     try {
         Response *resp;
-        py::gil_scoped_acquire acquire;
         // 执行python exec 推理
         py::object r = _wrapperRead(handle, sid);
         spdlog::debug("start cast python resp to c++ object, thread_id: {}, sid: {}", gettid(), sid);
@@ -667,11 +663,17 @@ const char *GetSidUsrTag(std::string sid) {
 }
 
 const std::string GetSidByUsrTag(const char *usrTag) {
+    RECORD_MUTEX.lock();
     //通过value找 key
     for (std::map<std::string, const char *>::iterator it = SID_USRTAG.begin(); it != SID_USRTAG.end(); it++) {
-        if (it->second == usrTag)
+        if (it->second == usrTag){
+    		RECORD_MUTEX.unlock();
             return it->first;
+
+        }
     }
+    RECORD_MUTEX.unlock();
+
     return "";
 }
 

wrapper.cpp

@@ -189,6 +189,8 @@ int WrapperAPI wrapperWrite(const void *handle, pDataList reqData) {
 
     DataListCls req;
     pDataList p = reqData;
+    py::gil_scoped_acquire acquire;
+
     if (dataNum > 0) {
         for (int tmpIdx = 0; tmpIdx < dataNum; tmpIdx++) {
             DataListNode item;
@@ -218,6 +220,7 @@ int WrapperAPI wrapperWrite(const void *handle, pDataList reqData) {
 
 int WrapperAPI wrapperRead(const void *handle, pDataList *respData) {
     int ret = 0;
+    py::gil_scoped_acquire acquire;
     std::string sid = GetHandleSid((char *) handle);
     // 构造响应数据
     printf("start read...sid %s\n", sid.c_str());
@@ -246,6 +249,8 @@ wrapperExec(const char *usrTag, pParamList params, pDataList reqData, pDataList
             int psrCnt) {
     int ret = 0;
     std::string sid = "";
+    py::gil_scoped_acquire acquire;
+
     for (pParamList sidP = params; sidP != NULL; sidP = sidP->next) {
         if (NULL == sidP->key) {
             continue;
@@ -273,17 +278,17 @@ wrapperExec(const char *usrTag, pParamList params, pDataList reqData, pDataList
     }
     spdlog::debug("call wrapper exec: building req data, data num:{}，sid:{}", dataNum, sid);
 
-    DataListCls req;
+    DataListCls *req = new DataListCls();
     pDataList p = reqData;
     if (dataNum > 0) {
         for (int tmpIdx = 0; tmpIdx < dataNum; tmpIdx++) {
 
-            DataListNode item;
-            item.key = p->key;
+            DataListNode *item = DataListNode();
+            item->key = p->key;
 
             // 直接拷贝
             size_t len = static_cast<size_t>(p->len);
-            item.data = py::bytes((char *) (p->data), len);
+            item->data = py::bytes((char *) (p->data), len);
             //
             // 写法2：
             //            Py_ssize_t len = static_cast<Py_ssize_t>(p->len);
@@ -296,11 +301,11 @@ wrapperExec(const char *usrTag, pParamList params, pDataList reqData, pDataList
             //            item.data = py::bytes(data);
             // todo 有无0拷贝方法？
 
-            item.len = p->len;
+            item->len = p->len;
             char t = static_cast<int>(p->type);
-            item.type = p->type;
+            item->type = p->type;
             spdlog::debug("reqDatatype :{}，sid:{}", p->type, sid);
-            req.list.push_back(item);
+            req->list.push_back(item);
             p = p->next;
         }
     }
@@ -368,6 +373,8 @@ wrapperExecAsync(const char *usrTag, pParamList params, pDataList reqData, wrapp
                  unsigned int psrIds[], int psrCnt) {
     int ret = 0;
     std::string sid = "";
+    py::gil_scoped_acquire acquire;
+
     for (pParamList sidP = params; sidP != NULL; sidP = sidP->next) {
         if (NULL == sidP->key) {
             continue;