Lines Matching refs:ep_ptr
66 IN DAPL_EP *ep_ptr);
78 * ep_ptr
90 DAPL_EP *ep_ptr;
93 ep_ptr = (DAPL_EP *)dapl_os_alloc(sizeof (DAPL_EP));
94 if (ep_ptr == NULL) {
99 (void) dapl_os_memzero(ep_ptr, sizeof (DAPL_EP));
104 ep_ptr->header.provider = ia_ptr->header.provider;
105 ep_ptr->header.magic = DAPL_MAGIC_EP;
106 ep_ptr->header.handle_type = DAT_HANDLE_TYPE_EP;
107 ep_ptr->header.owner_ia = ia_ptr;
108 ep_ptr->header.user_context.as_64 = 0;
109 ep_ptr->header.user_context.as_ptr = NULL;
110 dapl_llist_init_entry(&ep_ptr->header.ia_list_entry);
111 dapl_os_lock_init(&ep_ptr->header.lock);
116 (void) dapl_os_memzero(&ep_ptr->param, sizeof (DAT_EP_PARAM));
117 ep_ptr->param.ep_state = DAT_EP_STATE_UNCONNECTED;
118 ep_ptr->param.local_ia_address_ptr =
122 ep_ptr->param.remote_ia_address_ptr =
123 (DAT_IA_ADDRESS_PTR) &ep_ptr->remote_ia_address;
129 dapli_ep_default_attrs(ep_ptr);
131 ep_ptr->param.ep_attr = *ep_attr;
137 ep_ptr->qp_handle = IB_INVALID_HANDLE;
138 ep_ptr->qpn = 0;
139 ep_ptr->qp_state = DAPL_QP_STATE_UNATTACHED;
140 ep_ptr->cm_handle = IB_INVALID_HANDLE;
142 ep_ptr->req_count = 0;
143 ep_ptr->recv_count = 0;
145 ep_ptr->srq_attached = srq_attached;
147 if (DAT_SUCCESS != dapls_cb_create(&ep_ptr->req_buffer, ep_ptr,
148 DAPL_COOKIE_QUEUE_EP, ep_ptr->param.ep_attr.max_request_dtos)) {
149 dapl_ep_dealloc(ep_ptr);
150 ep_ptr = NULL;
155 if (DAT_SUCCESS != dapls_cb_create(&ep_ptr->recv_buffer, ep_ptr,
157 ep_ptr->param.ep_attr.max_recv_dtos)) {
158 dapl_ep_dealloc(ep_ptr);
159 ep_ptr = NULL;
165 return (ep_ptr);
186 IN DAPL_EP *ep_ptr)
188 dapl_os_assert(ep_ptr->header.magic == DAPL_MAGIC_EP ||
189 ep_ptr->header.magic == DAPL_MAGIC_EP_EXIT);
192 ep_ptr->header.magic = DAPL_MAGIC_INVALID;
194 dapls_cb_free(&ep_ptr->req_buffer);
195 dapls_cb_free(&ep_ptr->recv_buffer);
197 dapl_os_free(ep_ptr, sizeof (DAPL_EP));
218 IN DAPL_EP *ep_ptr)
222 ep_attr = &ep_ptr->param.ep_attr;
367 DAPL_EP *ep_ptr;
371 ep_ptr = (DAPL_EP *)arg;
374 ep_ptr->param.ep_state = DAT_EP_STATE_DISCONNECTED;
377 (DAPL_EVD *)ep_ptr->param.connect_evd_handle,
379 (DAT_HANDLE) ep_ptr,
393 IN DAPL_EP *ep_ptr)
397 switch (ep_ptr->param.ep_state) {
485 DAPL_EP *ep_ptr;
696 ep_ptr = dapl_ep_alloc(ia_ptr, ep_attr, srq_attached);
697 if (ep_ptr == NULL) {
706 ep_ptr->param.ia_handle = ia_handle;
707 ep_ptr->param.pz_handle = pz_handle;
708 ep_ptr->param.recv_evd_handle = recv_evd_handle;
709 ep_ptr->param.request_evd_handle = request_evd_handle;
710 ep_ptr->param.connect_evd_handle = connect_evd_handle;
711 ep_ptr->param.srq_handle = srq_handle;
713 ep_ptr->srq_attached = srq_attached;
719 ep_ptr->param.ep_attr.max_recv_dtos = 0;
723 ep_ptr->param.ep_attr.max_request_dtos = 0;
739 dat_status = dapls_ib_qp_alloc(ia_ptr, ep_ptr, ep_ptr);
744 dapl_ep_dealloc(ep_ptr);
748 ep_ptr->qp_state = DAPL_QP_STATE_UNATTACHED;
774 dapl_ia_link_ep(ia_ptr, ep_ptr);
776 *ep_handle = ep_ptr;