curr 12 ompi/mca/io/romio321/romio/adio/common/ad_end.c ADIOI_Flatlist_node *curr, *next; curr 27 ompi/mca/io/romio321/romio/adio/common/ad_end.c curr = ADIOI_Flatlist; curr 28 ompi/mca/io/romio321/romio/adio/common/ad_end.c while (curr) { curr 29 ompi/mca/io/romio321/romio/adio/common/ad_end.c if (curr->blocklens) ADIOI_Free(curr->blocklens); curr 30 ompi/mca/io/romio321/romio/adio/common/ad_end.c if (curr->indices) ADIOI_Free(curr->indices); curr 31 ompi/mca/io/romio321/romio/adio/common/ad_end.c next = curr->next; curr 32 ompi/mca/io/romio321/romio/adio/common/ad_end.c ADIOI_Free(curr); curr 33 ompi/mca/io/romio321/romio/adio/common/ad_end.c curr = next; curr 21 ompi/mca/io/romio321/romio/adio/common/async_list.c ADIOI_Async_node *curr, *ptr; curr 27 ompi/mca/io/romio321/romio/adio/common/async_list.c curr = ADIOI_Async_avail_head; curr 29 ompi/mca/io/romio321/romio/adio/common/async_list.c curr->next = ADIOI_Async_avail_head+i; curr 30 ompi/mca/io/romio321/romio/adio/common/async_list.c curr = curr->next; curr 32 ompi/mca/io/romio321/romio/adio/common/async_list.c curr->next = NULL; curr 33 ompi/mca/io/romio321/romio/adio/common/async_list.c ADIOI_Async_avail_tail = curr; curr 78 ompi/mca/io/romio321/romio/adio/common/async_list.c ADIOI_Async_node *curr; curr 88 ompi/mca/io/romio321/romio/adio/common/async_list.c curr = ADIOI_Async_list_tail; curr 89 ompi/mca/io/romio321/romio/adio/common/async_list.c curr->next = ADIOI_Malloc_async_node(); curr 90 ompi/mca/io/romio321/romio/adio/common/async_list.c ADIOI_Async_list_tail = curr->next; curr 92 ompi/mca/io/romio321/romio/adio/common/async_list.c ADIOI_Async_list_tail->prev = curr; curr 157 ompi/mca/io/romio321/romio/adio/common/async_list.c ADIOI_Async_node *curr, *prev, *next; curr 159 ompi/mca/io/romio321/romio/adio/common/async_list.c curr = (*request)->ptr_in_async_list; curr 160 ompi/mca/io/romio321/romio/adio/common/async_list.c prev = curr->prev; curr 162 ompi/mca/io/romio321/romio/adio/common/async_list.c if (prev) prev->next = curr->next; curr 163 ompi/mca/io/romio321/romio/adio/common/async_list.c else ADIOI_Async_list_head = curr->next; curr 165 ompi/mca/io/romio321/romio/adio/common/async_list.c next = curr->next; curr 169 ompi/mca/io/romio321/romio/adio/common/async_list.c ADIOI_Free_async_node(curr); curr 21 ompi/mca/io/romio321/romio/adio/common/req_malloc.c ADIOI_Req_node *curr, *ptr; curr 32 ompi/mca/io/romio321/romio/adio/common/req_malloc.c curr = ADIOI_Req_avail_head; curr 34 ompi/mca/io/romio321/romio/adio/common/req_malloc.c curr->next = ADIOI_Req_avail_head+i; curr 35 ompi/mca/io/romio321/romio/adio/common/req_malloc.c curr = curr->next; curr 37 ompi/mca/io/romio321/romio/adio/common/req_malloc.c curr->next = NULL; curr 38 ompi/mca/io/romio321/romio/adio/common/req_malloc.c ADIOI_Req_avail_tail = curr; curr 37 ompi/mca/io/romio321/romio/mpi2-other/info/info_delete.c MPI_Info prev, curr; curr 61 ompi/mca/io/romio321/romio/mpi2-other/info/info_delete.c curr = info->next; curr 64 ompi/mca/io/romio321/romio/mpi2-other/info/info_delete.c while (curr) { curr 65 ompi/mca/io/romio321/romio/mpi2-other/info/info_delete.c if (!strcmp(curr->key, key)) { curr 66 ompi/mca/io/romio321/romio/mpi2-other/info/info_delete.c ADIOI_Free(curr->key); curr 67 ompi/mca/io/romio321/romio/mpi2-other/info/info_delete.c ADIOI_Free(curr->value); curr 68 ompi/mca/io/romio321/romio/mpi2-other/info/info_delete.c prev->next = curr->next; curr 69 ompi/mca/io/romio321/romio/mpi2-other/info/info_delete.c ADIOI_Free(curr); curr 73 ompi/mca/io/romio321/romio/mpi2-other/info/info_delete.c prev = curr; curr 74 ompi/mca/io/romio321/romio/mpi2-other/info/info_delete.c curr = curr->next; curr 36 ompi/mca/io/romio321/romio/mpi2-other/info/info_free.c MPI_Info curr, next; curr 43 ompi/mca/io/romio321/romio/mpi2-other/info/info_free.c curr = (*info)->next; curr 47 ompi/mca/io/romio321/romio/mpi2-other/info/info_free.c while (curr) { curr 48 ompi/mca/io/romio321/romio/mpi2-other/info/info_free.c next = curr->next; curr 49 ompi/mca/io/romio321/romio/mpi2-other/info/info_free.c ADIOI_Free(curr->key); curr 50 ompi/mca/io/romio321/romio/mpi2-other/info/info_free.c ADIOI_Free(curr->value); curr 51 ompi/mca/io/romio321/romio/mpi2-other/info/info_free.c ADIOI_Free(curr); curr 52 ompi/mca/io/romio321/romio/mpi2-other/info/info_free.c curr = next; curr 42 ompi/mca/io/romio321/romio/mpi2-other/info/info_get.c MPI_Info curr; curr 74 ompi/mca/io/romio321/romio/mpi2-other/info/info_get.c curr = info->next; curr 77 ompi/mca/io/romio321/romio/mpi2-other/info/info_get.c while (curr) { curr 78 ompi/mca/io/romio321/romio/mpi2-other/info/info_get.c if (!strcmp(curr->key, key)) { curr 79 ompi/mca/io/romio321/romio/mpi2-other/info/info_get.c ADIOI_Strncpy(value, curr->value, valuelen); curr 84 ompi/mca/io/romio321/romio/mpi2-other/info/info_get.c curr = curr->next; curr 39 ompi/mca/io/romio321/romio/mpi2-other/info/info_getnks.c MPI_Info curr; curr 46 ompi/mca/io/romio321/romio/mpi2-other/info/info_getnks.c curr = info->next; curr 49 ompi/mca/io/romio321/romio/mpi2-other/info/info_getnks.c while (curr) { curr 50 ompi/mca/io/romio321/romio/mpi2-other/info/info_getnks.c curr = curr->next; curr 40 ompi/mca/io/romio321/romio/mpi2-other/info/info_getnth.c MPI_Info curr; curr 53 ompi/mca/io/romio321/romio/mpi2-other/info/info_getnth.c curr = info->next; curr 55 ompi/mca/io/romio321/romio/mpi2-other/info/info_getnth.c while (curr) { curr 56 ompi/mca/io/romio321/romio/mpi2-other/info/info_getnth.c curr = curr->next; curr 65 ompi/mca/io/romio321/romio/mpi2-other/info/info_getnth.c curr = info->next; curr 68 ompi/mca/io/romio321/romio/mpi2-other/info/info_getnth.c curr = curr->next; curr 71 ompi/mca/io/romio321/romio/mpi2-other/info/info_getnth.c ADIOI_Strncpy(key, curr->key, MPI_MAX_INFO_KEY); curr 41 ompi/mca/io/romio321/romio/mpi2-other/info/info_getvln.c MPI_Info curr; curr 63 ompi/mca/io/romio321/romio/mpi2-other/info/info_getvln.c curr = info->next; curr 66 ompi/mca/io/romio321/romio/mpi2-other/info/info_getvln.c while (curr) { curr 67 ompi/mca/io/romio321/romio/mpi2-other/info/info_getvln.c if (!strcmp(curr->key, key)) { curr 68 ompi/mca/io/romio321/romio/mpi2-other/info/info_getvln.c *valuelen = strlen(curr->value); curr 72 ompi/mca/io/romio321/romio/mpi2-other/info/info_getvln.c curr = curr->next; curr 38 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c MPI_Info prev, curr; curr 76 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c curr = info->next; curr 78 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c while (curr) { curr 79 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c if (!strcmp(curr->key, key)) { curr 80 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c ADIOI_Free(curr->value); curr 81 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c curr->value = ADIOI_Strdup(value); curr 84 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c prev = curr; curr 85 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c curr = curr->next; curr 88 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c if (!curr) { curr 90 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c curr = prev->next; curr 91 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c curr->cookie = 0; /* cookie not set on purpose */ curr 92 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c curr->key = ADIOI_Strdup(key); curr 93 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c curr->value = ADIOI_Strdup(value); curr 94 ompi/mca/io/romio321/romio/mpi2-other/info/info_set.c curr->next = 0; curr 66 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h ompi_osc_pt2pt_frag_t *curr; curr 69 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr = (ompi_osc_pt2pt_frag_t *) peer->active_frag; curr 70 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h if (NULL != curr && opal_atomic_compare_exchange_strong_ptr (&peer->active_frag, (intptr_t *) &curr, 0)) { curr 73 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h int ret = ompi_osc_pt2pt_frag_finish (module, curr); curr 79 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr = (ompi_osc_pt2pt_frag_t *) opal_free_list_get (&mca_osc_pt2pt_component.frags); curr 80 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h if (OPAL_UNLIKELY(NULL == curr)) { curr 84 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->target = peer->rank; curr 86 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->header = (ompi_osc_pt2pt_frag_header_t*) curr->buffer; curr 87 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->top = (char*) (curr->header + 1); curr 88 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->remain_len = mca_osc_pt2pt_component.buffer_size; curr 89 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->module = module; curr 90 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->pending = 1; curr 92 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->header->base.type = OMPI_OSC_PT2PT_HDR_TYPE_FRAG; curr 93 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->header->base.flags = OMPI_OSC_PT2PT_HDR_FLAG_VALID; curr 95 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->header->base.flags |= OMPI_OSC_PT2PT_HDR_FLAG_PASSIVE_TARGET; curr 97 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->header->source = ompi_comm_rank(module->comm); curr 98 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->header->num_ops = 1; curr 100 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h return curr; curr 117 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h ompi_osc_pt2pt_frag_t *curr; curr 134 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr = (ompi_osc_pt2pt_frag_t *) peer->active_frag; curr 135 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h if (NULL == curr || curr->remain_len < request_len || (long_send && curr->pending_long_sends == 32)) { curr 136 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr = ompi_osc_pt2pt_frag_alloc_non_buffered (module, peer, request_len); curr 137 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h if (OPAL_UNLIKELY(NULL == curr)) { curr 142 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->pending_long_sends = long_send; curr 143 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h peer->active_frag = (uintptr_t) curr; curr 145 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h OPAL_THREAD_ADD_FETCH32(&curr->header->num_ops, 1); curr 146 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->pending_long_sends += long_send; curr 149 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h OPAL_THREAD_ADD_FETCH32(&curr->pending, 1); curr 151 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr = ompi_osc_pt2pt_frag_alloc_non_buffered (module, peer, request_len); curr 152 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h if (OPAL_UNLIKELY(NULL == curr)) { curr 158 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h *ptr = curr->top; curr 159 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h *buffer = curr; curr 161 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->top += request_len; curr 162 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->remain_len -= request_len; curr 40 ompi/mca/osc/rdma/osc_rdma_frag.h ompi_osc_rdma_frag_t *curr = module->rdma_frag; curr 51 ompi/mca/osc/rdma/osc_rdma_frag.h if (NULL == curr) { curr 60 ompi/mca/osc/rdma/osc_rdma_frag.h curr = (ompi_osc_rdma_frag_t *) item; curr 62 ompi/mca/osc/rdma/osc_rdma_frag.h curr->handle = NULL; curr 63 ompi/mca/osc/rdma/osc_rdma_frag.h curr->pending = 1; curr 64 ompi/mca/osc/rdma/osc_rdma_frag.h curr->module = module; curr 65 ompi/mca/osc/rdma/osc_rdma_frag.h curr->curr_index = 0; curr 68 ompi/mca/osc/rdma/osc_rdma_frag.h ret = ompi_osc_rdma_register (module, MCA_BTL_ENDPOINT_ANY, curr->super.ptr, mca_osc_rdma_component.buffer_size, curr 69 ompi/mca/osc/rdma/osc_rdma_frag.h MCA_BTL_REG_FLAG_ACCESS_ANY, &curr->handle); curr 75 ompi/mca/osc/rdma/osc_rdma_frag.h if (!opal_atomic_compare_exchange_strong_ptr ((opal_atomic_intptr_t *) &module->rdma_frag, &(intptr_t){0}, (intptr_t) curr)) { curr 76 ompi/mca/osc/rdma/osc_rdma_frag.h ompi_osc_rdma_deregister (module, curr->handle); curr 77 ompi/mca/osc/rdma/osc_rdma_frag.h curr->handle = NULL; curr 79 ompi/mca/osc/rdma/osc_rdma_frag.h opal_free_list_return (&mca_osc_rdma_component.frags, &curr->super); curr 81 ompi/mca/osc/rdma/osc_rdma_frag.h curr = module->rdma_frag; curr 85 ompi/mca/osc/rdma/osc_rdma_frag.h OSC_RDMA_VERBOSE(MCA_BASE_VERBOSE_INFO, "allocating frag. pending = %d", curr->pending); curr 86 ompi/mca/osc/rdma/osc_rdma_frag.h OPAL_THREAD_ADD_FETCH32(&curr->pending, 1); curr 89 ompi/mca/osc/rdma/osc_rdma_frag.h my_index = opal_atomic_fetch_add_64 (&curr->curr_index, request_len); curr 91 ompi/mca/osc/rdma/osc_rdma_frag.h my_index = opal_atomic_fetch_add_32 (&curr->curr_index, request_len); curr 96 ompi/mca/osc/rdma/osc_rdma_frag.h ompi_osc_rdma_frag_complete (curr); curr 98 ompi/mca/osc/rdma/osc_rdma_frag.h ompi_osc_rdma_frag_complete (curr); curr 102 ompi/mca/osc/rdma/osc_rdma_frag.h *ptr = (void *) ((intptr_t) curr->super.ptr + my_index); curr 103 ompi/mca/osc/rdma/osc_rdma_frag.h *buffer = curr;