Skip to content

Commit 5e3e9ed

Browse files
committed
fix(amqueue): make data write synchronous
1 parent 6dd8c92 commit 5e3e9ed

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

implementations/active-message-queue/active-message-queue.hpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -224,8 +224,8 @@ template <typename T> class AMQueue {
224224
return false;
225225
}
226226

227-
write_async(&data, offset, this->_dequeuer_rank,
228-
queue_num ? this->_data_1_win : this->_data_0_win);
227+
write_sync(&data, offset, this->_dequeuer_rank,
228+
queue_num ? this->_data_1_win : this->_data_0_win);
229229
fetch_and_add_sync(&writer_count, -1, 0, this->_dequeuer_rank,
230230
queue_num ? this->_writer_count_1_win
231231
: this->_writer_count_0_win);

0 commit comments

Comments
 (0)