Lines Matching defs:ep_ptr
840 dapls_evd_post_premature_events(IN DAPL_EP *ep_ptr)
850 dapls_ib_poll_premature_events(ep_ptr, &cqe, &nevents);
852 evd_ptr = ep_ptr->param.recv_evd_handle;
853 qpn = ep_ptr->qpn;
861 dapl_os_assert(!ep_ptr->srq_attached ||
862 (prm_idx <= ((DAPL_SRQ *)ep_ptr->param.srq_handle)->
870 if (ep_ptr->srq_attached &&
899 if (ep_ptr->srq_attached) {
900 dapls_ib_free_premature_events(ep_ptr, prm_idx);
930 DAPL_EP *ep_ptr;
952 ep_ptr = cookie->queue.ep;
959 ep_ptr = dapls_ib_srq_lookup_ep(srq_ptr, cqe_ptr);
962 dapl_os_assert((NULL != ep_ptr));
963 dapl_os_assert((ep_ptr->header.magic == DAPL_MAGIC_EP) ||
964 (ep_ptr->header.magic == DAPL_MAGIC_EP_EXIT));
984 ep_state = ep_ptr->param.ep_state;
985 qp = ep_ptr->qp_handle;
1008 dapl_os_atomic_dec(&ep_ptr->recv_count);
1009 buffer = &ep_ptr->recv_buffer;
1012 dapl_os_atomic_dec(&ep_ptr->req_count);
1013 buffer = &ep_ptr->req_buffer;
1018 ep_ptr;
1147 dapl_os_atomic_dec(&ep_ptr->req_count);
1167 dapls_cookie_dealloc(&ep_ptr->req_buffer, cookie);
1180 if ((dto_error) && (ep_ptr->param.ep_state == DAT_EP_STATE_CONNECTED)) {
1181 ep_ptr->param.ep_state = DAT_EP_STATE_DISCONNECTED;
1185 dapls_ib_disconnect_clean(ep_ptr, DAT_TRUE, IB_CME_CONNECTED);
1188 if (process_premature_events && (ep_ptr->param.ep_state ==