Verified Commit af6d9da7 authored by Alberto Miranda's avatar Alberto Miranda ♨️
Browse files

Fix mismatching `recv()`

parent 581493b4

src/master.cpp

+2 −2
Original line number Diff line number Diff line
@@ -119,8 +119,8 @@ master_server::mpi_listener_ult() { 
        switch(static_cast<cargo::tag>(msg->tag())) {

            case tag::status: {

                status_message m;

                world.recv(mpi::any_source, msg->tag(), m);

                LOGGER_INFO("msg => from: {} body: {{status: {}}}",

                world.recv(msg->source(), msg->tag(), m);

                LOGGER_INFO("msg => from: {} body: {{payload: {}}}",

                            msg->source(), m);



                m_request_manager.update(m.tid(), m.seqno(), msg->source() - 1,

src/worker/worker.cpp

+1 −1
Original line number Diff line number Diff line
@@ -120,7 +120,7 @@ worker::run() { 
                [[fallthrough]];

            case tag::sequential: {

                transfer_message m;

                world.recv(0, msg->tag(), m);

                world.recv(msg->source(), msg->tag(), m);

                LOGGER_INFO("msg => from: {} body: {}", msg->source(), m);



                const auto op = operation::make_operation(