refractor taskthread to remove

code/cppfol/src/TaskThread.cpp

@@ -136,7 +136,7 @@ void TaskThread::processSalEvent(RdmaSalEndpoint *ep, struct ibv_wc *data)
         else if (req->type == MessageType::DELETE)
         {
             std::unique_lock<std::mutex> lock(_cqEventsMutex);
-            _cqEvents[id] = cqevent;
+            _cqEvents.emplace(id,cqevent);
             lock.unlock();
             replicateSalRequest(buffer, data->byte_len);
             sendInvalidation(buffer);
@@ -149,7 +149,7 @@ void TaskThread::processSalEvent(RdmaSalEndpoint *ep, struct ibv_wc *data)
         else if (req->type == MessageType::PUT)
         {
             std::unique_lock<std::mutex> lock(_cqEventsMutex);
-            _cqEvents[id] = cqevent;
+            _cqEvents.emplace( id ,cqevent);
             lock.unlock();
             replicateSalRequest(buffer, data->byte_len);
             sendInvalidation(buffer);
@@ -252,11 +252,11 @@ void TaskThread::processReplicationDone(uint32_t id, MessageType type, bool loca
         // std::cout<<"event 2\n";
         return;
     }
+    RdmaSalEndpoint *ep = it->second->_ep;
+
     _cqEvents.erase(it);
     cqEventlock.unlock();
 
-    RdmaSalEndpoint *ep = it->second->_ep;
-    
     void *sendBuf = nullptr;
     sendBuf = ep->getBuffer();
     if(sendBuf == nullptr)