/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/util/src/ |
H A D | util_wait.c | 92 switch (attr->wait_obj) { in ofi_check_wait_attr() 147 switch (attr->wait_obj) { in ofi_wait_init() 149 wait->wait_obj = FI_WAIT_FD; in ofi_wait_init() 155 wait->wait_obj = attr->wait_obj; in ofi_wait_init() 514 switch (attr->wait_obj) { in util_verify_wait_fd_attr() 663 switch (attr->wait_obj) { in util_verify_wait_yield_attr() 687 attr->wait_obj = FI_WAIT_YIELD; in ofi_wait_yield_open() 798 &fid_entry->wait_obj); in ofi_wait_get_fid_fds() 799 if ((fid_entry->wait_obj != FI_WAIT_FD) && in ofi_wait_get_fid_fds() 803 fid_entry->wait_obj, fi_strerror(ret)); in ofi_wait_get_fid_fds() [all …]
|
H A D | util_cntr.c | 50 switch (attr->wait_obj) { in ofi_check_cntr_attr() 287 switch (attr->wait_obj) { in ofi_cntr_init() 298 wait_attr.wait_obj = attr->wait_obj; in ofi_cntr_init()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/gni/test/ |
H A D | eq.c | 92 void eq_create(enum fi_wait_obj wait_obj, size_t size) in eq_create() argument 97 eq_attr.wait_obj = wait_obj; in eq_create() 257 cr_expect_eq(wait_priv->type, eq_priv->attr.wait_obj); 258 cr_expect_eq(wait_priv->type, eq_attr.wait_obj); 267 cr_expect_eq(wait_priv->type, eq_priv->attr.wait_obj); 268 cr_expect_eq(wait_priv->type, eq_attr.wait_obj); 277 cr_expect_eq(wait_priv->type, eq_priv->attr.wait_obj); 278 cr_expect_eq(wait_priv->type, eq_attr.wait_obj); 340 wait_attr.wait_obj = FI_WAIT_FD; 348 eq_attr.wait_obj = FI_WAIT_SET;
|
H A D | wait.c | 84 void setup_wait_type(enum fi_wait_obj wait_obj) in setup_wait_type() argument 89 wait_attr.wait_obj = wait_obj; in setup_wait_type() 115 cr_expect_eq(wait_priv->type, wait_attr.wait_obj); 124 cr_expect_eq(wait_priv->type, wait_attr.wait_obj); 133 cr_expect_eq(wait_priv->type, wait_attr.wait_obj); 208 ret = memcmp(entry->wait_obj, &temp_wait, sizeof(temp_wait)); 253 ret = memcmp(entry->wait_obj, &temp_wait, sizeof(temp_wait)); 300 wait_attr.wait_obj = FI_WAIT_SET;
|
H A D | cq.c | 96 cq_attr.wait_obj = FI_WAIT_NONE; in _setup() 121 void cq_create(enum fi_cq_format format, enum fi_wait_obj wait_obj, in cq_create() argument 128 cq_attr.wait_obj = wait_obj; in cq_create() 834 cr_expect_eq(wait_priv->type, cq_priv->attr.wait_obj); 835 cr_expect_eq(wait_priv->type, cq_attr.wait_obj); 843 cr_expect_eq(wait_priv->type, cq_priv->attr.wait_obj); 844 cr_expect_eq(wait_priv->type, cq_attr.wait_obj); 852 cr_expect_eq(wait_priv->type, cq_priv->attr.wait_obj); 853 cr_expect_eq(wait_priv->type, cq_attr.wait_obj); 933 wait_attr.wait_obj = FI_WAIT_FD; [all …]
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/gni/src/ |
H A D | gnix_wait.c | 247 return (entry->wait_obj == (struct fid *) fid); in gnix_match_fid() 253 int _gnix_wait_set_add(struct fid_wait *wait, struct fid *wait_obj) in _gnix_wait_set_add() argument 269 wait_entry->wait_obj = wait_obj; in _gnix_wait_set_add() 276 int _gnix_wait_set_remove(struct fid_wait *wait, struct fid *wait_obj) in _gnix_wait_set_remove() argument 287 wait_obj); in _gnix_wait_set_remove() 372 switch (attr->wait_obj) { in gnix_verify_wait_attr() 374 attr->wait_obj = FI_WAIT_UNSPEC; in gnix_verify_wait_attr() 378 attr->wait_obj); in gnix_verify_wait_attr() 552 ret = gnix_init_wait_obj(wait_priv, attr->wait_obj); in gnix_wait_open()
|
H A D | gnix_cntr.c | 76 switch (attr->wait_obj) { in __verify_cntr_attr() 85 attr->wait_obj); in __verify_cntr_attr() 99 .wait_obj = cntr->attr.wait_obj, in gnix_cntr_set_wait() 103 switch (cntr->attr.wait_obj) { in gnix_cntr_set_wait() 228 if (cntr_priv->attr.wait_obj == FI_WAIT_SET || in gnix_cntr_wait() 229 cntr_priv->attr.wait_obj == FI_WAIT_NONE) in gnix_cntr_wait() 274 switch (cntr->attr.wait_obj) { in __cntr_destruct() 288 cntr->attr.wait_obj); in __cntr_destruct()
|
H A D | gnix_eq.c | 79 .wait_obj = eq->attr.wait_obj, in gnix_eq_set_wait() 83 switch (eq->attr.wait_obj) { in gnix_eq_set_wait() 114 switch (attr->wait_obj) { in gnix_verify_eq_attr() 130 attr->wait_obj); in gnix_verify_eq_attr() 247 switch (eq->attr.wait_obj) { in __eq_destruct() 261 eq->attr.wait_obj); in __eq_destruct() 484 (blocking && eq_priv->attr.wait_obj == FI_WAIT_SET)) { in __gnix_eq_sread()
|
H A D | gnix_cq.c | 162 switch (attr->wait_obj) { in verify_cq_attr() 182 attr->wait_obj); in verify_cq_attr() 196 .wait_obj = cq->attr.wait_obj, in gnix_cq_set_wait() 200 switch (cq->attr.wait_obj) { in gnix_cq_set_wait() 382 switch (cq->attr.wait_obj) { in __cq_destruct() 396 cq->attr.wait_obj); in __cq_destruct() 484 (blocking && cq_priv->attr.wait_obj == FI_WAIT_SET)) in __gnix_cq_sreadfrom()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/gni/include/ |
H A D | gnix_wait.h | 49 struct fid *wait_obj; member 84 int _gnix_wait_set_add(struct fid_wait *wait, struct fid *wait_obj); 85 int _gnix_wait_set_remove(struct fid_wait *wait, struct fid *wait_obj);
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/usnic/src/ |
H A D | usdf_wait.c | 180 switch (attr->wait_obj) { in usdf_wait_open() 216 wait_priv->wait_obj = attr->wait_obj; in usdf_wait_open() 257 switch (wait_priv->wait_obj) { in usdf_wait_close() 312 switch (wait_priv->wait_obj) { in usdf_wait_get_wait()
|
H A D | usdf_eq.c | 122 if (eq->eq_attr.wait_obj == FI_WAIT_FD) { in usdf_eq_read_event() 360 if (ret >= 0 && eq->eq_attr.wait_obj == FI_WAIT_FD) { in usdf_eq_write_internal() 402 switch (eq->eq_attr.wait_obj) { in usdf_eq_get_wait() 515 switch (eq->eq_attr.wait_obj) { in usdf_eq_close() 592 switch (attr->wait_obj) { in usdf_eq_open() 597 attr->wait_obj = FI_WAIT_FD; in usdf_eq_open() 610 if (attr->wait_obj == FI_WAIT_SET) { in usdf_eq_open()
|
H A D | usdf_cq.c | 477 if (cq->cq_attr.wait_obj == FI_WAIT_SET || in usdf_cq_post_soft() 478 cq->cq_attr.wait_obj == FI_WAIT_FD) in usdf_cq_post_soft() 542 if (cq->cq_attr.wait_obj == FI_WAIT_NONE) in usdf_cq_sread() 780 if (cq->cq_attr.wait_obj == FI_WAIT_SET) { in usdf_cq_close() 823 switch (cq->cq_attr.wait_obj) { in usdf_cq_get_wait() 1033 switch (attr->wait_obj) { in usdf_cq_process_attr() 1113 switch (cq->cq_attr.wait_obj) { in usdf_cq_trywait() 1233 if ((cq->cq_attr.wait_obj == FI_WAIT_FD) || in usdf_cq_create_cq() 1234 (cq->cq_attr.wait_obj == FI_WAIT_SET)) { in usdf_cq_create_cq() 1251 if (cq->cq_attr.wait_obj == FI_WAIT_SET) { in usdf_cq_create_cq() [all …]
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/sockets/src/ |
H A D | sock_eq.c | 297 if (sock_eq->signal && sock_eq->attr.wait_obj == FI_WAIT_MUTEX_COND) in sock_eq_fi_close() 312 switch (eq->attr.wait_obj) { in sock_eq_control() 347 switch (attr->wait_obj) { in _sock_eq_verify_attr() 354 attr->wait_obj = FI_WAIT_FD; in _sock_eq_verify_attr() 366 .wait_obj = FI_WAIT_FD, 410 switch (sock_eq->attr.wait_obj) { in sock_eq_open() 420 wait_attr.wait_obj = FI_WAIT_MUTEX_COND; in sock_eq_open()
|
H A D | sock_cntr.c | 51 .wait_obj = FI_WAIT_MUTEX_COND, 383 switch (cntr->attr.wait_obj) { in sock_cntr_control() 426 if (cntr->signal && cntr->attr.wait_obj == FI_WAIT_FD) in sock_cntr_close() 488 switch (attr->wait_obj) { in sock_cntr_verify_attr() 530 switch (_cntr->attr.wait_obj) { in sock_cntr_open() 540 wait_attr.wait_obj = FI_WAIT_FD; in sock_cntr_open()
|
H A D | sock_cq.c | 486 if (cq->signal && cq->attr.wait_obj == FI_WAIT_MUTEX_COND) in sock_cq_close() 535 switch (cq->attr.wait_obj) { in sock_cq_control() 587 switch (attr->wait_obj) { in sock_cq_verify_attr() 594 attr->wait_obj = FI_WAIT_FD; in sock_cq_verify_attr() 607 .wait_obj = FI_WAIT_FD, 673 switch (sock_cq->attr.wait_obj) { in sock_cq_open() 681 wait_attr.wait_obj = FI_WAIT_MUTEX_COND; in sock_cq_open()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/shm/src/ |
H A D | smr_cq.c | 44 switch (attr->wait_obj) { in smr_cq_open() 46 attr->wait_obj = FI_WAIT_YIELD; in smr_cq_open()
|
H A D | smr_cntr.c | 41 switch (attr->wait_obj) { in smr_cntr_open() 43 attr->wait_obj = FI_WAIT_YIELD; in smr_cntr_open()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/verbs/src/ |
H A D | verbs_cq.c | 459 if (cq->wait_obj == FI_WAIT_FD) { in vrb_cq_control() 475 *(enum fi_wait_obj *) arg = cq->wait_obj; in vrb_cq_control() 577 tmp_attr.wait_obj = FI_WAIT_NONE; in vrb_cq_open() 583 switch (attr->wait_obj) { in vrb_cq_open() 585 cq->wait_obj = FI_WAIT_FD; in vrb_cq_open() 590 cq->wait_obj = attr->wait_obj; in vrb_cq_open() 597 if (cq->wait_obj != FI_WAIT_NONE) { in vrb_cq_open()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/fabtests/unit/ |
H A D | cq_test.c | 49 enum fi_cq_format format, enum fi_wait_obj wait_obj) in create_cq() argument 57 cq_attr.wait_obj = wait_obj; in create_cq()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/tcp/src/ |
H A D | tcpx_cq.c | 66 nfds = (wait_fd->util_wait.wait_obj == FI_WAIT_FD) ? in tcpx_cq_progress() 310 if (attr->wait_obj == FI_WAIT_NONE || in tcpx_cq_open() 311 attr->wait_obj == FI_WAIT_UNSPEC) { in tcpx_cq_open() 313 cq_attr.wait_obj = FI_WAIT_POLLFD; in tcpx_cq_open()
|
/dports/lang/yorick/yorick-y_2_2_04/play/win/ |
H A D | wpoll.c | 138 w_add_input(HANDLE wait_obj, void (*on_input)(void *), void *context) in w_add_input() argument 142 for (i=0 ; i<w_nputs ; i++) if (w_inputs[i]==wait_obj) break; in w_add_input() 154 w_inputs[i] = wait_obj; in w_add_input()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/fabtests/ubertest/ |
H A D | cq.c | 139 attr.wait_obj = test_info.cntr_wait_obj; in ft_open_cntrs() 148 attr.wait_obj = test_info.cntr_wait_obj; in ft_open_cntrs() 166 attr.wait_obj = test_info.cq_wait_obj; in ft_open_cqs() 179 attr.wait_obj = test_info.cq_wait_obj; in ft_open_cqs()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/include/rdma/ |
H A D | fi_eq.h | 69 enum fi_wait_obj wait_obj; member 127 enum fi_wait_obj wait_obj; member 253 enum fi_wait_obj wait_obj; member 292 enum fi_wait_obj wait_obj; member
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/psm2/src/ |
H A D | psmx2_cntr.c | 376 switch (attr->wait_obj) { in psmx2_cntr_open() 392 wait_attr.wait_obj = attr->wait_obj; in psmx2_cntr_open() 404 attr->wait_obj, FI_WAIT_NONE, FI_WAIT_MUTEX_COND); in psmx2_cntr_open()
|