memheap_oob 63 oshmem/mca/memheap/base/memheap_base_mkey.c struct oob_comm memheap_oob = {{{0}}}; memheap_oob 162 oshmem/mca/memheap/base/memheap_base_mkey.c &memheap_oob.mkeys[tr_id].va_base, memheap_oob 166 oshmem/mca/memheap/base/memheap_base_mkey.c if (0 == memheap_oob.mkeys[tr_id].va_base) { memheap_oob 168 oshmem/mca/memheap/base/memheap_base_mkey.c opal_dss.unpack(msg, &memheap_oob.mkeys[tr_id].u.key, &cnt, OPAL_UINT64); memheap_oob 170 oshmem/mca/memheap/base/memheap_base_mkey.c memheap_attach_segment(&memheap_oob.mkeys[tr_id], tr_id); memheap_oob 174 oshmem/mca/memheap/base/memheap_base_mkey.c opal_dss.unpack(msg, &memheap_oob.mkeys[tr_id].len, &cnt, OPAL_UINT16); memheap_oob 175 oshmem/mca/memheap/base/memheap_base_mkey.c if (0 < memheap_oob.mkeys[tr_id].len) { memheap_oob 176 oshmem/mca/memheap/base/memheap_base_mkey.c memheap_oob.mkeys[tr_id].u.data = malloc(memheap_oob.mkeys[tr_id].len); memheap_oob 177 oshmem/mca/memheap/base/memheap_base_mkey.c if (NULL == memheap_oob.mkeys[tr_id].u.data) { memheap_oob 178 oshmem/mca/memheap/base/memheap_base_mkey.c MEMHEAP_ERROR("Failed allocate %d bytes", memheap_oob.mkeys[tr_id].len); memheap_oob 181 oshmem/mca/memheap/base/memheap_base_mkey.c cnt = memheap_oob.mkeys[tr_id].len; memheap_oob 182 oshmem/mca/memheap/base/memheap_base_mkey.c opal_dss.unpack(msg, memheap_oob.mkeys[tr_id].u.data, &cnt, OPAL_BYTE); memheap_oob 184 oshmem/mca/memheap/base/memheap_base_mkey.c memheap_oob.mkeys[tr_id].u.key = MAP_SEGMENT_SHM_INVALID; memheap_oob 186 oshmem/mca/memheap/base/memheap_base_mkey.c MCA_SPML_CALL(rmkey_unpack(ctx, &memheap_oob.mkeys[tr_id], memheap_oob.segno, remote_pe, tr_id)); memheap_oob 191 oshmem/mca/memheap/base/memheap_base_mkey.c tr_id, mca_spml_base_mkey2str(&memheap_oob.mkeys[tr_id])); memheap_oob 245 oshmem/mca/memheap/base/memheap_base_mkey.c OPAL_THREAD_LOCK(&memheap_oob.lck); memheap_oob 246 oshmem/mca/memheap/base/memheap_base_mkey.c unpack_remote_mkeys(memheap_oob.ctx, buffer, source_pe); memheap_oob 247 oshmem/mca/memheap/base/memheap_base_mkey.c memheap_oob.mkeys_rcvd = MEMHEAP_RKEY_RESP; memheap_oob 248 oshmem/mca/memheap/base/memheap_base_mkey.c opal_condition_broadcast(&memheap_oob.cond); memheap_oob 249 oshmem/mca/memheap/base/memheap_base_mkey.c OPAL_THREAD_UNLOCK(&memheap_oob.lck); memheap_oob 254 oshmem/mca/memheap/base/memheap_base_mkey.c memheap_oob.mkeys_rcvd = MEMHEAP_RKEY_RESP_FAIL; memheap_oob 255 oshmem/mca/memheap/base/memheap_base_mkey.c opal_condition_broadcast(&memheap_oob.cond); memheap_oob 256 oshmem/mca/memheap/base/memheap_base_mkey.c OPAL_THREAD_UNLOCK(&memheap_oob.lck); memheap_oob 325 oshmem/mca/memheap/base/memheap_base_mkey.c r = (oob_comm_request_t *)opal_list_get_first(&memheap_oob.req_list); memheap_oob 327 oshmem/mca/memheap/base/memheap_base_mkey.c while(r != (oob_comm_request_t *)opal_list_get_end(&memheap_oob.req_list)) { memheap_oob 335 oshmem/mca/memheap/base/memheap_base_mkey.c opal_list_remove_first(&memheap_oob.req_list); memheap_oob 373 oshmem/mca/memheap/base/memheap_base_mkey.c opal_list_append(&memheap_oob.req_list, &r->super); memheap_oob 376 oshmem/mca/memheap/base/memheap_base_mkey.c r = (oob_comm_request_t *)opal_list_get_first(&memheap_oob.req_list); memheap_oob 391 oshmem/mca/memheap/base/memheap_base_mkey.c OBJ_CONSTRUCT(&memheap_oob.lck, opal_mutex_t); memheap_oob 392 oshmem/mca/memheap/base/memheap_base_mkey.c OBJ_CONSTRUCT(&memheap_oob.cond, opal_condition_t); memheap_oob 393 oshmem/mca/memheap/base/memheap_base_mkey.c OBJ_CONSTRUCT(&memheap_oob.req_list, opal_list_t); memheap_oob 397 oshmem/mca/memheap/base/memheap_base_mkey.c r = &memheap_oob.req_pool[i]; memheap_oob 412 oshmem/mca/memheap/base/memheap_base_mkey.c opal_list_append(&memheap_oob.req_list, &r->super); memheap_oob 416 oshmem/mca/memheap/base/memheap_base_mkey.c memheap_oob.is_inited = 1; memheap_oob 426 oshmem/mca/memheap/base/memheap_base_mkey.c if (!memheap_oob.is_inited) { memheap_oob 433 oshmem/mca/memheap/base/memheap_base_mkey.c r = &memheap_oob.req_pool[i]; memheap_oob 438 oshmem/mca/memheap/base/memheap_base_mkey.c OBJ_DESTRUCT(&memheap_oob.req_list); memheap_oob 439 oshmem/mca/memheap/base/memheap_base_mkey.c OBJ_DESTRUCT(&memheap_oob.lck); memheap_oob 440 oshmem/mca/memheap/base/memheap_base_mkey.c OBJ_DESTRUCT(&memheap_oob.cond); memheap_oob 441 oshmem/mca/memheap/base/memheap_base_mkey.c memheap_oob.is_inited = 0; memheap_oob 477 oshmem/mca/memheap/base/memheap_base_mkey.c OPAL_THREAD_LOCK(&memheap_oob.lck); memheap_oob 479 oshmem/mca/memheap/base/memheap_base_mkey.c memheap_oob.mkeys = mkeys; memheap_oob 480 oshmem/mca/memheap/base/memheap_base_mkey.c memheap_oob.segno = seg; memheap_oob 481 oshmem/mca/memheap/base/memheap_base_mkey.c memheap_oob.mkeys_rcvd = 0; memheap_oob 482 oshmem/mca/memheap/base/memheap_base_mkey.c memheap_oob.ctx = ctx; memheap_oob 486 oshmem/mca/memheap/base/memheap_base_mkey.c OPAL_THREAD_UNLOCK(&memheap_oob.lck); memheap_oob 497 oshmem/mca/memheap/base/memheap_base_mkey.c OPAL_THREAD_UNLOCK(&memheap_oob.lck); memheap_oob 502 oshmem/mca/memheap/base/memheap_base_mkey.c while (!memheap_oob.mkeys_rcvd) { memheap_oob 503 oshmem/mca/memheap/base/memheap_base_mkey.c opal_condition_wait(&memheap_oob.cond, &memheap_oob.lck); memheap_oob 506 oshmem/mca/memheap/base/memheap_base_mkey.c if (MEMHEAP_RKEY_RESP == memheap_oob.mkeys_rcvd) { memheap_oob 513 oshmem/mca/memheap/base/memheap_base_mkey.c OPAL_THREAD_UNLOCK(&memheap_oob.lck); memheap_oob 626 oshmem/mca/memheap/base/memheap_base_mkey.c OPAL_THREAD_LOCK(&memheap_oob.lck); memheap_oob 648 oshmem/mca/memheap/base/memheap_base_mkey.c memheap_oob.mkeys = s->mkeys_cache[i]; memheap_oob 649 oshmem/mca/memheap/base/memheap_base_mkey.c memheap_oob.segno = j; memheap_oob 654 oshmem/mca/memheap/base/memheap_base_mkey.c OPAL_THREAD_UNLOCK(&memheap_oob.lck); memheap_oob 689 oshmem/mca/memheap/base/memheap_base_mkey.c if (!memheap_oob.is_inited) {