Skip to content
Snippets Groups Projects
Commit c56b4fc5 authored by Utz-Uwe Haus's avatar Utz-Uwe Haus
Browse files

Add missing mreg table locks in RDMA transport

Closes #69 on JSC issue tracker
parent b543ae3a
Branches
Tags
No related merge requests found
Pipeline #77871 passed
......@@ -183,6 +183,12 @@ mstro_transport_rdma_src_execute(mstro_cdo src, Mstro__Pool__TransferTicket* tic
return MSTRO_FAIL;
}
int err = pthread_mutex_lock(&g_mstro_transport_mreg_table_lock);
if (err) {
ERR("Couldn't lock mutex on mreg table\n");
return MSTRO_FAIL;
}
status = mstro_transport_rdma__mreg_entry_find__locked(e->ep, cdo_id_p, &regentry);
if (regentry) {
......@@ -297,6 +303,13 @@ mstro_transport_rdma_src_execute_bh(Mstro__Pool__TransferCompleted *tc)
return MSTRO_FAIL;
}
int err = pthread_mutex_lock(&g_mstro_transport_mreg_table_lock);
if (err) {
ERR("Couldn't lock mutex on mreg table\n");
return MSTRO_FAIL;
}
status = mstro_transport_rdma__mreg_entry_find__locked(e->ep, &cdoid, &regentry);
if (!regentry) {
......@@ -313,7 +326,7 @@ mstro_transport_rdma_src_execute_bh(Mstro__Pool__TransferCompleted *tc)
DEBUG ("Unregistering memory region (start: %p) used for RDMA\n", regentry->addr);
int err = fi_close((struct fid*)regentry->mr_reg);
err = fi_close((struct fid*)regentry->mr_reg);
if(err) {
ERR("Couldn't unregister memory region for RDMA transport (err: %d)\n", err);
status=MSTRO_FAIL;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment