pool 39 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h custom_match_prq_node* pool; pool 83 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h elem->next = list->pool; pool 84 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h list->pool = elem; pool 166 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h elem->next = list->pool; pool 167 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h list->pool = elem; pool 210 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h if(list->pool) pool 212 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h elem = list->pool; pool 213 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h list->pool = list->pool->next; pool 269 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h list->pool = 0; pool 286 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h while(list->pool) pool 288 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h elem = list->pool; pool 289 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h list->pool = list->pool->next; pool 365 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h custom_match_umq_node* pool; pool 449 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h elem->next = list->pool; pool 450 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h list->pool = elem; pool 466 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h if(list->pool) pool 471 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h elem = list->pool; pool 472 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h list->pool = list->pool->next; pool 522 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h list->pool = 0; pool 539 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h while(list->pool) pool 541 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h elem = list->pool; pool 542 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_arrays.h list->pool = list->pool->next; pool 35 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h custom_match_prq_node* pool; pool 79 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h elem->next = list->pool; pool 80 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h list->pool = elem; pool 183 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h elem->next = list->pool; pool 184 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h list->pool = elem; pool 225 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h if(list->pool) pool 227 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h elem = list->pool; pool 228 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h list->pool = list->pool->next; pool 276 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h list->pool = 0; pool 293 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h while(list->pool) pool 295 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h elem = list->pool; pool 296 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h list->pool = list->pool->next; pool 369 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h custom_match_umq_node* pool; pool 456 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h elem->next = list->pool; pool 457 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h list->pool = elem; pool 476 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h if(list->pool) pool 481 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h elem = list->pool; pool 482 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h list->pool = list->pool->next; pool 527 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h list->pool = 0; pool 544 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h while(list->pool) pool 546 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h elem = list->pool; pool 547 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-byte.h list->pool = list->pool->next; pool 35 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h custom_match_prq_node* pool; pool 79 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h elem->next = list->pool; pool 80 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h list->pool = elem; pool 177 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h elem->next = list->pool; pool 178 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h list->pool = elem; pool 216 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h if(list->pool) pool 218 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h elem = list->pool; pool 219 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h list->pool = list->pool->next; pool 268 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h list->pool = 0; pool 285 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h while(list->pool) pool 287 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h elem = list->pool; pool 288 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h list->pool = list->pool->next; pool 361 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h custom_match_umq_node* pool; pool 447 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h elem->next = list->pool; pool 448 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h list->pool = elem; pool 467 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h if(list->pool) pool 472 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h elem = list->pool; pool 473 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h list->pool = list->pool->next; pool 522 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h list->pool = 0; pool 539 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h while(list->pool) pool 541 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h elem = list->pool; pool 542 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-short.h list->pool = list->pool->next; pool 35 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h custom_match_prq_node* pool; pool 77 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h elem->next = list->pool; pool 78 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h list->pool = elem; pool 177 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h elem->next = list->pool; pool 178 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h list->pool = elem; pool 227 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h if(list->pool) pool 229 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h elem = list->pool; pool 230 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h list->pool = list->pool->next; pool 278 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h list->pool = 0; pool 295 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h while(list->pool) pool 297 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h elem = list->pool; pool 298 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h list->pool = list->pool->next; pool 370 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h custom_match_umq_node* pool; pool 465 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h elem->next = list->pool; pool 466 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h list->pool = elem; pool 485 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h if(list->pool) pool 490 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h elem = list->pool; pool 491 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h list->pool = list->pool->next; pool 540 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h list->pool = 0; pool 557 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h while(list->pool) pool 559 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h elem = list->pool; pool 560 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_fuzzy512-word.h list->pool = list->pool->next; pool 34 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h custom_match_prq_node* pool; pool 68 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h elem->next = list->pool; pool 69 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h list->pool = elem; pool 133 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h elem->next = list->pool; pool 134 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h list->pool = elem; pool 136 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h printf("%x == %x added to the pool\n", elem, list->pool); pool 178 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h printf("%x next elem in the pool\n", list->pool); pool 180 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h if(list->pool) pool 182 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h elem = list->pool; pool 183 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h list->pool = list->pool->next; pool 226 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h list->pool = 0; pool 246 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h while(list->pool) pool 248 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h elem = list->pool; pool 249 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h list->pool = list->pool->next; pool 320 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h custom_match_umq_node* pool; pool 392 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h elem->next = list->pool; pool 393 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h list->pool = elem; pool 405 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h if(list->pool) pool 410 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h elem = list->pool; pool 411 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h list->pool = list->pool->next; pool 455 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h list->pool = 0; pool 475 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h while(list->pool) pool 477 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h elem = list->pool; pool 478 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_linkedlist.h list->pool = list->pool->next; pool 37 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h custom_match_prq_node* pool; pool 81 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h elem->next = list->pool; pool 82 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h list->pool = elem; pool 181 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h elem->next = list->pool; pool 182 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h list->pool = elem; pool 228 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h if(list->pool) pool 230 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h elem = list->pool; pool 231 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h list->pool = list->pool->next; pool 287 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h list->pool = 0; pool 304 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h while(list->pool) pool 306 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h elem = list->pool; pool 307 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h list->pool = list->pool->next; pool 381 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h custom_match_umq_node* pool; pool 468 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h elem->next = list->pool; pool 469 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h list->pool = elem; pool 491 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h if(list->pool) pool 493 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h elem = list->pool; pool 494 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h list->pool = list->pool->next; pool 536 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h list->pool = 0; pool 553 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h while(list->pool) pool 555 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h elem = list->pool; pool 556 ompi/mca/pml/ob1/custommatch/pml_ob1_custom_match_vectors.h list->pool = list->pool->next; pool 14 ompi/mca/topo/treematch/treematch/tm_thread_pool.c static thread_pool_t *pool = NULL; pool 168 ompi/mca/topo/treematch/treematch/tm_thread_pool.c if( (thread_id>=0) && (thread_id< pool->nb_threads)){ pool 170 ompi/mca/topo/treematch/treematch/tm_thread_pool.c add_work(&pool->list_lock[thread_id], &pool->cond_var[thread_id], &pool->working_list[thread_id], work); pool 209 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pool = (thread_pool_t*) MALLOC(sizeof(thread_pool_t)); pool 210 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pool -> topology = topology; pool 211 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pool -> nb_threads = nb_threads; pool 212 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pool -> thread_list = (pthread_t*)MALLOC(sizeof(pthread_t)*nb_threads); pool 213 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pool -> working_list = (work_t*)CALLOC(nb_threads,sizeof(work_t)); pool 214 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pool -> cond_var = (pthread_cond_t*)MALLOC(sizeof(pthread_cond_t)*nb_threads); pool 215 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pool -> list_lock = (pthread_mutex_t*)MALLOC(sizeof(pthread_mutex_t)*nb_threads); pool 218 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pool->local = local; pool 223 ompi/mca/topo/treematch/treematch/tm_thread_pool.c local[i].working_list = &pool->working_list[i]; pool 224 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pthread_cond_init(pool->cond_var +i, NULL); pool 225 ompi/mca/topo/treematch/treematch/tm_thread_pool.c local[i].cond_var = pool->cond_var +i; pool 226 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pthread_mutex_init(pool->list_lock +i, NULL); pool 227 ompi/mca/topo/treematch/treematch/tm_thread_pool.c local[i].list_lock = pool->list_lock+i; pool 228 ompi/mca/topo/treematch/treematch/tm_thread_pool.c if (pthread_create (pool->thread_list+i, NULL, thread_loop, local+i) < 0) { pool 234 ompi/mca/topo/treematch/treematch/tm_thread_pool.c return pool; pool 238 ompi/mca/topo/treematch/treematch/tm_thread_pool.c if (pool == NULL) pool 241 ompi/mca/topo/treematch/treematch/tm_thread_pool.c return pool; pool 249 ompi/mca/topo/treematch/treematch/tm_thread_pool.c if(pool){ pool 251 ompi/mca/topo/treematch/treematch/tm_thread_pool.c for (id=0;id<pool->nb_threads;id++){ pool 256 ompi/mca/topo/treematch/treematch/tm_thread_pool.c for (id=0;id<pool->nb_threads;id++){ pool 257 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pthread_join(pool->thread_list[id],(void **) &ret); pool 259 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pthread_cond_destroy(pool->cond_var +id); pool 260 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pthread_mutex_destroy(pool->list_lock +id); pool 261 ompi/mca/topo/treematch/treematch/tm_thread_pool.c if (pool->working_list[id].next != NULL) pool 266 ompi/mca/topo/treematch/treematch/tm_thread_pool.c hwloc_topology_destroy(pool->topology); pool 267 ompi/mca/topo/treematch/treematch/tm_thread_pool.c FREE(pool -> thread_list); pool 268 ompi/mca/topo/treematch/treematch/tm_thread_pool.c FREE(pool -> working_list); pool 269 ompi/mca/topo/treematch/treematch/tm_thread_pool.c FREE(pool -> cond_var); pool 270 ompi/mca/topo/treematch/treematch/tm_thread_pool.c FREE(pool -> list_lock); pool 271 ompi/mca/topo/treematch/treematch/tm_thread_pool.c FREE(pool -> local); pool 272 ompi/mca/topo/treematch/treematch/tm_thread_pool.c FREE(pool); pool 273 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pool = NULL; pool 281 ompi/mca/topo/treematch/treematch/tm_thread_pool.c pool = get_thread_pool(); pool 282 ompi/mca/topo/treematch/treematch/tm_thread_pool.c return pool -> nb_threads; pool 203 opal/mca/btl/usnic/btl_usnic_recv.c int pool; pool 210 opal/mca/btl/usnic/btl_usnic_recv.c pool = usnic_fls(chunk_hdr->ch_frag_size-1); pool 211 opal/mca/btl/usnic/btl_usnic_recv.c if (pool >= module->first_pool && pool 212 opal/mca/btl/usnic/btl_usnic_recv.c pool <= module->last_pool) { pool 215 opal/mca/btl/usnic/btl_usnic_recv.c USNIC_COMPAT_FREE_LIST_GET(&module->module_recv_buffers[pool], item); pool 220 opal/mca/btl/usnic/btl_usnic_recv.c fip->rfi_data_pool = pool; pool 36 opal/mca/compress/fwd/regx_fwd.c static int nidmap_create(opal_pointer_array_t *pool, char **regex); pool 48 opal/mca/compress/fwd/regx_fwd.c static int nidmap_create(opal_pointer_array_t *pool, char **regex) pool 67 opal/mca/compress/fwd/regx_fwd.c for (n=0; n < pool->size; n++) { pool 68 opal/mca/compress/fwd/regx_fwd.c if (NULL == (nptr = (orte_node_t*)opal_pointer_array_get_item(pool, n))) { pool 37 opal/mca/compress/reverse/regx_reverse.c static int nidmap_create(opal_pointer_array_t *pool, char **regex); pool 49 opal/mca/compress/reverse/regx_reverse.c static int nidmap_create(opal_pointer_array_t *pool, char **regex) pool 68 opal/mca/compress/reverse/regx_reverse.c for (n=0; n < pool->size; n++) { pool 69 opal/mca/compress/reverse/regx_reverse.c if (NULL == (nptr = (orte_node_t*)opal_pointer_array_get_item(pool, n))) { pool 173 opal/mca/event/libevent2022/libevent/evrpc-internal.h struct evrpc_pool *pool; pool 200 opal/mca/event/libevent2022/libevent/evrpc.c static void evrpc_pool_schedule(struct evrpc_pool *pool); pool 512 opal/mca/event/libevent2022/libevent/evrpc.c struct evrpc_pool *pool = mm_calloc(1, sizeof(struct evrpc_pool)); pool 513 opal/mca/event/libevent2022/libevent/evrpc.c if (pool == NULL) pool 516 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_INIT(&pool->connections); pool 517 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_INIT(&pool->requests); pool 519 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_INIT(&pool->paused_requests); pool 521 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_INIT(&pool->input_hooks); pool 522 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_INIT(&pool->output_hooks); pool 524 opal/mca/event/libevent2022/libevent/evrpc.c pool->base = base; pool 525 opal/mca/event/libevent2022/libevent/evrpc.c pool->timeout = -1; pool 527 opal/mca/event/libevent2022/libevent/evrpc.c return (pool); pool 540 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_pool_free(struct evrpc_pool *pool) pool 548 opal/mca/event/libevent2022/libevent/evrpc.c while ((request = TAILQ_FIRST(&pool->requests)) != NULL) { pool 549 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_REMOVE(&pool->requests, request, next); pool 553 opal/mca/event/libevent2022/libevent/evrpc.c while ((pause = TAILQ_FIRST(&pool->paused_requests)) != NULL) { pool 554 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_REMOVE(&pool->paused_requests, pause, next); pool 558 opal/mca/event/libevent2022/libevent/evrpc.c while ((connection = TAILQ_FIRST(&pool->connections)) != NULL) { pool 559 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_REMOVE(&pool->connections, connection, next); pool 563 opal/mca/event/libevent2022/libevent/evrpc.c while ((hook = TAILQ_FIRST(&pool->input_hooks)) != NULL) { pool 564 opal/mca/event/libevent2022/libevent/evrpc.c r = evrpc_remove_hook(pool, EVRPC_INPUT, hook); pool 568 opal/mca/event/libevent2022/libevent/evrpc.c while ((hook = TAILQ_FIRST(&pool->output_hooks)) != NULL) { pool 569 opal/mca/event/libevent2022/libevent/evrpc.c r = evrpc_remove_hook(pool, EVRPC_OUTPUT, hook); pool 573 opal/mca/event/libevent2022/libevent/evrpc.c mm_free(pool); pool 582 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_pool_add_connection(struct evrpc_pool *pool, pool 586 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_INSERT_TAIL(&pool->connections, connection, next); pool 591 opal/mca/event/libevent2022/libevent/evrpc.c if (pool->base != NULL) pool 592 opal/mca/event/libevent2022/libevent/evrpc.c evhttp_connection_set_base(connection, pool->base); pool 599 opal/mca/event/libevent2022/libevent/evrpc.c connection->timeout = pool->timeout; pool 606 opal/mca/event/libevent2022/libevent/evrpc.c if (TAILQ_FIRST(&pool->requests) != NULL) { pool 608 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_FIRST(&pool->requests); pool 609 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_REMOVE(&pool->requests, request, next); pool 615 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_pool_remove_connection(struct evrpc_pool *pool, pool 618 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_REMOVE(&pool->connections, connection, next); pool 622 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_pool_set_timeout(struct evrpc_pool *pool, int timeout_in_secs) pool 625 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_FOREACH(evcon, &pool->connections, next) { pool 628 opal/mca/event/libevent2022/libevent/evrpc.c pool->timeout = timeout_in_secs; pool 640 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_pool_find_connection(struct evrpc_pool *pool) pool 643 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_FOREACH(connection, &pool->connections, next) { pool 665 opal/mca/event/libevent2022/libevent/evrpc.c struct evrpc_pool *pool = ctx->pool; pool 680 opal/mca/event/libevent2022/libevent/evrpc.c if (TAILQ_FIRST(&pool->output_hooks) != NULL) { pool 686 opal/mca/event/libevent2022/libevent/evrpc.c hook_res = evrpc_process_hooks(&pool->output_hooks, pool 694 opal/mca/event/libevent2022/libevent/evrpc.c if (evrpc_pause_request(pool, ctx, pool 725 opal/mca/event/libevent2022/libevent/evrpc.c struct evrpc_pool *pool = ctx->pool; pool 737 opal/mca/event/libevent2022/libevent/evrpc.c if (pool->timeout > 0) { pool 743 opal/mca/event/libevent2022/libevent/evrpc.c tv.tv_sec = pool->timeout; pool 804 opal/mca/event/libevent2022/libevent/evrpc.c struct evrpc_pool *pool = ctx->pool; pool 807 opal/mca/event/libevent2022/libevent/evrpc.c evtimer_assign(&ctx->ev_timeout, pool->base, evrpc_request_timeout, ctx); pool 810 opal/mca/event/libevent2022/libevent/evrpc.c EVUTIL_ASSERT(TAILQ_FIRST(&pool->connections) != NULL); pool 816 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_INSERT_TAIL(&pool->requests, ctx, next); pool 818 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_pool_schedule(pool); pool 826 opal/mca/event/libevent2022/libevent/evrpc.c struct evrpc_pool *pool, void *request, void *reply, pool 839 opal/mca/event/libevent2022/libevent/evrpc.c ctx->pool = pool; pool 865 opal/mca/event/libevent2022/libevent/evrpc.c struct evrpc_pool *pool = ctx->pool; pool 879 opal/mca/event/libevent2022/libevent/evrpc.c if (TAILQ_FIRST(&pool->input_hooks) != NULL) { pool 883 opal/mca/event/libevent2022/libevent/evrpc.c hook_res = evrpc_process_hooks(&pool->input_hooks, pool 900 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_pause_request(pool, ctx, pool 920 opal/mca/event/libevent2022/libevent/evrpc.c struct evrpc_pool *pool = ctx->pool; pool 953 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_pool_schedule(pool); pool 957 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_pool_schedule(struct evrpc_pool *pool) pool 959 opal/mca/event/libevent2022/libevent/evrpc.c struct evrpc_request_wrapper *ctx = TAILQ_FIRST(&pool->requests); pool 966 opal/mca/event/libevent2022/libevent/evrpc.c if ((evcon = evrpc_pool_find_connection(pool)) != NULL) { pool 967 opal/mca/event/libevent2022/libevent/evrpc.c TAILQ_REMOVE(&pool->requests, ctx, next); pool 1082 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_send_request_generic(struct evrpc_pool *pool, pool 1093 opal/mca/event/libevent2022/libevent/evrpc.c ctx = evrpc_make_request_ctx(pool, request, reply, pool 1157 opal/mca/event/libevent2022/libevent/evrpc.c return (ctx->pool); pool 1162 opal/mca/event/libevent2022/libevent/evrpc.c struct evrpc_pool *pool) pool 1164 opal/mca/event/libevent2022/libevent/evrpc.c ctx->pool = pool; pool 191 opal/mca/event/libevent2022/libevent/include/event2/rpc.h struct evrpc_pool *pool, void *request, void *reply, pool 214 opal/mca/event/libevent2022/libevent/include/event2/rpc.h pool, request, reply, cb, cbarg) \ pool 215 opal/mca/event/libevent2022/libevent/include/event2/rpc.h evrpc_make_request_ctx(pool, request, reply, \ pool 234 opal/mca/event/libevent2022/libevent/include/event2/rpc.h int evrpc_send_request_##rpcname(struct evrpc_pool *pool, \ pool 239 opal/mca/event/libevent2022/libevent/include/event2/rpc.h return evrpc_send_request_generic(pool, request, reply, \ pool 374 opal/mca/event/libevent2022/libevent/include/event2/rpc.h #define EVRPC_MAKE_REQUEST(name, pool, request, reply, cb, cbarg) \ pool 375 opal/mca/event/libevent2022/libevent/include/event2/rpc.h evrpc_send_request_##name((pool), (request), (reply), (cb), (cbarg)) pool 406 opal/mca/event/libevent2022/libevent/include/event2/rpc.h void evrpc_pool_free(struct evrpc_pool *pool); pool 416 opal/mca/event/libevent2022/libevent/include/event2/rpc.h void evrpc_pool_add_connection(struct evrpc_pool *pool, pool 427 opal/mca/event/libevent2022/libevent/include/event2/rpc.h void evrpc_pool_remove_connection(struct evrpc_pool *pool, pool 445 opal/mca/event/libevent2022/libevent/include/event2/rpc.h void evrpc_pool_set_timeout(struct evrpc_pool *pool, int timeout_in_secs); pool 559 opal/mca/event/libevent2022/libevent/include/event2/rpc.h int evrpc_send_request_generic(struct evrpc_pool *pool, pool 587 opal/mca/event/libevent2022/libevent/include/event2/rpc.h struct evrpc_pool *pool); pool 312 opal/mca/event/libevent2022/libevent/test/regress_rpc.c struct evrpc_pool *pool; pool 314 opal/mca/event/libevent2022/libevent/test/regress_rpc.c pool = evrpc_pool_new(NULL); pool 315 opal/mca/event/libevent2022/libevent/test/regress_rpc.c assert(pool != NULL); pool 320 opal/mca/event/libevent2022/libevent/test/regress_rpc.c evrpc_pool_add_connection(pool, evcon); pool 322 opal/mca/event/libevent2022/libevent/test/regress_rpc.c return (pool); pool 451 opal/mca/event/libevent2022/libevent/test/regress_rpc.c struct evrpc_pool *pool = NULL; pool 465 opal/mca/event/libevent2022/libevent/test/regress_rpc.c pool = rpc_pool_with_connection(port); pool 467 opal/mca/event/libevent2022/libevent/test/regress_rpc.c assert(evrpc_add_hook(pool, EVRPC_OUTPUT, rpc_hook_add_meta, NULL)); pool 468 opal/mca/event/libevent2022/libevent/test/regress_rpc.c assert(evrpc_add_hook(pool, EVRPC_INPUT, rpc_hook_remove_header, (void*)"output")); pool 477 opal/mca/event/libevent2022/libevent/test/regress_rpc.c EVRPC_MAKE_REQUEST(Message, pool, msg, kill, GotKillCb, NULL); pool 488 opal/mca/event/libevent2022/libevent/test/regress_rpc.c EVRPC_MAKE_REQUEST(Message, pool, msg, kill, GotKillCb, NULL); pool 500 opal/mca/event/libevent2022/libevent/test/regress_rpc.c pool, msg, kill, GotKillCb, NULL); pool 516 opal/mca/event/libevent2022/libevent/test/regress_rpc.c if (pool) pool 517 opal/mca/event/libevent2022/libevent/test/regress_rpc.c evrpc_pool_free(pool); pool 535 opal/mca/event/libevent2022/libevent/test/regress_rpc.c struct evrpc_pool *pool = NULL; pool 541 opal/mca/event/libevent2022/libevent/test/regress_rpc.c pool = rpc_pool_with_connection(port); pool 551 opal/mca/event/libevent2022/libevent/test/regress_rpc.c EVRPC_MAKE_REQUEST(Message, pool, msg, kill_one, GotKillCbTwo, NULL); pool 552 opal/mca/event/libevent2022/libevent/test/regress_rpc.c EVRPC_MAKE_REQUEST(Message, pool, msg, kill_two, GotKillCb, NULL); pool 570 opal/mca/event/libevent2022/libevent/test/regress_rpc.c if (pool) pool 571 opal/mca/event/libevent2022/libevent/test/regress_rpc.c evrpc_pool_free(pool); pool 633 opal/mca/event/libevent2022/libevent/test/regress_rpc.c struct evrpc_pool *pool = NULL; pool 642 opal/mca/event/libevent2022/libevent/test/regress_rpc.c pool = rpc_pool_with_connection(port); pool 644 opal/mca/event/libevent2022/libevent/test/regress_rpc.c assert(evrpc_add_hook(pool, EVRPC_INPUT, rpc_hook_pause, pool)); pool 645 opal/mca/event/libevent2022/libevent/test/regress_rpc.c assert(evrpc_add_hook(pool, EVRPC_OUTPUT, rpc_hook_pause, pool)); pool 654 opal/mca/event/libevent2022/libevent/test/regress_rpc.c EVRPC_MAKE_REQUEST(Message, pool, msg, kill, GotKillCb, NULL); pool 672 opal/mca/event/libevent2022/libevent/test/regress_rpc.c if (pool) pool 673 opal/mca/event/libevent2022/libevent/test/regress_rpc.c evrpc_pool_free(pool); pool 684 opal/mca/event/libevent2022/libevent/test/regress_rpc.c struct evrpc_pool *pool = NULL; pool 690 opal/mca/event/libevent2022/libevent/test/regress_rpc.c pool = rpc_pool_with_connection(port); pool 693 opal/mca/event/libevent2022/libevent/test/regress_rpc.c evrpc_pool_set_timeout(pool, 5); pool 702 opal/mca/event/libevent2022/libevent/test/regress_rpc.c EVRPC_MAKE_REQUEST(NeverReply, pool, msg, kill, GotErrorCb, NULL); pool 721 opal/mca/event/libevent2022/libevent/test/regress_rpc.c if (pool) pool 722 opal/mca/event/libevent2022/libevent/test/regress_rpc.c evrpc_pool_free(pool); pool 33 orte/util/nidmap.c int orte_util_nidmap_create(opal_pointer_array_t *pool, pool 77 orte/util/nidmap.c if (256 >= pool->size) { pool 79 orte/util/nidmap.c } else if (65536 >= pool->size) { pool 84 orte/util/nidmap.c vpids = (uint8_t*)malloc(nbytes * pool->size); pool 87 orte/util/nidmap.c for (n=0; n < pool->size; n++) { pool 88 orte/util/nidmap.c if (NULL == (nptr = (orte_node_t*)opal_pointer_array_get_item(pool, n))) { pool 33 orte/util/nidmap.h ORTE_DECLSPEC int orte_util_nidmap_create(opal_pointer_array_t *pool,