Skip to content

Test ssend #20

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
hzhou wants to merge 21 commits into
base: main
Choose a base branch
from
Open

Test ssend #20

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
21 commits
Select commit Hold shift + click to select a range
bbd0f5c
test/xfail: remove multi-thread huge send xfails
hzhou Sep 20, 2021
30f1c6e
test: add more tests for sending huge message
hzhou Sep 22, 2021
9d5c2c9
test: enhance test/mpi/pt2pt/probe_unexp.c
hzhou Sep 27, 2021
f53eff1
ch4/ofi: remove done_fn in MPIDI_OFI_huge_recv_t
hzhou Sep 24, 2021
ac2d82b
ch4/ofi: refactor sending ctrl messages
hzhou Sep 24, 2021
9d48318
ch4/ofi: refactor huge functions to separate file
hzhou Sep 24, 2021
4e9d269
ch4/ofi: fix fi_read in enable_striping
hzhou Sep 28, 2021
1e1ad68
ch4/ofi: detect normal send in event loop
hzhou Sep 26, 2021
4f661a7
ch4/ofi: detect huge message data truncation
hzhou Sep 24, 2021
b63867e
ch4/ofi: swap order of sending huge ctrl
hzhou Sep 24, 2021
0ec4a61
ch4/ofi: remove debug messages from huge path
hzhou Sep 26, 2021
f33a14a
ch4/ofi: differentiate probe and mprobe of huge messages
hzhou Sep 26, 2021
54b3905
ch4/ofi: remove MPIDI_OFI_global.huge_send_counters
hzhou Sep 26, 2021
a7e5407
ch4/ofi: remove huge_recv_counters
hzhou Sep 26, 2021
1b4f505
ch4/ofi: revamp huge message handling
hzhou Sep 26, 2021
81fa0ad
ch4/ofi: split get_huge_complete
hzhou Sep 27, 2021
8886473
ch4/ofi: handle when huge message sent to small buffer
hzhou Sep 27, 2021
9e8c23d
ch4/ofi: add vni assertions in control handler
hzhou Sep 27, 2021
ddc0f97
ch4/ofi: set recv data_sz correctly in the huge path
hzhou Sep 27, 2021
ca8c3f3
ch4/ofi: fix usage of comm_id
hzhou Sep 27, 2021
4e57600
test: threads/pt2pt/ssend.c
hzhou Sep 28, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions src/mpid/ch4/netmod/ofi/Makefile.mk
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ mpi_core_sources += src/mpid/ch4/netmod/ofi/func_table.c \
src/mpid/ch4/netmod/ofi/ofi_win.c \
src/mpid/ch4/netmod/ofi/ofi_part.c \
src/mpid/ch4/netmod/ofi/ofi_events.c \
src/mpid/ch4/netmod/ofi/ofi_huge.c \
src/mpid/ch4/netmod/ofi/ofi_progress.c \
src/mpid/ch4/netmod/ofi/ofi_am_events.c \
src/mpid/ch4/netmod/ofi/ofi_nic.c \
Expand Down
8 changes: 4 additions & 4 deletions src/mpid/ch4/netmod/ofi/globals.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,10 @@
#include "ofi_impl.h"
MPIDI_OFI_global_t MPIDI_OFI_global;

MPIDI_OFI_huge_recv_t *MPIDI_unexp_huge_recv_head = NULL;
MPIDI_OFI_huge_recv_t *MPIDI_unexp_huge_recv_tail = NULL;
MPIDI_OFI_huge_recv_list_t *MPIDI_posted_huge_recv_head = NULL;
MPIDI_OFI_huge_recv_list_t *MPIDI_posted_huge_recv_tail = NULL;
MPIDI_OFI_huge_recv_list_t *MPIDI_huge_ctrl_head = NULL;
MPIDI_OFI_huge_recv_list_t *MPIDI_huge_ctrl_tail = NULL;
MPIDI_OFI_huge_recv_list_t *MPIDI_huge_recv_head = NULL;
MPIDI_OFI_huge_recv_list_t *MPIDI_huge_recv_tail = NULL;

unsigned long long PVAR_COUNTER_nic_sent_bytes_count[MPIDI_OFI_MAX_NICS] ATTRIBUTE((unused));
unsigned long long PVAR_COUNTER_nic_recvd_bytes_count[MPIDI_OFI_MAX_NICS] ATTRIBUTE((unused));
Expand Down
35 changes: 0 additions & 35 deletions src/mpid/ch4/netmod/ofi/ofi_control.h
View file
Open in desktop

This file was deleted.

317 changes: 15 additions & 302 deletions src/mpid/ch4/netmod/ofi/ofi_events.c
View file
Open in desktop

Large diffs are not rendered by default.

11 changes: 7 additions & 4 deletions src/mpid/ch4/netmod/ofi/ofi_events.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -9,11 +9,9 @@
#include "ofi_impl.h"
#include "ofi_am_impl.h"
#include "ofi_am_events.h"
#include "ofi_control.h"
#include "utlist.h"

int MPIDI_OFI_rma_done_event(int vni, struct fi_cq_tagged_entry *wc, MPIR_Request * in_req);
int MPIDI_OFI_get_huge_event(int vni, struct fi_cq_tagged_entry *wc, MPIR_Request * req);
int MPIDI_OFI_dispatch_function(int vni, struct fi_cq_tagged_entry *wc, MPIR_Request * req);

MPL_STATIC_INLINE_PREFIX int MPIDI_OFI_cqe_get_source(struct fi_cq_tagged_entry *wc, bool has_err)
Expand Down Expand Up @@ -55,8 +53,14 @@ MPL_STATIC_INLINE_PREFIX int MPIDI_OFI_recv_event(int vni, struct fi_cq_tagged_e
size_t count;
MPIR_FUNC_ENTER;

if (wc->tag & MPIDI_OFI_HUGE_SEND) {
mpi_errno = MPIDI_OFI_recv_huge_event(vni, wc, rreq);
goto fn_exit;
}
rreq->status.MPI_SOURCE = MPIDI_OFI_cqe_get_source(wc, true);
rreq->status.MPI_ERROR = MPIDI_OFI_idata_get_error_bits(wc->data);
if (!rreq->status.MPI_ERROR) {
rreq->status.MPI_ERROR = MPIDI_OFI_idata_get_error_bits(wc->data);
}
rreq->status.MPI_TAG = MPIDI_OFI_init_get_tag(wc->tag);
count = wc->len;
MPIR_STATUS_SET_COUNT(rreq->status, count);
Expand Down Expand Up @@ -131,7 +135,6 @@ MPL_STATIC_INLINE_PREFIX int MPIDI_OFI_recv_event(int vni, struct fi_cq_tagged_e

MPIDIU_request_complete(rreq);

/* Polling loop will check for truncation */
fn_exit:
MPIR_FUNC_EXIT;
return mpi_errno;
Expand Down
Loading