diff --git a/mustard/broker_queue.h b/mustard/broker_queue.h index 98fd12d..dd4aa69 100644 --- a/mustard/broker_queue.h +++ b/mustard/broker_queue.h @@ -128,7 +128,7 @@ class BrokerWorkDistributorT { putData(data, pe); } - return false; + return writeData; } __device__ inline void dequeue(bool &hasData, unsigned int &data, int pe)