chain 536 ompi/mca/coll/base/coll_base_topo.c ompi_coll_tree_t *chain; chain 558 ompi/mca/coll/base/coll_base_topo.c chain = (ompi_coll_tree_t*)malloc(COLL_TREE_SIZE(MAXTREEFANOUT)); chain 559 ompi/mca/coll/base/coll_base_topo.c if (!chain) { chain 564 ompi/mca/coll/base/coll_base_topo.c chain->tree_root = MPI_UNDEFINED; chain 565 ompi/mca/coll/base/coll_base_topo.c chain->tree_nextsize = -1; chain 566 ompi/mca/coll/base/coll_base_topo.c for(i=0;i<fanout;i++) chain->tree_next[i] = -1; chain 571 ompi/mca/coll/base/coll_base_topo.c chain->tree_root = root; chain 573 ompi/mca/coll/base/coll_base_topo.c chain->tree_nextsize = size-1; chain 576 ompi/mca/coll/base/coll_base_topo.c chain->tree_nextsize = fanout; chain 589 ompi/mca/coll/base/coll_base_topo.c if( srank == 0 ) chain->tree_prev = -1; chain 590 ompi/mca/coll/base/coll_base_topo.c else chain->tree_prev = (srank-1+root)%size; chain 593 ompi/mca/coll/base/coll_base_topo.c chain->tree_next[0] = -1; chain 594 ompi/mca/coll/base/coll_base_topo.c chain->tree_nextsize = 0; chain 596 ompi/mca/coll/base/coll_base_topo.c chain->tree_next[0] = (srank+1+root)%size; chain 597 ompi/mca/coll/base/coll_base_topo.c chain->tree_nextsize = 1; chain 599 ompi/mca/coll/base/coll_base_topo.c return chain; chain 604 ompi/mca/coll/base/coll_base_topo.c chain->tree_next[0] = -1; chain 605 ompi/mca/coll/base/coll_base_topo.c chain->tree_nextsize = 0; chain 606 ompi/mca/coll/base/coll_base_topo.c chain->tree_prev = -1; chain 607 ompi/mca/coll/base/coll_base_topo.c return chain; chain 636 ompi/mca/coll/base/coll_base_topo.c chain->tree_prev = 0; /*root*/ chain 638 ompi/mca/coll/base/coll_base_topo.c chain->tree_prev = srank-1; /* rank -1 */ chain 641 ompi/mca/coll/base/coll_base_topo.c chain->tree_next[0] = -1; chain 642 ompi/mca/coll/base/coll_base_topo.c chain->tree_nextsize = 0; chain 645 ompi/mca/coll/base/coll_base_topo.c chain->tree_next[0] = srank+1; chain 646 ompi/mca/coll/base/coll_base_topo.c chain->tree_nextsize = 1; chain 648 ompi/mca/coll/base/coll_base_topo.c chain->tree_next[0] = -1; chain 649 ompi/mca/coll/base/coll_base_topo.c chain->tree_nextsize = 0; chain 652 ompi/mca/coll/base/coll_base_topo.c chain->tree_prev = (chain->tree_prev+root)%size; chain 653 ompi/mca/coll/base/coll_base_topo.c if( chain->tree_next[0] != -1 ) { chain 654 ompi/mca/coll/base/coll_base_topo.c chain->tree_next[0] = (chain->tree_next[0]+root)%size; chain 660 ompi/mca/coll/base/coll_base_topo.c chain->tree_prev = -1; chain 661 ompi/mca/coll/base/coll_base_topo.c chain->tree_next[0] = (root+1)%size; chain 663 ompi/mca/coll/base/coll_base_topo.c chain->tree_next[i] = chain->tree_next[i-1] + maxchainlen; chain 665 ompi/mca/coll/base/coll_base_topo.c chain->tree_next[i]--; chain 667 ompi/mca/coll/base/coll_base_topo.c chain->tree_next[i] %= size; chain 669 ompi/mca/coll/base/coll_base_topo.c chain->tree_nextsize = fanout; chain 672 ompi/mca/coll/base/coll_base_topo.c return chain; chain 138 opal/mca/event/libevent2022/libevent/buffer.c static void evbuffer_chain_align(struct evbuffer_chain *chain); chain 139 opal/mca/event/libevent2022/libevent/buffer.c static int evbuffer_chain_should_realign(struct evbuffer_chain *chain, chain 157 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain; chain 176 opal/mca/event/libevent2022/libevent/buffer.c if ((chain = mm_malloc(to_alloc)) == NULL) chain 179 opal/mca/event/libevent2022/libevent/buffer.c memset(chain, 0, EVBUFFER_CHAIN_SIZE); chain 181 opal/mca/event/libevent2022/libevent/buffer.c chain->buffer_len = to_alloc - EVBUFFER_CHAIN_SIZE; chain 186 opal/mca/event/libevent2022/libevent/buffer.c chain->buffer = EVBUFFER_CHAIN_EXTRA(u_char, chain); chain 188 opal/mca/event/libevent2022/libevent/buffer.c return (chain); chain 192 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_free(struct evbuffer_chain *chain) chain 194 opal/mca/event/libevent2022/libevent/buffer.c if (CHAIN_PINNED(chain)) { chain 195 opal/mca/event/libevent2022/libevent/buffer.c chain->flags |= EVBUFFER_DANGLING; chain 198 opal/mca/event/libevent2022/libevent/buffer.c if (chain->flags & (EVBUFFER_MMAP|EVBUFFER_SENDFILE| chain 200 opal/mca/event/libevent2022/libevent/buffer.c if (chain->flags & EVBUFFER_REFERENCE) { chain 204 opal/mca/event/libevent2022/libevent/buffer.c chain); chain 206 opal/mca/event/libevent2022/libevent/buffer.c (*info->cleanupfn)(chain->buffer, chain 207 opal/mca/event/libevent2022/libevent/buffer.c chain->buffer_len, chain 211 opal/mca/event/libevent2022/libevent/buffer.c if (chain->flags & EVBUFFER_MMAP) { chain 214 opal/mca/event/libevent2022/libevent/buffer.c chain); chain 215 opal/mca/event/libevent2022/libevent/buffer.c if (munmap(chain->buffer, chain->buffer_len) == -1) chain 223 opal/mca/event/libevent2022/libevent/buffer.c if (chain->flags & EVBUFFER_SENDFILE) { chain 226 opal/mca/event/libevent2022/libevent/buffer.c chain); chain 234 opal/mca/event/libevent2022/libevent/buffer.c mm_free(chain); chain 238 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_free_all_chains(struct evbuffer_chain *chain) chain 241 opal/mca/event/libevent2022/libevent/buffer.c for (; chain; chain = next) { chain 242 opal/mca/event/libevent2022/libevent/buffer.c next = chain->next; chain 243 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_free(chain); chain 249 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chains_all_empty(struct evbuffer_chain *chain) chain 251 opal/mca/event/libevent2022/libevent/buffer.c for (; chain; chain = chain->next) { chain 252 opal/mca/event/libevent2022/libevent/buffer.c if (chain->off) chain 260 opal/mca/event/libevent2022/libevent/buffer.c static inline int evbuffer_chains_all_empty(struct evbuffer_chain *chain) { chain 292 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain) chain 299 opal/mca/event/libevent2022/libevent/buffer.c buf->first = buf->last = chain; chain 307 opal/mca/event/libevent2022/libevent/buffer.c buf->last->next = chain; chain 308 opal/mca/event/libevent2022/libevent/buffer.c if (chain->off) chain 314 opal/mca/event/libevent2022/libevent/buffer.c *ch = chain; chain 316 opal/mca/event/libevent2022/libevent/buffer.c buf->last = chain; chain 318 opal/mca/event/libevent2022/libevent/buffer.c buf->total_len += chain->off; chain 324 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain; chain 325 opal/mca/event/libevent2022/libevent/buffer.c if ((chain = evbuffer_chain_new(datlen)) == NULL) chain 327 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_insert(buf, chain); chain 328 opal/mca/event/libevent2022/libevent/buffer.c return chain; chain 332 opal/mca/event/libevent2022/libevent/buffer.c _evbuffer_chain_pin(struct evbuffer_chain *chain, unsigned flag) chain 334 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT((chain->flags & flag) == 0); chain 335 opal/mca/event/libevent2022/libevent/buffer.c chain->flags |= flag; chain 339 opal/mca/event/libevent2022/libevent/buffer.c _evbuffer_chain_unpin(struct evbuffer_chain *chain, unsigned flag) chain 341 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT((chain->flags & flag) != 0); chain 342 opal/mca/event/libevent2022/libevent/buffer.c chain->flags &= ~flag; chain 343 opal/mca/event/libevent2022/libevent/buffer.c if (chain->flags & EVBUFFER_DANGLING) chain 344 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_free(chain); chain 549 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain, *next; chain 559 opal/mca/event/libevent2022/libevent/buffer.c for (chain = buffer->first; chain != NULL; chain = next) { chain 560 opal/mca/event/libevent2022/libevent/buffer.c next = chain->next; chain 561 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_free(chain); chain 609 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain; chain 613 opal/mca/event/libevent2022/libevent/buffer.c chain = buf->first; chain 614 opal/mca/event/libevent2022/libevent/buffer.c result = (chain != NULL ? chain->off : 0); chain 624 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain, **chainp; chain 633 opal/mca/event/libevent2022/libevent/buffer.c if ((chain = evbuffer_expand_singlechain(buf, size)) == NULL) chain 636 opal/mca/event/libevent2022/libevent/buffer.c vec[0].iov_base = CHAIN_SPACE_PTR(chain); chain 637 opal/mca/event/libevent2022/libevent/buffer.c vec[0].iov_len = (size_t) CHAIN_SPACE_LEN(chain); chain 673 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain, **firstchainp, **chainp; chain 706 opal/mca/event/libevent2022/libevent/buffer.c chain = *firstchainp; chain 710 opal/mca/event/libevent2022/libevent/buffer.c if (!chain) chain 712 opal/mca/event/libevent2022/libevent/buffer.c if (vec[i].iov_base != (void*)CHAIN_SPACE_PTR(chain) || chain 713 opal/mca/event/libevent2022/libevent/buffer.c (size_t)vec[i].iov_len > CHAIN_SPACE_LEN(chain)) chain 715 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 763 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain, **pinned; chain 776 opal/mca/event/libevent2022/libevent/buffer.c chain = *first = *pinned; chain 781 opal/mca/event/libevent2022/libevent/buffer.c if (chain->off) { chain 785 opal/mca/event/libevent2022/libevent/buffer.c tmp = evbuffer_chain_new(chain->off); chain 788 opal/mca/event/libevent2022/libevent/buffer.c memcpy(tmp->buffer, chain->buffer + chain->misalign, chain 789 opal/mca/event/libevent2022/libevent/buffer.c chain->off); chain 790 opal/mca/event/libevent2022/libevent/buffer.c tmp->off = chain->off; chain 793 opal/mca/event/libevent2022/libevent/buffer.c chain->misalign += chain->off; chain 794 opal/mca/event/libevent2022/libevent/buffer.c chain->off = 0; chain 961 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain, *next; chain 978 opal/mca/event/libevent2022/libevent/buffer.c for (chain = buf->first; chain != NULL; chain = next) { chain 979 opal/mca/event/libevent2022/libevent/buffer.c next = chain->next; chain 980 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_free(chain); chain 990 opal/mca/event/libevent2022/libevent/buffer.c for (chain = buf->first; chain 991 opal/mca/event/libevent2022/libevent/buffer.c remaining >= chain->off; chain 992 opal/mca/event/libevent2022/libevent/buffer.c chain = next) { chain 993 opal/mca/event/libevent2022/libevent/buffer.c next = chain->next; chain 994 opal/mca/event/libevent2022/libevent/buffer.c remaining -= chain->off; chain 996 opal/mca/event/libevent2022/libevent/buffer.c if (chain == *buf->last_with_datap) { chain 999 opal/mca/event/libevent2022/libevent/buffer.c if (&chain->next == buf->last_with_datap) chain 1002 opal/mca/event/libevent2022/libevent/buffer.c if (CHAIN_PINNED_R(chain)) { chain 1004 opal/mca/event/libevent2022/libevent/buffer.c chain->misalign += chain->off; chain 1005 opal/mca/event/libevent2022/libevent/buffer.c chain->off = 0; chain 1008 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_free(chain); chain 1011 opal/mca/event/libevent2022/libevent/buffer.c buf->first = chain; chain 1012 opal/mca/event/libevent2022/libevent/buffer.c if (chain) { chain 1013 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(remaining <= chain->off); chain 1014 opal/mca/event/libevent2022/libevent/buffer.c chain->misalign += remaining; chain 1015 opal/mca/event/libevent2022/libevent/buffer.c chain->off -= remaining; chain 1047 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain; chain 1054 opal/mca/event/libevent2022/libevent/buffer.c chain = buf->first; chain 1069 opal/mca/event/libevent2022/libevent/buffer.c while (datlen && datlen >= chain->off) { chain 1070 opal/mca/event/libevent2022/libevent/buffer.c memcpy(data, chain->buffer + chain->misalign, chain->off); chain 1071 opal/mca/event/libevent2022/libevent/buffer.c data += chain->off; chain 1072 opal/mca/event/libevent2022/libevent/buffer.c datlen -= chain->off; chain 1074 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 1075 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(chain || datlen==0); chain 1079 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(chain); chain 1080 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(datlen <= chain->off); chain 1081 opal/mca/event/libevent2022/libevent/buffer.c memcpy(data, chain->buffer + chain->misalign, datlen); chain 1100 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain, *previous; chain 1106 opal/mca/event/libevent2022/libevent/buffer.c chain = previous = src->first; chain 1127 opal/mca/event/libevent2022/libevent/buffer.c while (chain->off <= datlen) { chain 1131 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(chain != *src->last_with_datap); chain 1132 opal/mca/event/libevent2022/libevent/buffer.c nread += chain->off; chain 1133 opal/mca/event/libevent2022/libevent/buffer.c datlen -= chain->off; chain 1134 opal/mca/event/libevent2022/libevent/buffer.c previous = chain; chain 1135 opal/mca/event/libevent2022/libevent/buffer.c if (src->last_with_datap == &chain->next) chain 1137 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 1152 opal/mca/event/libevent2022/libevent/buffer.c src->first = chain; chain 1161 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_add(dst, chain->buffer + chain->misalign, datlen); chain 1162 opal/mca/event/libevent2022/libevent/buffer.c chain->misalign += datlen; chain 1163 opal/mca/event/libevent2022/libevent/buffer.c chain->off -= datlen; chain 1186 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain, *next, *tmp, *last_with_data; chain 1194 opal/mca/event/libevent2022/libevent/buffer.c chain = buf->first; chain 1206 opal/mca/event/libevent2022/libevent/buffer.c if (chain->off >= (size_t)size) { chain 1207 opal/mca/event/libevent2022/libevent/buffer.c result = chain->buffer + chain->misalign; chain 1212 opal/mca/event/libevent2022/libevent/buffer.c remaining = size - chain->off; chain 1214 opal/mca/event/libevent2022/libevent/buffer.c for (tmp=chain->next; tmp; tmp=tmp->next) { chain 1222 opal/mca/event/libevent2022/libevent/buffer.c if (CHAIN_PINNED(chain)) { chain 1223 opal/mca/event/libevent2022/libevent/buffer.c size_t old_off = chain->off; chain 1224 opal/mca/event/libevent2022/libevent/buffer.c if (CHAIN_SPACE_LEN(chain) < size - chain->off) { chain 1228 opal/mca/event/libevent2022/libevent/buffer.c buffer = CHAIN_SPACE_PTR(chain); chain 1229 opal/mca/event/libevent2022/libevent/buffer.c tmp = chain; chain 1232 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 1233 opal/mca/event/libevent2022/libevent/buffer.c } else if (chain->buffer_len - chain->misalign >= (size_t)size) { chain 1235 opal/mca/event/libevent2022/libevent/buffer.c size_t old_off = chain->off; chain 1236 opal/mca/event/libevent2022/libevent/buffer.c buffer = chain->buffer + chain->misalign + chain->off; chain 1237 opal/mca/event/libevent2022/libevent/buffer.c tmp = chain; chain 1240 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 1255 opal/mca/event/libevent2022/libevent/buffer.c for (; chain != NULL && (size_t)size >= chain->off; chain = next) { chain 1256 opal/mca/event/libevent2022/libevent/buffer.c next = chain->next; chain 1258 opal/mca/event/libevent2022/libevent/buffer.c memcpy(buffer, chain->buffer + chain->misalign, chain->off); chain 1259 opal/mca/event/libevent2022/libevent/buffer.c size -= chain->off; chain 1260 opal/mca/event/libevent2022/libevent/buffer.c buffer += chain->off; chain 1261 opal/mca/event/libevent2022/libevent/buffer.c if (chain == last_with_data) chain 1263 opal/mca/event/libevent2022/libevent/buffer.c if (&chain->next == buf->last_with_datap) chain 1266 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_free(chain); chain 1269 opal/mca/event/libevent2022/libevent/buffer.c if (chain != NULL) { chain 1270 opal/mca/event/libevent2022/libevent/buffer.c memcpy(buffer, chain->buffer + chain->misalign, size); chain 1271 opal/mca/event/libevent2022/libevent/buffer.c chain->misalign += size; chain 1272 opal/mca/event/libevent2022/libevent/buffer.c chain->off -= size; chain 1277 opal/mca/event/libevent2022/libevent/buffer.c tmp->next = chain; chain 1308 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain = it->_internal.chain; chain 1310 opal/mca/event/libevent2022/libevent/buffer.c while (chain != NULL) { chain 1311 opal/mca/event/libevent2022/libevent/buffer.c char *buffer = (char *)chain->buffer + chain->misalign; chain 1312 opal/mca/event/libevent2022/libevent/buffer.c char *cp = memchr(buffer+i, chr, chain->off-i); chain 1314 opal/mca/event/libevent2022/libevent/buffer.c it->_internal.chain = chain; chain 1319 opal/mca/event/libevent2022/libevent/buffer.c it->pos += chain->off - i; chain 1321 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 1357 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain = it->_internal.chain; chain 1359 opal/mca/event/libevent2022/libevent/buffer.c while (chain != NULL) { chain 1360 opal/mca/event/libevent2022/libevent/buffer.c char *buffer = (char *)chain->buffer + chain->misalign; chain 1361 opal/mca/event/libevent2022/libevent/buffer.c char *cp = find_eol_char(buffer+i, chain->off-i); chain 1363 opal/mca/event/libevent2022/libevent/buffer.c it->_internal.chain = chain; chain 1368 opal/mca/event/libevent2022/libevent/buffer.c it->pos += chain->off - i; chain 1370 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 1381 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain = ptr->_internal.chain; chain 1384 opal/mca/event/libevent2022/libevent/buffer.c if (!chain) chain 1388 opal/mca/event/libevent2022/libevent/buffer.c char *buffer = (char *)chain->buffer + chain->misalign; chain 1389 opal/mca/event/libevent2022/libevent/buffer.c for (; i < chain->off; ++i) { chain 1395 opal/mca/event/libevent2022/libevent/buffer.c ptr->_internal.chain = chain; chain 1404 opal/mca/event/libevent2022/libevent/buffer.c if (! chain->next) { chain 1405 opal/mca/event/libevent2022/libevent/buffer.c ptr->_internal.chain = chain; chain 1411 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 1419 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain = it->_internal.chain; chain 1422 opal/mca/event/libevent2022/libevent/buffer.c return chain->buffer[chain->misalign + off]; chain 1440 opal/mca/event/libevent2022/libevent/buffer.c it._internal.chain = buffer->first; chain 1546 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain, *tmp; chain 1561 opal/mca/event/libevent2022/libevent/buffer.c chain = buf->last; chain 1565 opal/mca/event/libevent2022/libevent/buffer.c if (chain == NULL) { chain 1566 opal/mca/event/libevent2022/libevent/buffer.c chain = evbuffer_chain_new(datlen); chain 1567 opal/mca/event/libevent2022/libevent/buffer.c if (!chain) chain 1569 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_insert(buf, chain); chain 1572 opal/mca/event/libevent2022/libevent/buffer.c if ((chain->flags & EVBUFFER_IMMUTABLE) == 0) { chain 1574 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(chain->misalign >= 0 && chain 1575 opal/mca/event/libevent2022/libevent/buffer.c (ev_uint64_t)chain->misalign <= EVBUFFER_CHAIN_MAX); chain 1576 opal/mca/event/libevent2022/libevent/buffer.c remain = chain->buffer_len - (size_t)chain->misalign - chain->off; chain 1580 opal/mca/event/libevent2022/libevent/buffer.c memcpy(chain->buffer + chain->misalign + chain->off, chain 1582 opal/mca/event/libevent2022/libevent/buffer.c chain->off += datlen; chain 1586 opal/mca/event/libevent2022/libevent/buffer.c } else if (!CHAIN_PINNED(chain) && chain 1587 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_should_realign(chain, datlen)) { chain 1589 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_align(chain); chain 1591 opal/mca/event/libevent2022/libevent/buffer.c memcpy(chain->buffer + chain->off, data, datlen); chain 1592 opal/mca/event/libevent2022/libevent/buffer.c chain->off += datlen; chain 1603 opal/mca/event/libevent2022/libevent/buffer.c to_alloc = chain->buffer_len; chain 1613 opal/mca/event/libevent2022/libevent/buffer.c memcpy(chain->buffer + chain->misalign + chain->off, chain 1615 opal/mca/event/libevent2022/libevent/buffer.c chain->off += remain; chain 1639 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain, *tmp; chain 1651 opal/mca/event/libevent2022/libevent/buffer.c chain = buf->first; chain 1653 opal/mca/event/libevent2022/libevent/buffer.c if (chain == NULL) { chain 1654 opal/mca/event/libevent2022/libevent/buffer.c chain = evbuffer_chain_new(datlen); chain 1655 opal/mca/event/libevent2022/libevent/buffer.c if (!chain) chain 1657 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_insert(buf, chain); chain 1661 opal/mca/event/libevent2022/libevent/buffer.c if ((chain->flags & EVBUFFER_IMMUTABLE) == 0) { chain 1663 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(chain->misalign >= 0 && chain 1664 opal/mca/event/libevent2022/libevent/buffer.c (ev_uint64_t)chain->misalign <= EVBUFFER_CHAIN_MAX); chain 1668 opal/mca/event/libevent2022/libevent/buffer.c if (chain->off == 0) chain 1669 opal/mca/event/libevent2022/libevent/buffer.c chain->misalign = chain->buffer_len; chain 1671 opal/mca/event/libevent2022/libevent/buffer.c if ((size_t)chain->misalign >= datlen) { chain 1673 opal/mca/event/libevent2022/libevent/buffer.c memcpy(chain->buffer + chain->misalign - datlen, chain 1675 opal/mca/event/libevent2022/libevent/buffer.c chain->off += datlen; chain 1676 opal/mca/event/libevent2022/libevent/buffer.c chain->misalign -= datlen; chain 1680 opal/mca/event/libevent2022/libevent/buffer.c } else if (chain->misalign) { chain 1682 opal/mca/event/libevent2022/libevent/buffer.c memcpy(chain->buffer, chain 1683 opal/mca/event/libevent2022/libevent/buffer.c (char*)data + datlen - chain->misalign, chain 1684 opal/mca/event/libevent2022/libevent/buffer.c (size_t)chain->misalign); chain 1685 opal/mca/event/libevent2022/libevent/buffer.c chain->off += (size_t)chain->misalign; chain 1686 opal/mca/event/libevent2022/libevent/buffer.c buf->total_len += (size_t)chain->misalign; chain 1687 opal/mca/event/libevent2022/libevent/buffer.c buf->n_add_for_cb += (size_t)chain->misalign; chain 1688 opal/mca/event/libevent2022/libevent/buffer.c datlen -= (size_t)chain->misalign; chain 1689 opal/mca/event/libevent2022/libevent/buffer.c chain->misalign = 0; chain 1700 opal/mca/event/libevent2022/libevent/buffer.c tmp->next = chain; chain 1708 opal/mca/event/libevent2022/libevent/buffer.c buf->n_add_for_cb += (size_t)chain->misalign; chain 1720 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_align(struct evbuffer_chain *chain) chain 1722 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(!(chain->flags & EVBUFFER_IMMUTABLE)); chain 1723 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(!(chain->flags & EVBUFFER_MEM_PINNED_ANY)); chain 1724 opal/mca/event/libevent2022/libevent/buffer.c memmove(chain->buffer, chain->buffer + chain->misalign, chain->off); chain 1725 opal/mca/event/libevent2022/libevent/buffer.c chain->misalign = 0; chain 1734 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_should_realign(struct evbuffer_chain *chain, chain 1737 opal/mca/event/libevent2022/libevent/buffer.c return chain->buffer_len - chain->off >= datlen && chain 1738 opal/mca/event/libevent2022/libevent/buffer.c (chain->off < chain->buffer_len / 2) && chain 1739 opal/mca/event/libevent2022/libevent/buffer.c (chain->off <= MAX_TO_REALIGN_IN_EXPAND); chain 1747 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain, **chainp; chain 1761 opal/mca/event/libevent2022/libevent/buffer.c chain = *chainp; chain 1763 opal/mca/event/libevent2022/libevent/buffer.c if (chain == NULL || chain 1764 opal/mca/event/libevent2022/libevent/buffer.c (chain->flags & (EVBUFFER_IMMUTABLE|EVBUFFER_MEM_PINNED_ANY))) { chain 1771 opal/mca/event/libevent2022/libevent/buffer.c if (CHAIN_SPACE_LEN(chain) >= datlen) { chain 1772 opal/mca/event/libevent2022/libevent/buffer.c result = chain; chain 1778 opal/mca/event/libevent2022/libevent/buffer.c if (chain->off == 0) { chain 1788 opal/mca/event/libevent2022/libevent/buffer.c if (evbuffer_chain_should_realign(chain, datlen)) { chain 1789 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_align(chain); chain 1790 opal/mca/event/libevent2022/libevent/buffer.c result = chain; chain 1801 opal/mca/event/libevent2022/libevent/buffer.c if (CHAIN_SPACE_LEN(chain) < chain->buffer_len / 8 || chain 1802 opal/mca/event/libevent2022/libevent/buffer.c chain->off > MAX_TO_COPY_IN_EXPAND || chain 1804 opal/mca/event/libevent2022/libevent/buffer.c EVBUFFER_CHAIN_MAX - datlen >= chain->off)) { chain 1807 opal/mca/event/libevent2022/libevent/buffer.c if (chain->next && CHAIN_SPACE_LEN(chain->next) >= datlen) { chain 1810 opal/mca/event/libevent2022/libevent/buffer.c result = chain->next; chain 1823 opal/mca/event/libevent2022/libevent/buffer.c size_t length = chain->off + datlen; chain 1829 opal/mca/event/libevent2022/libevent/buffer.c tmp->off = chain->off; chain 1830 opal/mca/event/libevent2022/libevent/buffer.c memcpy(tmp->buffer, chain->buffer + chain->misalign, chain 1831 opal/mca/event/libevent2022/libevent/buffer.c chain->off); chain 1833 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(*chainp == chain); chain 1836 opal/mca/event/libevent2022/libevent/buffer.c if (buf->last == chain) chain 1839 opal/mca/event/libevent2022/libevent/buffer.c tmp->next = chain->next; chain 1840 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_free(chain); chain 1860 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain = buf->last, *tmp, *next; chain 1867 opal/mca/event/libevent2022/libevent/buffer.c if (chain == NULL || (chain->flags & EVBUFFER_IMMUTABLE)) { chain 1870 opal/mca/event/libevent2022/libevent/buffer.c chain = evbuffer_chain_new(datlen); chain 1871 opal/mca/event/libevent2022/libevent/buffer.c if (chain == NULL) chain 1874 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_insert(buf, chain); chain 1883 opal/mca/event/libevent2022/libevent/buffer.c for (chain = *buf->last_with_datap; chain; chain = chain->next) { chain 1884 opal/mca/event/libevent2022/libevent/buffer.c if (chain->off) { chain 1885 opal/mca/event/libevent2022/libevent/buffer.c size_t space = (size_t) CHAIN_SPACE_LEN(chain); chain 1886 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(chain == *buf->last_with_datap); chain 1893 opal/mca/event/libevent2022/libevent/buffer.c chain->misalign = 0; chain 1894 opal/mca/event/libevent2022/libevent/buffer.c avail += chain->buffer_len; chain 1911 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(chain == NULL); chain 1926 opal/mca/event/libevent2022/libevent/buffer.c chain = *buf->last_with_datap; chain 1927 opal/mca/event/libevent2022/libevent/buffer.c if (!chain->off) { chain 1928 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(chain == buf->first); chain 1934 opal/mca/event/libevent2022/libevent/buffer.c avail = (size_t) CHAIN_SPACE_LEN(chain); chain 1935 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 1939 opal/mca/event/libevent2022/libevent/buffer.c for (; chain; chain = next) { chain 1940 opal/mca/event/libevent2022/libevent/buffer.c next = chain->next; chain 1941 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(chain->off == 0); chain 1942 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_free(chain); chain 1970 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain; chain 1973 opal/mca/event/libevent2022/libevent/buffer.c chain = evbuffer_expand_singlechain(buf, datlen); chain 1975 opal/mca/event/libevent2022/libevent/buffer.c return chain ? 0 : -1; chain 2036 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain; chain 2052 opal/mca/event/libevent2022/libevent/buffer.c chain = *firstchainp; chain 2054 opal/mca/event/libevent2022/libevent/buffer.c size_t avail = (size_t) CHAIN_SPACE_LEN(chain); chain 2057 opal/mca/event/libevent2022/libevent/buffer.c vecs[i].iov_base = CHAIN_SPACE_PTR(chain); chain 2060 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 2098 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain; chain 2160 opal/mca/event/libevent2022/libevent/buffer.c if ((chain = evbuffer_expand_singlechain(buf, howmuch)) == NULL) { chain 2166 opal/mca/event/libevent2022/libevent/buffer.c p = chain->buffer + chain->misalign + chain->off; chain 2205 opal/mca/event/libevent2022/libevent/buffer.c chain->off += n; chain 2275 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain = buffer->first; chain 2285 opal/mca/event/libevent2022/libevent/buffer.c while (chain != NULL && i < NUM_WRITE_IOVEC && howmuch) { chain 2288 opal/mca/event/libevent2022/libevent/buffer.c if (chain->flags & EVBUFFER_SENDFILE) chain 2291 opal/mca/event/libevent2022/libevent/buffer.c iov[i].IOV_PTR_FIELD = (void *) (chain->buffer + chain->misalign); chain 2292 opal/mca/event/libevent2022/libevent/buffer.c if ((size_t)howmuch >= chain->off) { chain 2294 opal/mca/event/libevent2022/libevent/buffer.c iov[i++].IOV_LEN_FIELD = (IOV_LEN_TYPE)chain->off; chain 2295 opal/mca/event/libevent2022/libevent/buffer.c howmuch -= chain->off; chain 2301 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 2325 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain = buffer->first; chain 2327 opal/mca/event/libevent2022/libevent/buffer.c EVBUFFER_CHAIN_EXTRA(struct evbuffer_chain_fd, chain); chain 2330 opal/mca/event/libevent2022/libevent/buffer.c off_t len = chain->off; chain 2333 opal/mca/event/libevent2022/libevent/buffer.c off_t offset = chain->misalign; chain 2339 opal/mca/event/libevent2022/libevent/buffer.c res = sendfile(info->fd, fd, chain->misalign, &len, NULL, 0); chain 2345 opal/mca/event/libevent2022/libevent/buffer.c res = sendfile(info->fd, fd, chain->misalign, chain->off, NULL, &len, 0); chain 2352 opal/mca/event/libevent2022/libevent/buffer.c res = sendfile(fd, info->fd, &offset, chain->off); chain 2361 opal/mca/event/libevent2022/libevent/buffer.c res = sendfile(fd, info->fd, &offset, chain->off); chain 2392 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain = buffer->first; chain 2393 opal/mca/event/libevent2022/libevent/buffer.c if (chain != NULL && (chain->flags & EVBUFFER_SENDFILE)) chain 2454 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain = NULL; chain 2460 opal/mca/event/libevent2022/libevent/buffer.c chain = buf->first; chain 2471 opal/mca/event/libevent2022/libevent/buffer.c chain = pos->_internal.chain; chain 2478 opal/mca/event/libevent2022/libevent/buffer.c while (chain && position + left >= chain->off) { chain 2479 opal/mca/event/libevent2022/libevent/buffer.c left -= chain->off - position; chain 2480 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 2483 opal/mca/event/libevent2022/libevent/buffer.c if (chain) { chain 2484 opal/mca/event/libevent2022/libevent/buffer.c pos->_internal.chain = chain; chain 2487 opal/mca/event/libevent2022/libevent/buffer.c pos->_internal.chain = NULL; chain 2493 opal/mca/event/libevent2022/libevent/buffer.c return chain != NULL ? 0 : -1; chain 2504 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain; chain 2515 opal/mca/event/libevent2022/libevent/buffer.c chain = pos->_internal.chain; chain 2517 opal/mca/event/libevent2022/libevent/buffer.c while (len && chain) { chain 2519 opal/mca/event/libevent2022/libevent/buffer.c if (len + position > chain->off) chain 2520 opal/mca/event/libevent2022/libevent/buffer.c n_comparable = chain->off - position; chain 2523 opal/mca/event/libevent2022/libevent/buffer.c r = memcmp(chain->buffer + chain->misalign + position, mem, chain 2530 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 2546 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain, *last_chain = NULL; chain 2554 opal/mca/event/libevent2022/libevent/buffer.c chain = pos._internal.chain; chain 2557 opal/mca/event/libevent2022/libevent/buffer.c chain = pos._internal.chain = buffer->first; chain 2562 opal/mca/event/libevent2022/libevent/buffer.c last_chain = end->_internal.chain; chain 2569 opal/mca/event/libevent2022/libevent/buffer.c while (chain) { chain 2571 opal/mca/event/libevent2022/libevent/buffer.c chain->buffer + chain->misalign + chain 2574 opal/mca/event/libevent2022/libevent/buffer.c chain->off - pos._internal.pos_in_chain); chain 2586 opal/mca/event/libevent2022/libevent/buffer.c if (pos._internal.pos_in_chain == chain->off) { chain 2587 opal/mca/event/libevent2022/libevent/buffer.c chain = pos._internal.chain = chain->next; chain 2591 opal/mca/event/libevent2022/libevent/buffer.c if (chain == last_chain) chain 2593 opal/mca/event/libevent2022/libevent/buffer.c pos.pos += chain->off - pos._internal.pos_in_chain; chain 2594 opal/mca/event/libevent2022/libevent/buffer.c chain = pos._internal.chain = chain->next; chain 2601 opal/mca/event/libevent2022/libevent/buffer.c pos._internal.chain = NULL; chain 2612 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain; chain 2619 opal/mca/event/libevent2022/libevent/buffer.c chain = start_at->_internal.chain; chain 2620 opal/mca/event/libevent2022/libevent/buffer.c len_so_far = chain->off chain 2624 opal/mca/event/libevent2022/libevent/buffer.c vec[0].iov_base = chain->buffer + chain->misalign chain 2628 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 2630 opal/mca/event/libevent2022/libevent/buffer.c chain = buffer->first; chain 2642 opal/mca/event/libevent2022/libevent/buffer.c while (chain) { chain 2646 opal/mca/event/libevent2022/libevent/buffer.c vec[idx].iov_base = chain->buffer + chain->misalign; chain 2647 opal/mca/event/libevent2022/libevent/buffer.c vec[idx].iov_len = chain->off; chain 2652 opal/mca/event/libevent2022/libevent/buffer.c len_so_far += chain->off; chain 2653 opal/mca/event/libevent2022/libevent/buffer.c chain = chain->next; chain 2669 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain; chain 2679 opal/mca/event/libevent2022/libevent/buffer.c if ((chain = evbuffer_expand_singlechain(buf, 64)) == NULL) chain 2684 opal/mca/event/libevent2022/libevent/buffer.c size_t used = chain->misalign + chain->off; chain 2685 opal/mca/event/libevent2022/libevent/buffer.c buffer = (char *)chain->buffer + chain->misalign + chain->off; chain 2686 opal/mca/event/libevent2022/libevent/buffer.c EVUTIL_ASSERT(chain->buffer_len >= used); chain 2687 opal/mca/event/libevent2022/libevent/buffer.c space = chain->buffer_len - used; chain 2689 opal/mca/event/libevent2022/libevent/buffer.c buffer = (char*) CHAIN_SPACE_PTR(chain); chain 2690 opal/mca/event/libevent2022/libevent/buffer.c space = (size_t) CHAIN_SPACE_LEN(chain); chain 2707 opal/mca/event/libevent2022/libevent/buffer.c chain->off += sz; chain 2716 opal/mca/event/libevent2022/libevent/buffer.c if ((chain = evbuffer_expand_singlechain(buf, sz + 1)) == NULL) chain 2744 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain; chain 2748 opal/mca/event/libevent2022/libevent/buffer.c chain = evbuffer_chain_new(sizeof(struct evbuffer_chain_reference)); chain 2749 opal/mca/event/libevent2022/libevent/buffer.c if (!chain) chain 2751 opal/mca/event/libevent2022/libevent/buffer.c chain->flags |= EVBUFFER_REFERENCE | EVBUFFER_IMMUTABLE; chain 2752 opal/mca/event/libevent2022/libevent/buffer.c chain->buffer = (u_char *)data; chain 2753 opal/mca/event/libevent2022/libevent/buffer.c chain->buffer_len = datlen; chain 2754 opal/mca/event/libevent2022/libevent/buffer.c chain->off = datlen; chain 2756 opal/mca/event/libevent2022/libevent/buffer.c info = EVBUFFER_CHAIN_EXTRA(struct evbuffer_chain_reference, chain); chain 2764 opal/mca/event/libevent2022/libevent/buffer.c mm_free(chain); chain 2767 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_insert(outbuf, chain); chain 2791 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_chain *chain; chain 2812 opal/mca/event/libevent2022/libevent/buffer.c chain = evbuffer_chain_new(sizeof(struct evbuffer_chain_fd)); chain 2813 opal/mca/event/libevent2022/libevent/buffer.c if (chain == NULL) { chain 2818 opal/mca/event/libevent2022/libevent/buffer.c chain->flags |= EVBUFFER_SENDFILE | EVBUFFER_IMMUTABLE; chain 2819 opal/mca/event/libevent2022/libevent/buffer.c chain->buffer = NULL; /* no reading possible */ chain 2820 opal/mca/event/libevent2022/libevent/buffer.c chain->buffer_len = length + offset; chain 2821 opal/mca/event/libevent2022/libevent/buffer.c chain->off = length; chain 2822 opal/mca/event/libevent2022/libevent/buffer.c chain->misalign = offset; chain 2824 opal/mca/event/libevent2022/libevent/buffer.c info = EVBUFFER_CHAIN_EXTRA(struct evbuffer_chain_fd, chain); chain 2829 opal/mca/event/libevent2022/libevent/buffer.c mm_free(chain); chain 2833 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_insert(outbuf, chain); chain 2859 opal/mca/event/libevent2022/libevent/buffer.c chain = evbuffer_chain_new(sizeof(struct evbuffer_chain_fd)); chain 2860 opal/mca/event/libevent2022/libevent/buffer.c if (chain == NULL) { chain 2866 opal/mca/event/libevent2022/libevent/buffer.c chain->flags |= EVBUFFER_MMAP | EVBUFFER_IMMUTABLE; chain 2867 opal/mca/event/libevent2022/libevent/buffer.c chain->buffer = mapped; chain 2868 opal/mca/event/libevent2022/libevent/buffer.c chain->buffer_len = length + offset; chain 2869 opal/mca/event/libevent2022/libevent/buffer.c chain->off = length + offset; chain 2871 opal/mca/event/libevent2022/libevent/buffer.c info = EVBUFFER_CHAIN_EXTRA(struct evbuffer_chain_fd, chain); chain 2877 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_free(chain); chain 2882 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_chain_insert(outbuf, chain); chain 85 opal/mca/event/libevent2022/libevent/buffer_iocp.c struct evbuffer_chain *next, *chain = eo->first_pinned; chain 88 opal/mca/event/libevent2022/libevent/buffer_iocp.c EVUTIL_ASSERT(chain); chain 89 opal/mca/event/libevent2022/libevent/buffer_iocp.c next = chain->next; chain 90 opal/mca/event/libevent2022/libevent/buffer_iocp.c _evbuffer_chain_unpin(chain, flag); chain 91 opal/mca/event/libevent2022/libevent/buffer_iocp.c chain = next; chain 176 opal/mca/event/libevent2022/libevent/buffer_iocp.c struct evbuffer_chain *chain; chain 201 opal/mca/event/libevent2022/libevent/buffer_iocp.c chain = buf_o->first_pinned = buf->first; chain 203 opal/mca/event/libevent2022/libevent/buffer_iocp.c for (i=0; i < MAX_WSABUFS && chain; ++i, chain=chain->next) { chain 205 opal/mca/event/libevent2022/libevent/buffer_iocp.c b->buf = (char*)( chain->buffer + chain->misalign ); chain 206 opal/mca/event/libevent2022/libevent/buffer_iocp.c _evbuffer_chain_pin(chain, EVBUFFER_MEM_PINNED_W); chain 208 opal/mca/event/libevent2022/libevent/buffer_iocp.c if ((size_t)at_most > chain->off) { chain 213 opal/mca/event/libevent2022/libevent/buffer_iocp.c b->len = (unsigned long)chain->off; chain 214 opal/mca/event/libevent2022/libevent/buffer_iocp.c at_most -= chain->off; chain 251 opal/mca/event/libevent2022/libevent/buffer_iocp.c struct evbuffer_chain *chain=NULL, **chainp; chain 280 opal/mca/event/libevent2022/libevent/buffer_iocp.c buf_o->first_pinned = chain = *chainp; chain 283 opal/mca/event/libevent2022/libevent/buffer_iocp.c for ( ; chain; chain = chain->next) { chain 284 opal/mca/event/libevent2022/libevent/buffer_iocp.c _evbuffer_chain_pin(chain, EVBUFFER_MEM_PINNED_R); chain 255 opal/mca/event/libevent2022/libevent/evbuffer-internal.h void _evbuffer_chain_pin(struct evbuffer_chain *chain, unsigned flag); chain 257 opal/mca/event/libevent2022/libevent/evbuffer-internal.h void _evbuffer_chain_unpin(struct evbuffer_chain *chain, unsigned flag); chain 114 opal/mca/event/libevent2022/libevent/include/event2/buffer.h void *chain; chain 69 opal/mca/event/libevent2022/libevent/test/regress_buffer.c struct evbuffer_chain *chain; chain 78 opal/mca/event/libevent2022/libevent/test/regress_buffer.c chain = buf->first; chain 84 opal/mca/event/libevent2022/libevent/test/regress_buffer.c while (chain != NULL) { chain 85 opal/mca/event/libevent2022/libevent/test/regress_buffer.c if (&chain->next == buf->last_with_datap) chain 87 opal/mca/event/libevent2022/libevent/test/regress_buffer.c sum += chain->off; chain 88 opal/mca/event/libevent2022/libevent/test/regress_buffer.c if (chain->next == NULL) { chain 89 opal/mca/event/libevent2022/libevent/test/regress_buffer.c tt_assert(buf->last == chain); chain 91 opal/mca/event/libevent2022/libevent/test/regress_buffer.c tt_assert(chain->buffer_len >= chain->misalign + chain->off); chain 92 opal/mca/event/libevent2022/libevent/test/regress_buffer.c chain = chain->next; chain 99 opal/mca/event/libevent2022/libevent/test/regress_buffer.c chain = *buf->last_with_datap; chain 100 opal/mca/event/libevent2022/libevent/test/regress_buffer.c if (chain->off == 0 || buf->total_len == 0) { chain 101 opal/mca/event/libevent2022/libevent/test/regress_buffer.c tt_assert(chain->off == 0) chain 102 opal/mca/event/libevent2022/libevent/test/regress_buffer.c tt_assert(chain == buf->first); chain 105 opal/mca/event/libevent2022/libevent/test/regress_buffer.c chain = chain->next; chain 106 opal/mca/event/libevent2022/libevent/test/regress_buffer.c while (chain != NULL) { chain 107 opal/mca/event/libevent2022/libevent/test/regress_buffer.c tt_assert(chain->off == 0); chain 108 opal/mca/event/libevent2022/libevent/test/regress_buffer.c chain = chain->next; chain 124 opal/mca/event/libevent2022/libevent/test/regress_buffer.c struct evbuffer_chain *chain; chain 129 opal/mca/event/libevent2022/libevent/test/regress_buffer.c chain = buf->first; chain 131 opal/mca/event/libevent2022/libevent/test/regress_buffer.c while (chain && chain->off==0) { chain 133 opal/mca/event/libevent2022/libevent/test/regress_buffer.c a += chain->buffer_len; chain 134 opal/mca/event/libevent2022/libevent/test/regress_buffer.c chain = chain->next; chain 137 opal/mca/event/libevent2022/libevent/test/regress_buffer.c if (chain) { chain 139 opal/mca/event/libevent2022/libevent/test/regress_buffer.c a += chain->buffer_len; chain 140 opal/mca/event/libevent2022/libevent/test/regress_buffer.c u += chain->off; chain 141 opal/mca/event/libevent2022/libevent/test/regress_buffer.c if (chain->next && chain->next->off) chain 142 opal/mca/event/libevent2022/libevent/test/regress_buffer.c w += (size_t)(chain->buffer_len - (chain->misalign + chain->off)); chain 143 opal/mca/event/libevent2022/libevent/test/regress_buffer.c chain = chain->next; chain 146 opal/mca/event/libevent2022/libevent/test/regress_buffer.c while (chain && chain->off) { chain 148 opal/mca/event/libevent2022/libevent/test/regress_buffer.c a += chain->buffer_len; chain 149 opal/mca/event/libevent2022/libevent/test/regress_buffer.c w += (size_t)chain->misalign; chain 150 opal/mca/event/libevent2022/libevent/test/regress_buffer.c u += chain->off; chain 151 opal/mca/event/libevent2022/libevent/test/regress_buffer.c if (chain->next && chain->next->off) chain 152 opal/mca/event/libevent2022/libevent/test/regress_buffer.c w += (size_t) (chain->buffer_len - (chain->misalign + chain->off)); chain 153 opal/mca/event/libevent2022/libevent/test/regress_buffer.c chain = chain->next; chain 156 opal/mca/event/libevent2022/libevent/test/regress_buffer.c while (chain) { chain 158 opal/mca/event/libevent2022/libevent/test/regress_buffer.c a += chain->buffer_len; chain 242 opal/mca/event/libevent2022/libevent/test/regress_iocp.c struct evbuffer_chain *chain; chain 275 opal/mca/event/libevent2022/libevent/test/regress_iocp.c for (chain = buf->first; chain; chain = chain->next) chain 276 opal/mca/event/libevent2022/libevent/test/regress_iocp.c tt_int_op(chain->flags & EVBUFFER_MEM_PINNED_ANY, ==, 0); chain 81 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_event_chain_t *chain = (pmix_event_chain_t*)cbdata; chain 82 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_ACQUIRE_OBJECT(chain); chain 83 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_RELEASE(chain); chain 93 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_event_chain_t *chain; chain 106 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c chain = PMIX_NEW(pmix_event_chain_t); chain 107 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if (NULL == chain) { chain 111 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c chain->final_cbfunc = _notify_complete; chain 112 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c chain->final_cbdata = chain; chain 119 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_RELEASE(chain); chain 125 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c buf, &chain->status, &cnt, PMIX_STATUS); chain 128 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_RELEASE(chain); chain 135 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c buf, &chain->source, &cnt, PMIX_PROC); chain 138 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_RELEASE(chain); chain 148 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_RELEASE(chain); chain 153 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c chain->nallocated = ninfo + 2; chain 154 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_INFO_CREATE(chain->info, chain->nallocated); chain 155 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if (NULL == chain->info) { chain 157 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_RELEASE(chain); chain 162 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c chain->ninfo = ninfo; chain 165 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c buf, chain->info, &cnt, PMIX_INFO); chain 168 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_RELEASE(chain); chain 173 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_prep_event_chain(chain, chain->info, ninfo, false); chain 177 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_globals.myid.nspace, pmix_globals.myid.rank, PMIx_Error_string(chain->status)); chain 179 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_invoke_local_event_hdlr(chain); chain 186 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c chain = PMIX_NEW(pmix_event_chain_t); chain 187 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if (NULL == chain) { chain 191 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c chain->status = rc; chain 192 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_invoke_local_event_hdlr(chain); chain 150 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event.h pmix_status_t pmix_prep_event_chain(pmix_event_chain_t *chain, chain 157 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event.h void pmix_invoke_local_event_hdlr(pmix_event_chain_t *chain); chain 167 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_event_chain_t *chain; chain 220 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain = PMIX_NEW(pmix_event_chain_t); chain 221 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->status = status; chain 222 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_strncpy(chain->source.nspace, pmix_globals.myid.nspace, PMIX_MAX_NSLEN); chain 223 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->source.rank = pmix_globals.myid.rank; chain 225 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->nallocated = ninfo + 2; chain 226 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_CREATE(chain->info, chain->nallocated); chain 228 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_prep_event_chain(chain, info, ninfo, true); chain 242 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (0 < chain->ninfo) { chain 243 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c cd->ninfo = chain->ninfo; chain 245 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c cd->nondefault = chain->nondefault; chain 248 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_XFER(&cd->info[n], &chain->info[n]); chain 251 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->targets) { chain 252 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c cd->ntargets = chain->ntargets; chain 254 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c memcpy(cd->targets, chain->targets, cd->ntargets * sizeof(pmix_proc_t)); chain 256 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->affected) { chain 257 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c cd->naffected = chain->naffected; chain 264 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c memcpy(cd->affected, chain->affected, cd->naffected * sizeof(pmix_proc_t)); chain 301 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_invoke_local_event_hdlr(chain); chain 324 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_event_chain_t *chain = (pmix_event_chain_t*)notification_cbdata; chain 334 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c for (n=0; n < chain->nresults; n++) { chain 335 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (0 < strlen(chain->results[n].key)) { chain 349 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c for (n=0; n < chain->nresults; n++) { chain 350 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (0 < strlen(chain->results[n].key)) { chain 351 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_XFER(&newinfo[cnt], &chain->results[n]); chain 357 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->name) { chain 358 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_strncpy(newinfo[cnt].key, chain->evhdlr->name, PMIX_MAX_KEYLEN); chain 371 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (0 < chain->nresults) { chain 372 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_FREE(chain->results, chain->nresults); chain 375 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->results = newinfo; chain 376 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->nresults = cnt; chain 378 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo = chain->nallocated - 2; chain 379 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_DESTRUCT(&chain->info[chain->nallocated-2]); chain 380 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_DESTRUCT(&chain->info[chain->nallocated-1]); chain 384 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (PMIX_EVENT_ACTION_COMPLETE == status || chain->endchain) { chain 390 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (1 == chain->evhdlr->ncodes) { chain 393 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c item = &chain->evhdlr->super; chain 396 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (nxt->codes[0] == chain->status && chain 397 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_notify_check_range(&nxt->rng, &chain->source) && chain 399 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->affected, chain->naffected)) { chain 400 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = nxt; chain 402 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo = chain->nallocated - 2; chain 404 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->name) { chain 405 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_HDLR_NAME, chain->evhdlr->name, PMIX_STRING); chain 406 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 410 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->cbobject) { chain 411 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_RETURN_OBJECT, chain->evhdlr->cbobject, PMIX_POINTER); chain 412 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 415 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->status, &chain->source, chain 416 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->info, chain->ninfo, chain 417 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->results, chain->nresults, chain 418 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c progress_local_event_hdlr, (void*)chain); chain 428 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->codes || NULL != item) { chain 433 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c item = &chain->evhdlr->super; chain 437 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (!pmix_notify_check_range(&nxt->rng, &chain->source) || chain 439 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->affected, chain->naffected)) { chain 445 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (nxt->codes[n] == chain->status) { chain 446 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = nxt; chain 448 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo = chain->nallocated - 2; chain 450 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->name) { chain 451 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_HDLR_NAME, chain->evhdlr->name, PMIX_STRING); chain 452 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 456 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->cbobject) { chain 457 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_RETURN_OBJECT, chain->evhdlr->cbobject, PMIX_POINTER); chain 458 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 461 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->status, &chain->source, chain 462 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->info, chain->ninfo, chain 463 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->results, chain->nresults, chain 464 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c progress_local_event_hdlr, (void*)chain); chain 475 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (!chain->nondefault) { chain 477 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c item = &chain->evhdlr->super; chain 483 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (pmix_notify_check_range(&nxt->rng, &chain->source) && chain 485 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->affected, chain->naffected)) { chain 486 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = nxt; chain 488 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo = chain->nallocated - 2; chain 490 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->name) { chain 491 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_HDLR_NAME, chain->evhdlr->name, PMIX_STRING); chain 492 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 496 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->cbobject) { chain 497 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_RETURN_OBJECT, chain->evhdlr->cbobject, PMIX_POINTER); chain 498 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 501 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->status, &chain->source, chain 502 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->info, chain->ninfo, chain 503 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->results, chain->nresults, chain 504 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c progress_local_event_hdlr, (void*)chain); chain 513 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_notify_check_range(&pmix_globals.events.last->rng, &chain->source) && chain 515 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->affected, chain->naffected)) { chain 516 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->endchain = true; // ensure we don't do this again chain 518 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_globals.events.last->codes[0] == chain->status) { chain 519 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = pmix_globals.events.last; chain 521 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo = chain->nallocated - 2; chain 523 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->name) { chain 524 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_HDLR_NAME, chain->evhdlr->name, PMIX_STRING); chain 525 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 529 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->cbobject) { chain 530 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_RETURN_OBJECT, chain->evhdlr->cbobject, PMIX_POINTER); chain 531 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 533 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr->evhdlr(chain->evhdlr->index, chain 534 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->status, &chain->source, chain 535 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->info, chain->ninfo, chain 536 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->results, chain->nresults, chain 537 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c progress_local_event_hdlr, (void*)chain); chain 542 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (pmix_globals.events.last->codes[n] == chain->status) { chain 543 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = pmix_globals.events.last; chain 545 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo = chain->nallocated - 2; chain 547 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->name) { chain 548 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_HDLR_NAME, chain->evhdlr->name, PMIX_STRING); chain 549 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 553 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->cbobject) { chain 554 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_RETURN_OBJECT, chain->evhdlr->cbobject, PMIX_POINTER); chain 555 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 557 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr->evhdlr(chain->evhdlr->index, chain 558 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->status, &chain->source, chain 559 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->info, chain->ninfo, chain 560 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->results, chain->nresults, chain 561 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c progress_local_event_hdlr, (void*)chain); chain 567 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = pmix_globals.events.last; chain 569 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo = chain->nallocated - 2; chain 571 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->name) { chain 572 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_HDLR_NAME, chain->evhdlr->name, PMIX_STRING); chain 573 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 577 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->cbobject) { chain 578 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_RETURN_OBJECT, chain->evhdlr->cbobject, PMIX_POINTER); chain 579 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 581 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr->evhdlr(chain->evhdlr->index, chain 582 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->status, &chain->source, chain 583 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->info, chain->ninfo, chain 584 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->results, chain->nresults, chain 585 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c progress_local_event_hdlr, (void*)chain); chain 592 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->final_cbfunc) { chain 593 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->final_cbfunc(PMIX_SUCCESS, chain->final_cbdata); chain 597 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_RELEASE(chain); chain 613 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c void pmix_invoke_local_event_hdlr(pmix_event_chain_t *chain) chain 625 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIx_Error_string(chain->status)); chain 628 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL == chain->info) { chain 636 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->targets) { chain 638 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c for (i=0; i < chain->ntargets; i++) { chain 639 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (PMIX_CHECK_PROCID(&chain->targets[i], &pmix_globals.myid)) { chain 653 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_globals.events.first->codes[0] == chain->status && chain 654 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_notify_check_range(&pmix_globals.events.first->rng, &chain->source) && chain 656 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->affected, chain->naffected)) { chain 658 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = pmix_globals.events.first; chain 664 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (pmix_globals.events.first->codes[i] == chain->status) { chain 671 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (found && pmix_notify_check_range(&pmix_globals.events.first->rng, &chain->source)) { chain 673 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = pmix_globals.events.first; chain 678 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (pmix_notify_check_range(&pmix_globals.events.first->rng, &chain->source)) { chain 680 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = pmix_globals.events.first; chain 689 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (evhdlr->codes[0] == chain->status) { chain 690 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (pmix_notify_check_range(&evhdlr->rng, &chain->source) && chain 692 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->affected, chain->naffected)) { chain 694 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = evhdlr; chain 704 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (evhdlr->codes[i] == chain->status) { chain 705 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (pmix_notify_check_range(&evhdlr->rng, &chain->source) && chain 707 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->affected, chain->naffected)) { chain 709 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = evhdlr; chain 717 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (!chain->nondefault) { chain 720 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (pmix_notify_check_range(&evhdlr->rng, &chain->source) && chain 722 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->affected, chain->naffected)) { chain 724 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = evhdlr; chain 733 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_notify_check_range(&pmix_globals.events.last->rng, &chain->source) && chain 735 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->affected, chain->naffected)) { chain 736 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->endchain = true; // ensure we don't do this again chain 738 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_globals.events.last->codes[0] == chain->status) { chain 739 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = pmix_globals.events.last; chain 744 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (pmix_globals.events.last->codes[i] == chain->status) { chain 745 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = pmix_globals.events.last; chain 751 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr = pmix_globals.events.last; chain 760 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->final_cbfunc) { chain 761 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->final_cbfunc(rc, chain->final_cbdata); chain 763 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_RELEASE(chain); chain 770 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo = chain->nallocated - 2; chain 773 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->name) { chain 774 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_HDLR_NAME, chain->evhdlr->name, PMIX_STRING); chain 775 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 779 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->evhdlr->cbobject) { chain 780 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_LOAD(&chain->info[chain->ninfo], PMIX_EVENT_RETURN_OBJECT, chain->evhdlr->cbobject, PMIX_POINTER); chain 781 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo++; chain 787 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c (NULL == chain->evhdlr->name) ? chain 788 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c "NULL" : chain->evhdlr->name); chain 789 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->evhdlr->evhdlr(chain->evhdlr->index, chain 790 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->status, &chain->source, chain 791 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->info, chain->ninfo, chain 793 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c progress_local_event_hdlr, (void*)chain); chain 812 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_event_chain_t *chain; chain 860 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain = PMIX_NEW(pmix_event_chain_t); chain 861 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->status = cd->status; chain 862 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_strncpy(chain->source.nspace, cd->source.nspace, PMIX_MAX_NSLEN); chain 863 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->source.rank = cd->source.rank; chain 866 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->nallocated = cd->ninfo + 2; chain 867 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_CREATE(chain->info, chain->nallocated); chain 869 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_prep_event_chain(chain, cd->info, cd->ninfo, true); chain 872 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c cd->nondefault = chain->nondefault; chain 873 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->targets) { chain 874 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c cd->ntargets = chain->ntargets; chain 876 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c memcpy(cd->targets, chain->targets, cd->ntargets * sizeof(pmix_proc_t)); chain 903 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != chain->affected) { chain 904 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c cd->naffected = chain->naffected; chain 913 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_RELEASE(chain); chain 916 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c memcpy(cd->affected, chain->affected, cd->naffected * sizeof(pmix_proc_t)); chain 929 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_RELEASE(chain); chain 954 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_RELEASE(chain); chain 965 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_RELEASE(chain); chain 1109 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_invoke_local_event_hdlr(chain); chain 1279 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_status_t pmix_prep_event_chain(pmix_event_chain_t *chain, chain 1286 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ninfo = ninfo; chain 1287 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL == chain->info) { chain 1288 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_CREATE(chain->info, chain->ninfo); chain 1294 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_INFO_XFER(&chain->info[n], &info[n]); chain 1298 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->nondefault = PMIX_INFO_TRUE(&info[n]); chain 1305 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ntargets = info[n].value.data.darray->size; chain 1306 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_PROC_CREATE(chain->targets, chain->ntargets); chain 1307 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c memcpy(chain->targets, info[n].value.data.darray->array, chain->ntargets * sizeof(pmix_proc_t)); chain 1309 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->ntargets = 1; chain 1310 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_PROC_CREATE(chain->targets, chain->ntargets); chain 1311 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c memcpy(chain->targets, info[n].value.data.proc, sizeof(pmix_proc_t)); chain 1318 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_PROC_CREATE(chain->affected, 1); chain 1319 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL == chain->affected) { chain 1322 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->naffected = 1; chain 1323 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c memcpy(chain->affected, info[n].value.data.proc, sizeof(pmix_proc_t)); chain 1325 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->naffected = info[n].value.data.darray->size; chain 1326 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_PROC_CREATE(chain->affected, chain->naffected); chain 1327 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL == chain->affected) { chain 1328 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c chain->naffected = 0; chain 1331 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c memcpy(chain->affected, info[n].value.data.darray->array, chain->naffected * sizeof(pmix_proc_t)); chain 366 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_event_chain_t *chain; chain 411 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c chain = PMIX_NEW(pmix_event_chain_t); chain 412 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c chain->status = ncd->status; chain 413 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_strncpy(chain->source.nspace, pmix_globals.myid.nspace, PMIX_MAX_NSLEN); chain 414 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c chain->source.rank = pmix_globals.myid.rank; chain 416 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c chain->nallocated = ncd->ninfo + 2; chain 417 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_INFO_CREATE(chain->info, chain->nallocated); chain 419 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c chain->ninfo = ncd->ninfo; chain 422 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_INFO_XFER(&chain->info[n], &ncd->info[n]); chain 424 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c chain->nondefault = true; chain 426 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_PROC_CREATE(chain->affected, 1); chain 427 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL == chain->affected) { chain 428 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_RELEASE(chain); chain 431 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c chain->naffected = 1; chain 432 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c memcpy(chain->affected, ncd->info[n].value.data.proc, sizeof(pmix_proc_t)); chain 434 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c chain->naffected = ncd->info[n].value.data.darray->size; chain 435 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_PROC_CREATE(chain->affected, chain->naffected); chain 436 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL == chain->affected) { chain 437 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c chain->naffected = 0; chain 438 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_RELEASE(chain); chain 441 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c memcpy(chain->affected, ncd->info[n].value.data.darray->array, chain->naffected * sizeof(pmix_proc_t)); chain 453 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c chain->endchain = true; chain 455 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_invoke_local_event_hdlr(chain); chain 53 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_event_chain_t *chain = (pmix_event_chain_t*)cbdata; chain 54 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_RELEASE(chain); chain 78 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_event_chain_t *chain = (pmix_event_chain_t*)cbdata; chain 79 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_RELEASE(chain); chain 89 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_event_chain_t *chain; chain 102 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c chain = PMIX_NEW(pmix_event_chain_t); chain 103 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c chain->final_cbfunc = _notify_complete; chain 104 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c chain->final_cbdata = chain; chain 111 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_RELEASE(chain); chain 117 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c buf, &chain->status, &cnt, PMIX_STATUS); chain 120 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_RELEASE(chain); chain 127 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c buf, &chain->source, &cnt, PMIX_PROC); chain 130 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_RELEASE(chain); chain 140 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_RELEASE(chain); chain 145 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c chain->nallocated = ninfo + 2; chain 146 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_INFO_CREATE(chain->info, chain->nallocated); chain 147 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c if (NULL == chain->info) { chain 149 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_RELEASE(chain); chain 154 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c chain->ninfo = ninfo; chain 157 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c buf, chain->info, &cnt, PMIX_INFO); chain 160 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_RELEASE(chain); chain 165 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_prep_event_chain(chain, chain->info, ninfo, false); chain 169 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_globals.myid.nspace, pmix_globals.myid.rank, PMIx_Error_string(chain->status), chain 170 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c chain->source.nspace, chain->source.rank); chain 172 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_invoke_local_event_hdlr(chain); chain 179 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c chain = PMIX_NEW(pmix_event_chain_t); chain 180 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c chain->status = rc; chain 181 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_invoke_local_event_hdlr(chain);