pop 98 opal/mca/event/libevent2022/libevent/poll.c poll_check_ok(struct pollop *pop) pop 103 opal/mca/event/libevent2022/libevent/poll.c for (i = 0; i < pop->fd_count; ++i) { pop 104 opal/mca/event/libevent2022/libevent/poll.c idx = pop->idxplus1_by_fd[i]-1; pop 107 opal/mca/event/libevent2022/libevent/poll.c EVUTIL_ASSERT(pop->event_set[idx].fd == i); pop 109 opal/mca/event/libevent2022/libevent/poll.c for (i = 0; i < pop->nfds; ++i) { pop 110 opal/mca/event/libevent2022/libevent/poll.c struct pollfd *pfd = &pop->event_set[i]; pop 111 opal/mca/event/libevent2022/libevent/poll.c EVUTIL_ASSERT(pop->idxplus1_by_fd[pfd->fd] == i+1); pop 115 opal/mca/event/libevent2022/libevent/poll.c #define poll_check_ok(pop) pop 123 opal/mca/event/libevent2022/libevent/poll.c struct pollop *pop = base->evbase; pop 126 opal/mca/event/libevent2022/libevent/poll.c poll_check_ok(pop); pop 128 opal/mca/event/libevent2022/libevent/poll.c nfds = pop->nfds; pop 137 opal/mca/event/libevent2022/libevent/poll.c if (pop->realloc_copy) { pop 138 opal/mca/event/libevent2022/libevent/poll.c struct pollfd *tmp = mm_realloc(pop->event_set_copy, pop 139 opal/mca/event/libevent2022/libevent/poll.c pop->event_count * sizeof(struct pollfd)); pop 144 opal/mca/event/libevent2022/libevent/poll.c pop->event_set_copy = tmp; pop 145 opal/mca/event/libevent2022/libevent/poll.c pop->realloc_copy = 0; pop 147 opal/mca/event/libevent2022/libevent/poll.c memcpy(pop->event_set_copy, pop->event_set, pop 149 opal/mca/event/libevent2022/libevent/poll.c event_set = pop->event_set_copy; pop 151 opal/mca/event/libevent2022/libevent/poll.c event_set = pop->event_set; pop 154 opal/mca/event/libevent2022/libevent/poll.c event_set = pop->event_set; pop 213 opal/mca/event/libevent2022/libevent/poll.c struct pollop *pop = base->evbase; pop 222 opal/mca/event/libevent2022/libevent/poll.c poll_check_ok(pop); pop 223 opal/mca/event/libevent2022/libevent/poll.c if (pop->nfds + 1 >= pop->event_count) { pop 227 opal/mca/event/libevent2022/libevent/poll.c if (pop->event_count < 32) pop 230 opal/mca/event/libevent2022/libevent/poll.c tmp_event_count = pop->event_count * 2; pop 233 opal/mca/event/libevent2022/libevent/poll.c tmp_event_set = mm_realloc(pop->event_set, pop 239 opal/mca/event/libevent2022/libevent/poll.c pop->event_set = tmp_event_set; pop 241 opal/mca/event/libevent2022/libevent/poll.c pop->event_count = tmp_event_count; pop 242 opal/mca/event/libevent2022/libevent/poll.c pop->realloc_copy = 1; pop 248 opal/mca/event/libevent2022/libevent/poll.c pfd = &pop->event_set[i]; pop 250 opal/mca/event/libevent2022/libevent/poll.c i = pop->nfds++; pop 251 opal/mca/event/libevent2022/libevent/poll.c pfd = &pop->event_set[i]; pop 262 opal/mca/event/libevent2022/libevent/poll.c poll_check_ok(pop); pop 274 opal/mca/event/libevent2022/libevent/poll.c struct pollop *pop = base->evbase; pop 283 opal/mca/event/libevent2022/libevent/poll.c poll_check_ok(pop); pop 289 opal/mca/event/libevent2022/libevent/poll.c pfd = &pop->event_set[i]; pop 294 opal/mca/event/libevent2022/libevent/poll.c poll_check_ok(pop); pop 302 opal/mca/event/libevent2022/libevent/poll.c --pop->nfds; pop 303 opal/mca/event/libevent2022/libevent/poll.c if (i != pop->nfds) { pop 308 opal/mca/event/libevent2022/libevent/poll.c memcpy(&pop->event_set[i], &pop->event_set[pop->nfds], pop 310 opal/mca/event/libevent2022/libevent/poll.c idx = evmap_io_get_fdinfo(&base->io, pop->event_set[i].fd); pop 312 opal/mca/event/libevent2022/libevent/poll.c EVUTIL_ASSERT(idx->idxplus1 == pop->nfds + 1); pop 316 opal/mca/event/libevent2022/libevent/poll.c poll_check_ok(pop); pop 323 opal/mca/event/libevent2022/libevent/poll.c struct pollop *pop = base->evbase; pop 326 opal/mca/event/libevent2022/libevent/poll.c if (pop->event_set) pop 327 opal/mca/event/libevent2022/libevent/poll.c mm_free(pop->event_set); pop 328 opal/mca/event/libevent2022/libevent/poll.c if (pop->event_set_copy) pop 329 opal/mca/event/libevent2022/libevent/poll.c mm_free(pop->event_set_copy); pop 331 opal/mca/event/libevent2022/libevent/poll.c memset(pop, 0, sizeof(struct pollop)); pop 332 opal/mca/event/libevent2022/libevent/poll.c mm_free(pop); pop 1013 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_peer_op_t *pop = (mca_oob_tcp_peer_op_t*)cbdata; pop 1018 orte/mca/oob/tcp/oob_tcp_component.c ORTE_ACQUIRE_OBJECT(pop); pop 1023 orte/mca/oob/tcp/oob_tcp_component.c ORTE_NAME_PRINT(&pop->peer)); pop 1029 orte/mca/oob/tcp/oob_tcp_component.c memcpy(&ui64, (char*)&pop->peer, sizeof(uint64_t)); pop 1041 orte/mca/oob/tcp/oob_tcp_component.c OBJ_RELEASE(pop); pop 1046 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_peer_op_t *pop = (mca_oob_tcp_peer_op_t*)cbdata; pop 1051 orte/mca/oob/tcp/oob_tcp_component.c ORTE_ACQUIRE_OBJECT(pop); pop 1056 orte/mca/oob/tcp/oob_tcp_component.c ORTE_NAME_PRINT(&pop->peer)); pop 1059 orte/mca/oob/tcp/oob_tcp_component.c memcpy(&ui64, (char*)&pop->peer, sizeof(uint64_t)); pop 1072 orte/mca/oob/tcp/oob_tcp_component.c if (ORTE_SUCCESS != orte_routed.route_lost(&pop->peer)) { pop 1073 orte/mca/oob/tcp/oob_tcp_component.c ORTE_ACTIVATE_PROC_STATE(&pop->peer, ORTE_PROC_STATE_LIFELINE_LOST); pop 1075 orte/mca/oob/tcp/oob_tcp_component.c ORTE_ACTIVATE_PROC_STATE(&pop->peer, ORTE_PROC_STATE_COMM_FAILED); pop 1078 orte/mca/oob/tcp/oob_tcp_component.c OBJ_RELEASE(pop); pop 1196 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_peer_op_t *pop = (mca_oob_tcp_peer_op_t*)cbdata; pop 1198 orte/mca/oob/tcp/oob_tcp_component.c ORTE_ACQUIRE_OBJECT(pop); pop 1203 orte/mca/oob/tcp/oob_tcp_component.c ORTE_NAME_PRINT(&pop->peer)); pop 1207 orte/mca/oob/tcp/oob_tcp_component.c OBJ_RELEASE(pop); pop 1215 orte/mca/oob/tcp/oob_tcp_component.c ORTE_NAME_PRINT(&pop->peer)); pop 1217 orte/mca/oob/tcp/oob_tcp_component.c ORTE_ACTIVATE_PROC_STATE(&pop->peer, ORTE_PROC_STATE_FAILED_TO_CONNECT); pop 1218 orte/mca/oob/tcp/oob_tcp_component.c OBJ_RELEASE(pop); pop 1383 orte/mca/oob/tcp/oob_tcp_component.c static void pop_cons(mca_oob_tcp_peer_op_t *pop) pop 1385 orte/mca/oob/tcp/oob_tcp_component.c pop->net = NULL; pop 1386 orte/mca/oob/tcp/oob_tcp_component.c pop->port = NULL; pop 1388 orte/mca/oob/tcp/oob_tcp_component.c static void pop_des(mca_oob_tcp_peer_op_t *pop) pop 1390 orte/mca/oob/tcp/oob_tcp_component.c if (NULL != pop->net) { pop 1391 orte/mca/oob/tcp/oob_tcp_component.c free(pop->net); pop 1393 orte/mca/oob/tcp/oob_tcp_component.c if (NULL != pop->port) { pop 1394 orte/mca/oob/tcp/oob_tcp_component.c free(pop->port); pop 81 orte/mca/oob/tcp/oob_tcp_peer.h mca_oob_tcp_peer_op_t *pop; \ pop 82 orte/mca/oob/tcp/oob_tcp_peer.h pop = OBJ_NEW(mca_oob_tcp_peer_op_t); \ pop 83 orte/mca/oob/tcp/oob_tcp_peer.h pop->peer.jobid = (p)->name.jobid; \ pop 84 orte/mca/oob/tcp/oob_tcp_peer.h pop->peer.vpid = (p)->name.vpid; \ pop 85 orte/mca/oob/tcp/oob_tcp_peer.h ORTE_THREADSHIFT(pop, orte_oob_base.ev_base, \