Searched defs:evd_ptr (Results 1 - 25 of 28) sorted by relevance

12

/osnet-11/usr/src/lib/udapl/udapl_tavor/common/
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_disable.c66 DAPL_EVD *evd_ptr; local
69 evd_ptr = (DAPL_EVD *)evd_handle;
77 evd_ptr->evd_enabled = DAT_FALSE;
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_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_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_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_cno_util.c138 * 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 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_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_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_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_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_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,
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_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_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_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_rsp_create.c84 DAPL_EVD *evd_ptr; local
124 evd_ptr = (DAPL_EVD *)evd_handle;
125 if (!(evd_ptr->evd_flags & DAT_EVD_CR_FLAG)) {
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_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_osd.c371 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 Ddapl_ep_util.c487 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 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...]

Completed in 62 milliseconds

12