/illumos-gate/usr/src/lib/udapl/udapl_tavor/common/ |
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_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_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_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_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_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_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_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_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_util.c | 60 IN DAPL_EVD *evd_ptr, 67 IN DAPL_EVD *evd_ptr, 101 DAPL_EVD *evd_ptr; local 109 evd_ptr = dapls_evd_alloc(ia_ptr, 113 if (!evd_ptr) { 123 evd_ptr->evd_producer_locking_needed = 127 evd_ptr->evd_state = DAPL_EVD_STATE_OPEN; 134 evd_ptr, cno_ptr, &cq_len); 142 (unsigned int *) evd_ptr->ib_cq_handle, 144 evd_ptr); 200 DAPL_EVD *evd_ptr; local 265 dapli_evd_event_alloc( IN DAPL_EVD *evd_ptr, IN DAPL_CNO *cno_ptr, IN DAT_COUNT qlen) argument 341 dapls_evd_dealloc( IN DAPL_EVD *evd_ptr) argument 492 dapli_evd_get_event( DAPL_EVD *evd_ptr) argument 530 dapli_evd_post_event( IN DAPL_EVD *evd_ptr, IN const DAT_EVENT *event_ptr) argument 618 dapli_evd_post_event_nosignal( IN DAPL_EVD *evd_ptr, IN const DAT_EVENT *event_ptr) argument 654 dapli_evd_format_overflow_event( IN DAPL_EVD *evd_ptr, OUT DAT_EVENT *event_ptr) argument 710 dapli_evd_get_and_init_event( IN DAPL_EVD *evd_ptr, IN DAT_EVENT_NUMBER event_number) argument 729 dapls_evd_post_cr_arrival_event( IN DAPL_EVD *evd_ptr, IN DAT_EVENT_NUMBER event_number, IN DAT_SP_HANDLE sp_handle, DAT_IA_ADDRESS_PTR ia_address_ptr, DAT_CONN_QUAL conn_qual, DAT_CR_HANDLE cr_handle) argument 761 dapls_evd_post_connection_event( IN DAPL_EVD *evd_ptr, IN DAT_EVENT_NUMBER event_number, IN DAT_EP_HANDLE ep_handle, IN DAT_COUNT private_data_size, IN DAT_PVOID private_data) argument 791 dapls_evd_post_async_error_event( IN DAPL_EVD *evd_ptr, IN DAT_EVENT_NUMBER event_number, IN DAT_IA_HANDLE ia_handle) argument 816 dapls_evd_post_software_event( IN DAPL_EVD *evd_ptr, IN DAT_EVENT_NUMBER event_number, IN DAT_PVOID pointer) argument 842 DAPL_EVD *evd_ptr; local 924 dapli_evd_cqe_to_event( IN DAPL_EVD *evd_ptr, IN ib_work_completion_t *cqe_ptr, IN DAT_BOOLEAN process_premature_events, OUT DAT_EVENT *event_ptr) argument 1216 dapls_evd_copy_cq( DAPL_EVD *evd_ptr, int *nevents) argument 1306 dapls_evd_copy_events( DAPL_EVD *evd_ptr, DAT_TIMEOUT timeout) argument 1594 dapls_evd_cq_poll_to_event( IN DAPL_EVD *evd_ptr, OUT DAT_EVENT *event) argument [all...] |
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_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_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_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_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_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_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_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_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...] |
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,
|
/illumos-gate/usr/src/lib/udapl/udapl_tavor/include/ |
H A D | dapl_evd_util.h | 67 IN DAPL_EVD *evd_ptr); 82 IN DAPL_EVD *evd_ptr, 91 IN DAPL_EVD *evd_ptr, 99 IN DAPL_EVD *evd_ptr, 105 IN DAPL_EVD *evd_ptr, 151 IN DAPL_EVD *evd_ptr, 155 DAPL_EVD *evd_ptr, 162 IN DAPL_EVD *evd_ptr,
|
H A D | dapl_cno_util.h | 62 IN DAPL_EVD *evd_ptr);
|
/illumos-gate/usr/src/lib/udapl/udapl_tavor/tavor/ |
H A D | dapl_tavor_ibtf_util.c | 55 * evd_ptr pointer to EVD struct 70 IN DAPL_EVD *evd_ptr, 88 "cq_alloc: evd_ptr 0x%p, cq_handle == NULL\n", 89 evd_ptr); 97 create_msg.evd_flags = evd_ptr->evd_flags; 98 create_msg.evd_cookie = (uintptr_t)evd_ptr; 103 if (evd_ptr->evd_flags & (DAT_EVD_DTO_FLAG | DAT_EVD_RMR_BIND_FLAG)) { 109 " cno_hkey 0x%llx, cq_size %d\n", evd_ptr, 132 "cq_alloc: created, evd 0x%p, hkey 0x%016llx\n\n", evd_ptr, 137 if (evd_ptr 68 dapls_ib_cq_alloc( IN DAPL_IA *ia_ptr, IN DAPL_EVD *evd_ptr, IN DAPL_CNO *cno_ptr, IN DAT_COUNT *cqlen) argument 236 dapls_ib_cq_resize( IN DAPL_EVD *evd_ptr, IN DAT_COUNT cqlen) argument 279 dapli_ib_cq_resize_internal( IN DAPL_EVD *evd_ptr, IN DAT_COUNT cqlen) argument 418 dapls_ib_cq_free( IN DAPL_IA *ia_ptr, IN DAPL_EVD *evd_ptr) argument 476 dapls_set_cq_notify( IN DAPL_IA *ia_ptr, IN DAPL_EVD *evd_ptr) argument 495 dapls_set_cqN_notify( IN DAPL_IA *ia_ptr, IN DAPL_EVD *evd_ptr, IN uint32_t num_events) argument 1265 DAPL_EVD *evd_ptr; local 1687 dapls_ib_event_poll( IN DAPL_EVD *evd_ptr, IN uint64_t timeout, IN uint_t threshold, OUT dapl_ib_event_t *evp_ptr, OUT int *num_events) argument 1742 dapls_ib_event_wakeup( IN DAPL_EVD *evd_ptr) argument 1776 dapls_ib_cq_peek( IN DAPL_EVD *evd_ptr, OUT int *num_cqe) argument 1798 dapls_ib_modify_cno( IN DAPL_EVD *evd_ptr, IN DAPL_CNO *cno_ptr) argument [all...] |