/illumos-gate/usr/src/lib/udapl/udapl_tavor/common/ |
H A D | dapl_evd_clear_unwaitable.c | 65 DAPL_EVD *evd_ptr; local 68 evd_ptr = (DAPL_EVD *)evd_handle; 75 dapl_os_lock(&evd_ptr->header.lock); 76 evd_ptr->evd_waitable = DAT_TRUE; 77 dapl_os_unlock(&evd_ptr->header.lock);
|
H A D | dapl_evd_disable.c | 66 DAPL_EVD *evd_ptr; local 69 evd_ptr = (DAPL_EVD *)evd_handle; 77 evd_ptr->evd_enabled = DAT_FALSE;
|
H A D | dapl_evd_enable.c | 68 DAPL_EVD *evd_ptr; local 71 evd_ptr = (DAPL_EVD *)evd_handle; 79 evd_ptr->evd_enabled = DAT_TRUE; 82 if (evd_ptr->cno_ptr != NULL && 83 evd_ptr->ib_cq_handle != IB_INVALID_HANDLE) { 84 dat_status = DAPL_NOTIFY(evd_ptr)( 85 evd_ptr->ib_cq_handle, IB_NOTIFY_ON_NEXT_COMP, 0);
|
H A D | dapl_evd_free.c | 68 DAPL_EVD *evd_ptr; local 74 evd_ptr = (DAPL_EVD *)evd_handle; 81 if (evd_ptr->evd_ref_count != 0) { 87 dapl_ia_unlink_evd(evd_ptr->header.owner_ia, evd_ptr); 89 dat_status = dapls_evd_dealloc(evd_ptr); 91 dapl_ia_link_evd(evd_ptr->header.owner_ia, evd_ptr);
|
H A D | dapl_evd_set_unwaitable.c | 65 DAPL_EVD *evd_ptr; local 68 evd_ptr = (DAPL_EVD *)evd_handle; 75 dapl_os_lock(&evd_ptr->header.lock); 76 evd_ptr->evd_waitable = DAT_FALSE; 77 dapl_os_unlock(&evd_ptr->header.lock); 85 if (evd_ptr->evd_state == DAPL_EVD_STATE_WAITED) { 86 (void) dapl_os_wait_object_wakeup(&evd_ptr->wait_object);
|
H A D | dapl_evd_post_se.c | 71 DAPL_EVD *evd_ptr; local 74 evd_ptr = (DAPL_EVD *)evd_handle; 82 if (!(evd_ptr->evd_flags & DAT_EVD_SOFTWARE_FLAG)) { 98 evd_ptr,
|
H A D | dapl_cno_util.c | 138 * evd_ptr EVD triggering 149 IN DAPL_EVD *evd_ptr) /* ARGSUSED */ 147 dapl_cno_trigger( IN DAPL_CNO *cno_ptr, IN DAPL_EVD *evd_ptr) argument
|
H A D | dapl_evd_dequeue.c | 72 DAPL_EVD *evd_ptr; local 81 evd_ptr = (DAPL_EVD *)evd_handle; 99 dapl_os_lock(&evd_ptr->header.lock); 105 if (evd_ptr->evd_state != DAPL_EVD_STATE_OPEN || 106 evd_ptr->catastrophic_overflow) { 107 dapl_os_unlock(&evd_ptr->header.lock); 117 if (evd_ptr->pending_event_queue.head != 118 evd_ptr->pending_event_queue.tail) { 120 dapls_rbuf_remove(&evd_ptr->pending_event_queue); 123 dat_status = dapls_rbuf_add(&evd_ptr [all...] |
H A D | dapl_evd_modify_cno.c | 70 DAPL_EVD *evd_ptr; local 75 evd_ptr = (DAPL_EVD *)evd_handle; 93 if (cno_ptr == evd_ptr->cno_ptr) { 98 if (dapls_ib_modify_cno(evd_ptr, cno_ptr) != DAT_SUCCESS) { 103 dapl_os_lock(&evd_ptr->header.lock); 104 old_cno_ptr = evd_ptr->cno_ptr; 105 evd_ptr->cno_ptr = cno_ptr; 106 dapl_os_unlock(&evd_ptr->header.lock); 115 &evd_ptr->cno_list_entry); 124 &evd_ptr [all...] |
H A D | dapl_evd_query.c | 68 DAPL_EVD *evd_ptr; local 95 evd_ptr = (DAPL_EVD *) evd_handle; 108 (evd_ptr->evd_enabled ? DAT_EVD_STATE_ENABLED : 111 (evd_ptr->evd_waitable ? DAT_EVD_STATE_WAITABLE : 113 evd_param->ia_handle = evd_ptr->header.owner_ia; 114 evd_param->evd_qlen = evd_ptr->qlen; 115 evd_param->cno_handle = (DAT_CNO_HANDLE) evd_ptr->cno_ptr; 116 evd_param->evd_flags = evd_ptr->evd_flags;
|
H A D | dapl_cno_wait.c | 74 DAPL_EVD *evd_ptr, *head_evd_ptr; local 99 evd_ptr = (DAPL_EVD *) 107 if (dapls_rbuf_count(&evd_ptr->pending_event_queue) > 0) { 112 dapls_ib_cq_peek(evd_ptr, &nevents); 117 evd_ptr = (DAPL_EVD *) 119 &evd_ptr->cno_list_entry); 120 if (evd_ptr == NULL) { 132 if (evd_ptr != NULL) { 133 *evd_handle = evd_ptr; 141 dat_status = dapls_ib_cno_wait(cno_ptr, timeout, &evd_ptr); [all...] |
H A D | dapl_evd_connection_callb.c | 75 DAPL_EVD *evd_ptr; local 98 evd_ptr = (DAPL_EVD *)ep_ptr->param.connect_evd_handle; 127 evd_ptr, 169 /* If the EP has been freed, the evd_ptr will be NULL */ 170 if (evd_ptr != NULL) { 172 evd_ptr, event_type, (DAT_HANDLE) ep_ptr, 0, 0); 189 evd_ptr, 201 evd_ptr, 215 evd_ptr, 227 evd_ptr, [all...] |
H A D | dapl_evd_dto_callb.c | 68 DAPL_EVD *evd_ptr; local 78 evd_ptr = (DAPL_EVD *) user_context; 81 evd_ptr->header.owner_ia->hca_ptr->ib_hca_handle); 82 dapl_os_assert(evd_ptr->ib_cq_handle == cq_handle); 83 dapl_os_assert(evd_ptr->header.magic == DAPL_MAGIC_EVD); 86 state = *(volatile DAPL_EVD_STATE *) &evd_ptr->evd_state; 90 (void *)evd_ptr->ib_cq_handle, 116 (void) dapl_os_wait_object_wakeup(&evd_ptr->wait_object); 118 DAPL_CNO *cno = evd_ptr->cno_ptr; 119 if (evd_ptr [all...] |
H A D | dapl_psp_create_any.c | 86 DAPL_EVD *evd_ptr; local 121 evd_ptr = (DAPL_EVD *)evd_handle; 122 if (!(evd_ptr->evd_flags & DAT_EVD_CR_FLAG)) {
|
H A D | dapl_ep_connect.c | 287 DAPL_EVD *evd_ptr; local 292 evd_ptr = (DAPL_EVD *)ep_ptr->param.connect_evd_handle; 293 if (evd_ptr != NULL) { 294 (void) dapls_evd_post_connection_event(evd_ptr, 303 evd_ptr = (DAPL_EVD *)ep_ptr->param.connect_evd_handle; 304 if (evd_ptr != NULL) { 305 (void) dapls_evd_post_connection_event(evd_ptr,
|
H A D | dapl_evd_create.c | 88 DAPL_EVD *evd_ptr; local 108 evd_ptr = NULL; 165 &evd_ptr); 170 evd_ptr->evd_state = DAPL_EVD_STATE_OPEN; 172 *evd_handle = (DAT_EVD_HANDLE) evd_ptr; 176 if (evd_ptr) { 177 (void) dapl_evd_free(evd_ptr);
|
H A D | dapl_evd_resize.c | 76 DAPL_EVD *evd_ptr; local 87 evd_ptr = (DAPL_EVD *)evd_handle; 94 if (req_evd_qlen < evd_ptr->qlen) { 98 if (req_evd_qlen == evd_ptr->qlen) { 102 max_evd_qlen = evd_ptr->header.owner_ia->hca_ptr->ia_attr.max_evd_qlen; 134 if (0 != (evd_ptr->evd_flags & ~ (DAT_EVD_SOFTWARE_FLAG | 136 dat_status = dapls_ib_cq_resize(evd_ptr, evd_qlen); 150 dapls_rbuf_remove(&evd_ptr->pending_event_queue)) { 156 dat_status = dapls_rbuf_add(&evd_ptr->free_event_queue, event); 160 dapls_rbuf_destroy(&evd_ptr [all...] |
H A D | dapl_evd_wait.c | 76 DAPL_EVD *evd_ptr; local 90 evd_ptr = (DAPL_EVD *)evd_handle; 93 if (DAPL_BAD_HANDLE(evd_ptr, DAPL_MAGIC_EVD)) { 112 evd_ptr->completion_type != DAPL_EVD_STATE_THRESHOLD)) { 116 if (evd_ptr->catastrophic_overflow) { 123 evd_ptr, 124 (void *)evd_ptr->ib_cq_handle); 132 dapl_os_lock(&evd_ptr->header.lock); 133 waitable = evd_ptr->evd_waitable; 134 evd_state = evd_ptr [all...] |
H A D | dapl_psp_create.c | 83 DAPL_EVD *evd_ptr; local 114 evd_ptr = (DAPL_EVD *)evd_handle; 115 if (!(evd_ptr->evd_flags & DAT_EVD_CR_FLAG)) {
|
H A D | dapl_rsp_create.c | 84 DAPL_EVD *evd_ptr; local 124 evd_ptr = (DAPL_EVD *)evd_handle; 125 if (!(evd_ptr->evd_flags & DAT_EVD_CR_FLAG)) {
|
H A D | dapl_cr_callback.c | 59 IN DAPL_EVD *evd_ptr); 91 DAPL_EVD *evd_ptr; local 127 evd_ptr = sp_ptr->evd_handle; 131 evd_ptr = (DAPL_EVD *) ep_ptr->param.connect_evd_handle; 134 ep_ptr, evd_ptr); 170 sp_ptr, prd_ptr, evd_ptr); 197 evd_ptr, 241 /* If the EP has been freed, the evd_ptr will be NULL */ 242 if (evd_ptr != NULL) { 244 evd_ptr, event_typ 333 dapli_connection_request( IN ib_cm_handle_t ib_cm_handle, IN DAPL_SP *sp_ptr, IN DAPL_PRIVATE *prd_ptr, IN DAPL_EVD *evd_ptr) argument [all...] |
H A D | dapl_ia_open.c | 181 DAPL_EVD *evd_ptr; local 334 evd_ptr = (DAPL_EVD *) *async_evd_handle_ptr; 335 if (evd_ptr) { 336 if (DAPL_BAD_HANDLE(evd_ptr, DAPL_MAGIC_EVD) || 337 ! (evd_ptr->evd_flags & DAT_EVD_ASYNC_FLAG)) { 351 if (evd_ptr->header.owner_ia->hca_ptr->ib_hca_handle != 359 ia_ptr->async_error_evd = evd_ptr; 374 &evd_ptr); 379 dapl_os_atomic_inc(&evd_ptr->evd_ref_count); 395 dapl_os_atomic_dec(&evd_ptr [all...] |
H A D | dapl_osd.c | 371 DAPL_EVD *evd_ptr; local 491 evd_ptr = (DAPL_EVD *) dapl_llist_peek_head( 493 dapl_ia_unlink_evd(evd_ptr->header.owner_ia, 494 evd_ptr); 499 evd_ptr->ib_cq_handle = IB_INVALID_HANDLE; 500 (void) dapls_evd_dealloc(evd_ptr);
|
H A D | dapl_ep_util.c | 487 DAPL_EVD *evd_ptr; local 664 evd_ptr = (DAPL_EVD *)recv_evd_handle; 665 if (evd_ptr->completion_type == DAPL_EVD_STATE_INIT) { 669 evd_ptr->completion_type = DAPL_EVD_STATE_THRESHOLD; 676 evd_ptr->completion_type = DAPL_EVD_STATE_THRESHOLD; 679 evd_ptr = (DAPL_EVD *)request_evd_handle; 680 if (evd_ptr->completion_type == DAPL_EVD_STATE_INIT) { 684 evd_ptr->completion_type = DAPL_EVD_STATE_THRESHOLD; 691 evd_ptr->completion_type = DAPL_EVD_STATE_THRESHOLD;
|
H A D | dapl_ia_util.c | 145 DAPL_EVD *evd_ptr, *next_evd_ptr; local 265 evd_ptr = (dapl_llist_is_empty(&ia_ptr->evd_list_head) 267 while (evd_ptr != NULL) { 269 &evd_ptr->header.ia_list_entry); 270 if (evd_ptr == ia_ptr->async_error_evd) { 275 (void) dapl_evd_disable(evd_ptr); 276 (void) dapl_evd_modify_cno(evd_ptr, 280 dat_status = dapl_evd_free(evd_ptr); 285 evd_ptr, 289 evd_ptr 365 DAPL_EVD *evd_ptr; local 765 dapl_ia_link_evd( IN DAPL_IA *ia_ptr, IN DAPL_EVD *evd_ptr) argument 793 dapl_ia_unlink_evd( IN DAPL_IA *ia_ptr, IN DAPL_EVD *evd_ptr) argument [all...] |