Searched refs:evd_ptr (Results 1 - 25 of 31) sorted by relevance

12

/illumos-gate/usr/src/lib/udapl/udapl_tavor/common/
H A Ddapl_evd_enable.c68 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 Ddapl_evd_set_unwaitable.c65 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 Ddapl_evd_free.c68 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 Ddapl_evd_wait.c76 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 Ddapl_evd_dto_callb.c68 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 Ddapl_evd_clear_unwaitable.c65 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 Ddapl_evd_dequeue.c72 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 Ddapl_evd_modify_cno.c70 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 Ddapl_evd_query.c68 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 Ddapl_evd_disable.c66 DAPL_EVD *evd_ptr; local
69 evd_ptr = (DAPL_EVD *)evd_handle;
77 evd_ptr->evd_enabled = DAT_FALSE;
H A Ddapl_cno_wait.c74 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 Ddapl_evd_util.c60 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 Ddapl_evd_resize.c76 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 Ddapl_evd_post_se.c71 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 Ddapl_evd_create.c88 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 Ddapl_evd_connection_callb.c75 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 Ddapl_ia_open.c181 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 Ddapl_cr_callback.c59 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 Ddapl_psp_create.c83 DAPL_EVD *evd_ptr; local
114 evd_ptr = (DAPL_EVD *)evd_handle;
115 if (!(evd_ptr->evd_flags & DAT_EVD_CR_FLAG)) {
H A Ddapl_psp_create_any.c86 DAPL_EVD *evd_ptr; local
121 evd_ptr = (DAPL_EVD *)evd_handle;
122 if (!(evd_ptr->evd_flags & DAT_EVD_CR_FLAG)) {
H A Ddapl_ia_util.c145 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 Ddapl_ep_connect.c287 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 Ddapl_evd_util.h67 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 Ddapl_cno_util.h62 IN DAPL_EVD *evd_ptr);
/illumos-gate/usr/src/lib/udapl/udapl_tavor/tavor/
H A Ddapl_tavor_ibtf_util.c55 * 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...]

Completed in 127 milliseconds

12