diff --git a/src/tests/c_api/test_join_sail.cpp b/src/tests/c_api/test_join_sail.cpp index fed3339..51b9a82 100644 --- a/src/tests/c_api/test_join_sail.cpp +++ b/src/tests/c_api/test_join_sail.cpp @@ -123,6 +123,19 @@ int main(int argc, char** argv) { js1_header.push_back(curr_header); } + // Send header to P2 + MPI_Send(js1_header_toSend.data(), js1_header_toSend.size(), MPI_LONG_LONG, 1, HEADER_TAG, MPI_COMM_WORLD); + + // Receive P2's header and convert to string + std::vector js2_header_toReceive(COLS2); + MPI_Recv(js2_header_toReceive.data(), COLS2, MPI_LONG_LONG, 1, HEADER_TAG, MPI_COMM_WORLD, MPI_STATUS_IGNORE); + + std::vector js2_header; + for(size_t i = 0; i js2_header_toReceive(COLS2); - MPI_Recv(js2_header_toReceive.data(), COLS2, MPI_LONG_LONG, 1, HEADER_TAG, MPI_COMM_WORLD, MPI_STATUS_IGNORE); - - std::vector js2_header; - for(size_t i = 0; i js1_header_toReceive(COLS1); + MPI_Recv(js1_header_toReceive.data(), COLS1, MPI_LONG_LONG, 0, HEADER_TAG, MPI_COMM_WORLD, MPI_STATUS_IGNORE); + + std::vector js1_header; + for(size_t i = 0; i js1_header_toReceive(COLS1); - MPI_Recv(js1_header_toReceive.data(), COLS1, MPI_LONG_LONG, 0, HEADER_TAG, MPI_COMM_WORLD, MPI_STATUS_IGNORE); - - std::vector js1_header; - for(size_t i = 0; i