mca_osc_pt2pt_component 272 ompi/mca/osc/pt2pt/osc_pt2pt.h OMPI_MODULE_DECLSPEC extern ompi_osc_pt2pt_component_t mca_osc_pt2pt_component; mca_osc_pt2pt_component 695 ompi/mca/osc/pt2pt/osc_pt2pt.h OPAL_THREAD_SCOPED_LOCK(&mca_osc_pt2pt_component.pending_operations_lock, mca_osc_pt2pt_component 696 ompi/mca/osc/pt2pt/osc_pt2pt.h opal_list_append (&mca_osc_pt2pt_component.pending_operations, &pending->super)); mca_osc_pt2pt_component 97 ompi/mca/osc/pt2pt/osc_pt2pt_comm.c OPAL_THREAD_LOCK(&mca_osc_pt2pt_component.lock); mca_osc_pt2pt_component 98 ompi/mca/osc/pt2pt/osc_pt2pt_comm.c (void) opal_hash_table_get_value_uint32(&mca_osc_pt2pt_component.modules, mca_osc_pt2pt_component 101 ompi/mca/osc/pt2pt/osc_pt2pt_comm.c OPAL_THREAD_UNLOCK(&mca_osc_pt2pt_component.lock); mca_osc_pt2pt_component 51 ompi/mca/osc/pt2pt/osc_pt2pt_component.c ompi_osc_pt2pt_component_t mca_osc_pt2pt_component = { mca_osc_pt2pt_component 128 ompi/mca/osc/pt2pt/osc_pt2pt_component.c (void) mca_base_component_var_register(&mca_osc_pt2pt_component.super.osc_version, mca_osc_pt2pt_component 138 ompi/mca/osc/pt2pt/osc_pt2pt_component.c mca_osc_pt2pt_component.buffer_size = 8192; mca_osc_pt2pt_component 139 ompi/mca/osc/pt2pt/osc_pt2pt_component.c (void) mca_base_component_var_register (&mca_osc_pt2pt_component.super.osc_version, "buffer_size", mca_osc_pt2pt_component 143 ompi/mca/osc/pt2pt/osc_pt2pt_component.c &mca_osc_pt2pt_component.buffer_size); mca_osc_pt2pt_component 145 ompi/mca/osc/pt2pt/osc_pt2pt_component.c mca_osc_pt2pt_component.receive_count = 4; mca_osc_pt2pt_component 146 ompi/mca/osc/pt2pt/osc_pt2pt_component.c (void) mca_base_component_var_register (&mca_osc_pt2pt_component.super.osc_version, "receive_count", mca_osc_pt2pt_component 149 ompi/mca/osc/pt2pt/osc_pt2pt_component.c MCA_BASE_VAR_SCOPE_READONLY, &mca_osc_pt2pt_component.receive_count); mca_osc_pt2pt_component 156 ompi/mca/osc/pt2pt/osc_pt2pt_component.c int pending_count = opal_list_get_size (&mca_osc_pt2pt_component.pending_operations); mca_osc_pt2pt_component 157 ompi/mca/osc/pt2pt/osc_pt2pt_component.c int recv_count = opal_list_get_size (&mca_osc_pt2pt_component.pending_receives); mca_osc_pt2pt_component 162 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OPAL_THREAD_LOCK(&mca_osc_pt2pt_component.pending_receives_lock); mca_osc_pt2pt_component 163 ompi/mca/osc/pt2pt/osc_pt2pt_component.c ompi_osc_pt2pt_receive_t *recv = (ompi_osc_pt2pt_receive_t *) opal_list_remove_first (&mca_osc_pt2pt_component.pending_receives); mca_osc_pt2pt_component 164 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OPAL_THREAD_UNLOCK(&mca_osc_pt2pt_component.pending_receives_lock); mca_osc_pt2pt_component 175 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OPAL_THREAD_LOCK(&mca_osc_pt2pt_component.pending_operations_lock); mca_osc_pt2pt_component 176 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OPAL_LIST_FOREACH_SAFE(pending, next, &mca_osc_pt2pt_component.pending_operations, ompi_osc_pt2pt_pending_t) { mca_osc_pt2pt_component 195 ompi/mca/osc/pt2pt/osc_pt2pt_component.c opal_list_remove_item (&mca_osc_pt2pt_component.pending_operations, &pending->super); mca_osc_pt2pt_component 199 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OPAL_THREAD_UNLOCK(&mca_osc_pt2pt_component.pending_operations_lock); mca_osc_pt2pt_component 215 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_CONSTRUCT(&mca_osc_pt2pt_component.lock, opal_mutex_t); mca_osc_pt2pt_component 216 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_CONSTRUCT(&mca_osc_pt2pt_component.pending_operations, opal_list_t); mca_osc_pt2pt_component 217 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_CONSTRUCT(&mca_osc_pt2pt_component.pending_operations_lock, opal_mutex_t); mca_osc_pt2pt_component 218 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_CONSTRUCT(&mca_osc_pt2pt_component.pending_receives, opal_list_t); mca_osc_pt2pt_component 219 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_CONSTRUCT(&mca_osc_pt2pt_component.pending_receives_lock, opal_mutex_t); mca_osc_pt2pt_component 221 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_CONSTRUCT(&mca_osc_pt2pt_component.modules, mca_osc_pt2pt_component 223 ompi/mca/osc/pt2pt/osc_pt2pt_component.c opal_hash_table_init(&mca_osc_pt2pt_component.modules, 2); mca_osc_pt2pt_component 225 ompi/mca/osc/pt2pt/osc_pt2pt_component.c mca_osc_pt2pt_component.progress_enable = false; mca_osc_pt2pt_component 226 ompi/mca/osc/pt2pt/osc_pt2pt_component.c mca_osc_pt2pt_component.module_count = 0; mca_osc_pt2pt_component 228 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_CONSTRUCT(&mca_osc_pt2pt_component.frags, opal_free_list_t); mca_osc_pt2pt_component 229 ompi/mca/osc/pt2pt/osc_pt2pt_component.c ret = opal_free_list_init (&mca_osc_pt2pt_component.frags, mca_osc_pt2pt_component 232 ompi/mca/osc/pt2pt/osc_pt2pt_component.c mca_osc_pt2pt_component.buffer_size + mca_osc_pt2pt_component 242 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_CONSTRUCT(&mca_osc_pt2pt_component.requests, opal_free_list_t); mca_osc_pt2pt_component 243 ompi/mca/osc/pt2pt/osc_pt2pt_component.c ret = opal_free_list_init (&mca_osc_pt2pt_component.requests, mca_osc_pt2pt_component 263 ompi/mca/osc/pt2pt/osc_pt2pt_component.c if (mca_osc_pt2pt_component.progress_enable) { mca_osc_pt2pt_component 268 ompi/mca/osc/pt2pt/osc_pt2pt_component.c (num_modules = opal_hash_table_get_size(&mca_osc_pt2pt_component.modules))) { mca_osc_pt2pt_component 274 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_DESTRUCT(&mca_osc_pt2pt_component.frags); mca_osc_pt2pt_component 275 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_DESTRUCT(&mca_osc_pt2pt_component.modules); mca_osc_pt2pt_component 276 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_DESTRUCT(&mca_osc_pt2pt_component.lock); mca_osc_pt2pt_component 277 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_DESTRUCT(&mca_osc_pt2pt_component.requests); mca_osc_pt2pt_component 278 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_DESTRUCT(&mca_osc_pt2pt_component.pending_operations); mca_osc_pt2pt_component 279 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_DESTRUCT(&mca_osc_pt2pt_component.pending_operations_lock); mca_osc_pt2pt_component 280 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_DESTRUCT(&mca_osc_pt2pt_component.pending_receives); mca_osc_pt2pt_component 281 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OBJ_DESTRUCT(&mca_osc_pt2pt_component.pending_receives_lock); mca_osc_pt2pt_component 406 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OPAL_THREAD_LOCK(&mca_osc_pt2pt_component.lock); mca_osc_pt2pt_component 407 ompi/mca/osc/pt2pt/osc_pt2pt_component.c ret = opal_hash_table_set_value_uint32(&mca_osc_pt2pt_component.modules, mca_osc_pt2pt_component 410 ompi/mca/osc/pt2pt/osc_pt2pt_component.c OPAL_THREAD_UNLOCK(&mca_osc_pt2pt_component.lock); mca_osc_pt2pt_component 434 ompi/mca/osc/pt2pt/osc_pt2pt_component.c if (!mca_osc_pt2pt_component.progress_enable) { mca_osc_pt2pt_component 436 ompi/mca/osc/pt2pt/osc_pt2pt_component.c mca_osc_pt2pt_component.progress_enable = true; mca_osc_pt2pt_component 1620 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c OPAL_THREAD_LOCK(&mca_osc_pt2pt_component.pending_receives_lock); mca_osc_pt2pt_component 1621 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c opal_list_append (&mca_osc_pt2pt_component.pending_receives, &recv->super); mca_osc_pt2pt_component 1622 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c OPAL_THREAD_UNLOCK(&mca_osc_pt2pt_component.pending_receives_lock); mca_osc_pt2pt_component 1701 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c module->recv_frag_count = mca_osc_pt2pt_component.receive_count; mca_osc_pt2pt_component 1714 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c module->recv_frags[i].buffer = malloc (mca_osc_pt2pt_component.buffer_size + sizeof (ompi_osc_pt2pt_frag_header_t)); mca_osc_pt2pt_component 1719 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c rc = ompi_osc_pt2pt_irecv_w_cb (module->recv_frags[i].buffer, mca_osc_pt2pt_component.buffer_size + sizeof (ompi_osc_pt2pt_frag_header_t), mca_osc_pt2pt_component 39 ompi/mca/osc/pt2pt/osc_pt2pt_frag.c opal_free_list_return (&mca_osc_pt2pt_component.frags, &frag->super); mca_osc_pt2pt_component 79 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr = (ompi_osc_pt2pt_frag_t *) opal_free_list_get (&mca_osc_pt2pt_component.frags); mca_osc_pt2pt_component 88 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h curr->remain_len = mca_osc_pt2pt_component.buffer_size; mca_osc_pt2pt_component 124 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h if (request_len > mca_osc_pt2pt_component.buffer_size) { mca_osc_pt2pt_component 175 ompi/mca/osc/pt2pt/osc_pt2pt_frag.h if (request_len > mca_osc_pt2pt_component.buffer_size) { mca_osc_pt2pt_component 66 ompi/mca/osc/pt2pt/osc_pt2pt_module.c OPAL_THREAD_SCOPED_LOCK(&mca_osc_pt2pt_component.lock, mca_osc_pt2pt_component 67 ompi/mca/osc/pt2pt/osc_pt2pt_module.c opal_hash_table_remove_value_uint32(&mca_osc_pt2pt_component.modules, mca_osc_pt2pt_component 43 ompi/mca/osc/pt2pt/osc_pt2pt_request.h item = opal_free_list_get (&mca_osc_pt2pt_component.requests); \ mca_osc_pt2pt_component 61 ompi/mca/osc/pt2pt/osc_pt2pt_request.h opal_free_list_return (&mca_osc_pt2pt_component.requests, \