Skip to content
Snippets Groups Projects
Commit c1c526bf authored by Utz-Uwe Haus's avatar Utz-Uwe Haus Committed by Ali Mohammed
Browse files

Check maximum supported transfer size of endpoints, raise error

Better than having the error manifest in unclear issues from the provider.
parent f5d12657
Branches
No related tags found
No related merge requests found
...@@ -2522,6 +2522,11 @@ mstro_ofi__submit_component_descriptor_read(struct mstro_endpoint *my_ep, ...@@ -2522,6 +2522,11 @@ mstro_ofi__submit_component_descriptor_read(struct mstro_endpoint *my_ep,
DEBUG("Checking for PM config block MR at (remote addr) 0x%" PRIx64 ", key of len %zu value %" PRIx64 "\n", DEBUG("Checking for PM config block MR at (remote addr) 0x%" PRIx64 ", key of len %zu value %" PRIx64 "\n",
mr_addr, inforeg->raw_key.len, mr_key); mr_addr, inforeg->raw_key.len, mr_key);
if(sizeof(g_pm_component_descriptor) > my_ep->fi->ep_attr->max_msg_size) {
ERR("component descriptor size exceeds endpoint's max_msg_size. FIXME: should split up operation\n");
}
assert(ctx->msg==NULL); assert(ctx->msg==NULL);
assert(my_ep->peer_info_mr!=NULL); /* incoming buffer has been registered at local endpoint set creation */ assert(my_ep->peer_info_mr!=NULL); /* incoming buffer has been registered at local endpoint set creation */
void * local_buf_mr_desc = fi_mr_desc(my_ep->peer_info_mr); void * local_buf_mr_desc = fi_mr_desc(my_ep->peer_info_mr);
......
...@@ -543,6 +543,12 @@ mstro_transport_rdma_dst_execute(mstro_cdo cdo_dst, Mstro__Pool__TransferTicket* ...@@ -543,6 +543,12 @@ mstro_transport_rdma_dst_execute(mstro_cdo cdo_dst, Mstro__Pool__TransferTicket*
ctx->ep = app_entry->ep; ctx->ep = app_entry->ep;
mstro_ofi__remember_ctx(app_entry->ep, ctx); mstro_ofi__remember_ctx(app_entry->ep, ctx);
if(len> app_entry->ep->fi->ep_attr->max_msg_size) {
ERR("Transfer size exceeds endpoint's maximum operation size. FIXME: should split up operation\n");
status=MSTRO_UNIMPL;
goto BAILOUT;
}
int num_retries = 3; int num_retries = 3;
RETRY_RDMA_TRANSPORT_READ: ; RETRY_RDMA_TRANSPORT_READ: ;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment