Home
last modified time | relevance | path

Searched refs:wait_obj (Results 1 – 25 of 115) sorted by relevance

12345

/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/util/src/
H A Dutil_wait.c92 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 Dutil_cntr.c50 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 Deq.c92 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 Dwait.c84 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 Dcq.c96 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 Dgnix_wait.c247 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 Dgnix_cntr.c76 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 Dgnix_eq.c79 .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 Dgnix_cq.c162 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 Dgnix_wait.h49 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 Dusdf_wait.c180 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 Dusdf_eq.c122 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 Dusdf_cq.c477 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 Dsock_eq.c297 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 Dsock_cntr.c51 .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 Dsock_cq.c486 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 Dsmr_cq.c44 switch (attr->wait_obj) { in smr_cq_open()
46 attr->wait_obj = FI_WAIT_YIELD; in smr_cq_open()
H A Dsmr_cntr.c41 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 Dverbs_cq.c459 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 Dcq_test.c49 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 Dtcpx_cq.c66 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 Dwpoll.c138 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 Dcq.c139 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 Dfi_eq.h69 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 Dpsmx2_cntr.c376 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()

12345