Added wait for replication event

code/cppfol/src/TaskThread.cpp

@@ -105,7 +105,7 @@ inline void *TaskThread::run(void *object)
 
 void TaskThread::processEvent(RdmaSalEndpoint *ep, struct ibv_wc *data)
 {
-    std::cout << "processing sal event\n";
+    std::cout << "processing sal event"<<data->opcode<<"\n";
     /* sal Request*/
     switch (data->opcode)
     {
@@ -120,6 +120,7 @@ void TaskThread::processEvent(RdmaSalEndpoint *ep, struct ibv_wc *data)
         rdma_post_recv(ep->_cm_id, (void *)data->wr_id, (void *)data->wr_id,
                        ep->_recvMsgSize, ep->_recvMr);
         struct MessageHeader *req = (struct MessageHeader *)buffer;
+        std::cout<<"recv"<<req->type<<"\n";
         std::shared_ptr<CQEventData> cqevent = std::make_shared<CQEventData>(_serverRepMap->size() + _clientRepMap->size(), ep);
         uint32_t id = req->id;
         /*
@@ -161,7 +162,7 @@ void TaskThread::processEvent(RdmaSalEndpoint *ep, struct ibv_wc *data)
 
 void TaskThread::processRepEvent(RdmaRepEndpoint *ep, struct ibv_wc *data)
 {
-    std::cout << "processing rep event\n";
+    std::cout << "processing rep event"<<data->opcode<<"\n";
     switch (data->opcode)
     {
     case IBV_WC_SEND:
@@ -175,6 +176,7 @@ void TaskThread::processRepEvent(RdmaRepEndpoint *ep, struct ibv_wc *data)
         rdma_post_recv(ep->_cm_id, (void *)data->wr_id, (void *)data->wr_id,
                        ep->_recvMsgSize, ep->_recvMr);
         struct MessageHeader *req = (struct MessageHeader *)buffer;
+        std::cout<<"recv"<<req->type<<"\n";
         switch (req->type)
         {
         case MessageType::GET: