From e8994dfa0f1fe82b00dfd5abd8805e72d3009fd6 Mon Sep 17 00:00:00 2001 From: Dennis Klein Date: Thu, 8 Mar 2018 03:10:10 +0100 Subject: [PATCH] FairMQ: Disable post buffer ack on control band Seems to be unnecessary. --- fairmq/ofi/Socket.cxx | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/fairmq/ofi/Socket.cxx b/fairmq/ofi/Socket.cxx index 38bb2d29..0a69d508 100644 --- a/fairmq/ofi/Socket.cxx +++ b/fairmq/ofi/Socket.cxx @@ -320,9 +320,9 @@ try { if (size) { // Receive and process control message - auto ctrl2 = ReceiveControlMessage(); - assert(ctrl2->has_post_buffer_acknowledgement()); - assert(ctrl2->post_buffer_acknowledgement().size() == size); + // auto ctrl2 = ReceiveControlMessage(); + // assert(ctrl2->has_post_buffer_acknowledgement()); + // assert(ctrl2->post_buffer_acknowledgement().size() == size); // Send data auto ret = fi_send(fDataEndpoint, msg->GetData(), size, nullptr, fRemoteDataAddr, nullptr); @@ -375,12 +375,12 @@ try { throw SocketError(tools::ToString("Failed posting ofi receive buffer, reason: ", fi_strerror(ret))); // Create and send control message - auto ctrl2 = tools::make_unique(); - auto ack = tools::make_unique(); - ack->set_size(msg->GetSize()); - ctrl2->set_allocated_post_buffer_acknowledgement(ack.release()); - assert(ctrl2->IsInitialized()); - SendControlMessage(move(ctrl2)); + // auto ctrl2 = tools::make_unique(); + // auto ack = tools::make_unique(); + // ack->set_size(msg->GetSize()); + // ctrl2->set_allocated_post_buffer_acknowledgement(ack.release()); + // assert(ctrl2->IsInitialized()); + // SendControlMessage(move(ctrl2)); fi_cq_err_entry cqEntry; ret = fi_cq_sread(fDataCompletionQueueRx, &cqEntry, 1, nullptr, -1);