Skip to content

H
hpdos
Commit 71c35087 authored by Paras Garg's avatar Paras Garg
Browse files
Options

Added code for follower

parent 184a3b67
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 2 deletions
code/cppfol/src/TaskThread.cpp
View file @ 71c35087
...@@ -52,11 +52,11 @@ inline void *TaskThread::run(void *object) ...@@ -52,11 +52,11 @@ inline void *TaskThread::run(void *object)
while (!thread->_stop) while (!thread->_stop)
{ {
struct ibv_wc *data = NULL; struct ibv_wc *data = NULL;
std::cout << "Get start\n"; //std::cout << "Get start\n";
data = thread->_taskQueue->try_pop(); data = thread->_taskQueue->try_pop();
if (data != NULL) if (data != NULL)
{ {
std::cout << "TaskThread:: got data"; //std::cout << "TaskThread:: got data";
if (data == NULL || data->status != IBV_WC_SUCCESS) if (data == NULL || data->status != IBV_WC_SUCCESS)
{ {
std::ostringstream ss; std::ostringstream ss;
...@@ -152,6 +152,7 @@ void TaskThread::processEvent(RdmaSalEndpoint *ep, struct ibv_wc *data) ...@@ -152,6 +152,7 @@ void TaskThread::processEvent(RdmaSalEndpoint *ep, struct ibv_wc *data)
void TaskThread::processRepEvent(RdmaRepEndpoint *ep, struct ibv_wc *data) void TaskThread::processRepEvent(RdmaRepEndpoint *ep, struct ibv_wc *data)
{ {
std::cout<<"processing rep event\n";
switch (data->opcode) switch (data->opcode)
{ {
case IBV_WC_SEND: case IBV_WC_SEND:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment