Searched refs:ep_ptr (Results 1 - 25 of 28) sorted by relevance

12

/osnet-11/usr/src/lib/udapl/udapl_tavor/common/
H A Ddapl_ep_free.c70 DAPL_EP *ep_ptr; local
77 ep_ptr = (DAPL_EP *) ep_handle;
78 param = &ep_ptr->param;
83 if (DAPL_BAD_HANDLE(ep_ptr, DAPL_MAGIC_EP) &&
84 !(ep_ptr->header.magic == DAPL_MAGIC_EP_EXIT &&
85 ep_ptr->param.ep_state == DAT_EP_STATE_DISCONNECTED)) {
91 if (ep_ptr->param.ep_state == DAT_EP_STATE_RESERVED ||
92 ep_ptr->param.ep_state == DAT_EP_STATE_PASSIVE_CONNECTION_PENDING ||
93 ep_ptr->param.ep_state ==
97 ep_ptr
[all...]
H A Ddapl_ep_reset.c71 DAPL_EP *ep_ptr; local
76 ep_ptr = (DAPL_EP *)ep_handle;
81 if (DAPL_BAD_HANDLE(ep_ptr, DAPL_MAGIC_EP)) {
87 if (ep_ptr->param.ep_state != DAT_EP_STATE_UNCONNECTED &&
88 ep_ptr->param.ep_state != DAT_EP_STATE_DISCONNECTED) {
90 dapls_ep_state_subtype(ep_ptr));
94 if (ep_ptr->param.ep_state == DAT_EP_STATE_DISCONNECTED) {
95 dapls_ib_reinit_ep(ep_ptr);
96 ep_ptr->param.ep_state = DAT_EP_STATE_UNCONNECTED;
H A Ddapl_ep_disconnect.c72 DAPL_EP *ep_ptr; local
78 ep_ptr = (DAPL_EP *) ep_handle;
83 if (DAPL_BAD_HANDLE(ep_ptr, DAPL_MAGIC_EP)) {
93 dapl_os_lock(&ep_ptr->header.lock);
102 if (ep_ptr->param.ep_state != DAT_EP_STATE_CONNECTED &&
103 ep_ptr->param.ep_state != DAT_EP_STATE_DISCONNECTED &&
104 ep_ptr->param.ep_state != DAT_EP_STATE_ACTIVE_CONNECTION_PENDING &&
105 ep_ptr->param.ep_state != DAT_EP_STATE_COMPLETION_PENDING &&
106 ep_ptr->param.ep_state != DAT_EP_STATE_DISCONNECT_PENDING) {
107 dapl_os_unlock(&ep_ptr
[all...]
H A Ddapl_evd_connection_callb.c74 DAPL_EP *ep_ptr; local
97 ep_ptr = (DAPL_EP *)context;
98 evd_ptr = (DAPL_EVD *)ep_ptr->param.connect_evd_handle;
111 if (ep_ptr->param.ep_state == DAT_EP_STATE_DISCONNECT_PENDING) {
118 dapls_ib_connected(ep_ptr);
119 ep_ptr->param.ep_state = DAT_EP_STATE_CONNECTED;
120 ep_ptr->cm_handle = ib_cm_handle;
122 (void) dapl_os_memcpy(ep_ptr->private_data,
129 (DAT_HANDLE) ep_ptr,
131 ep_ptr
[all...]
H A Ddapl_evd_qp_async_error_callb.c99 DAPL_EP *ep_ptr; local
104 ep_ptr = (DAPL_EP *) context;
105 ia_ptr = ep_ptr->header.owner_ia;
110 ep_ptr,
111 ep_ptr->qp_handle,
112 ep_ptr->qpn,
113 ep_ptr->param.ep_state);
119 if (ep_ptr->param.ep_state == DAT_EP_STATE_CONNECTED) {
120 ep_ptr->param.ep_state = DAT_EP_STATE_ERROR;
H A Ddapl_ep_connect.c86 DAPL_EP *ep_ptr; local
106 ep_ptr = (DAPL_EP *) ep_handle;
112 if (DAPL_BAD_HANDLE(ep_ptr, DAPL_MAGIC_EP)) {
118 if (DAPL_BAD_HANDLE(ep_ptr->param.connect_evd_handle, DAPL_MAGIC_EVD)) {
138 if (ep_ptr->qp_state == DAPL_QP_STATE_UNATTACHED) {
139 if (ep_ptr->param.pz_handle == NULL ||
140 DAPL_BAD_HANDLE(ep_ptr->param.pz_handle, DAPL_MAGIC_PZ)) {
145 alloc_ep = *ep_ptr;
147 dat_status = dapls_ib_qp_alloc(ep_ptr->header.owner_ia,
148 &alloc_ep, ep_ptr);
[all...]
H A Ddapl_cr_callback.c90 DAPL_EP *ep_ptr; local
126 ep_ptr = NULL;
129 ep_ptr = dapli_get_sp_ep(ib_cm_handle, sp_ptr, ib_cm_event);
130 dapl_os_assert(ep_ptr != NULL);
131 evd_ptr = (DAPL_EVD *) ep_ptr->param.connect_evd_handle;
134 ep_ptr, evd_ptr);
181 dapl_os_lock(&ep_ptr->header.lock);
182 if (ep_ptr->param.ep_state == DAT_EP_STATE_DISCONNECT_PENDING) {
187 dapl_os_unlock(&ep_ptr->header.lock);
191 dapls_ib_connected(ep_ptr);
341 DAPL_EP *ep_ptr; local
480 DAPL_EP *ep_ptr; local
[all...]
H A Ddapl_ep_util.c66 IN DAPL_EP *ep_ptr);
78 * ep_ptr
90 DAPL_EP *ep_ptr; local
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
185 dapl_ep_dealloc( IN DAPL_EP *ep_ptr) argument
217 dapli_ep_default_attrs( IN DAPL_EP *ep_ptr) argument
367 DAPL_EP *ep_ptr; local
392 dapls_ep_state_subtype( IN DAPL_EP *ep_ptr) argument
485 DAPL_EP *ep_ptr; local
[all...]
H A Ddapl_cr_reject.c71 DAPL_EP *ep_ptr; local
91 ep_ptr = (DAPL_EP *)cr_ptr->param.local_ep_handle;
94 if (ep_ptr != NULL) {
95 entry_ep_state = ep_ptr->param.ep_state;
96 ep_ptr->param.ep_state = DAT_EP_STATE_UNCONNECTED;
104 if (ep_ptr != NULL) {
106 ep_ptr->param.ep_state = entry_ep_state;
108 cr_ptr->param.local_ep_handle = (DAT_EP_HANDLE)ep_ptr;
117 if (ep_ptr != NULL &&
119 (void) dapl_ep_free(ep_ptr);
[all...]
H A Ddapl_cr_accept.c74 DAPL_EP *ep_ptr; local
139 ep_ptr = (DAPL_EP *) ep_handle;
152 dapl_os_lock(&ep_ptr->header.lock);
153 if ((ep_ptr->param.pz_handle == NULL) ||
154 DAPL_BAD_HANDLE(ep_ptr->param.pz_handle, DAPL_MAGIC_PZ) ||
155 (ep_ptr->param.connect_evd_handle == NULL) ||
156 DAPL_BAD_HANDLE(ep_ptr->param.connect_evd_handle, DAPL_MAGIC_EVD) ||
157 !(((DAPL_EVD *)ep_ptr->param.connect_evd_handle)->evd_flags &
159 (ep_ptr->param.recv_evd_handle != DAT_HANDLE_NULL &&
160 (DAPL_BAD_HANDLE(ep_ptr
[all...]
H A Ddapl_ep_get_status.c73 DAPL_EP *ep_ptr; local
79 ep_ptr = (DAPL_EP *)ep_handle;
85 if (DAPL_BAD_HANDLE(ep_ptr, DAPL_MAGIC_EP)) {
95 *ep_state = ep_ptr->param.ep_state;
99 *in_dto_idle = (ep_ptr->recv_count) ? DAT_FALSE : DAT_TRUE;
103 *out_dto_idle = (ep_ptr->req_count) ? DAT_FALSE : DAT_TRUE;
H A Ddapl_ep_query.c70 DAPL_EP *ep_ptr; local
77 ep_ptr = (DAPL_EP *) ep_handle;
82 if (DAPL_BAD_HANDLE(ep_ptr, DAPL_MAGIC_EP)) {
100 if (ep_ptr->param.ep_state == DAT_EP_STATE_CONNECTED) {
104 &ep_ptr->remote_ia_address);
106 *ep_param = ep_ptr->param;
H A Ddapl_ep_post_recv.c80 DAPL_EP *ep_ptr; local
98 ep_ptr = (DAPL_EP *) ep_handle;
101 if (ep_ptr->srq_attached) {
110 dat_status = dapls_dto_cookie_alloc(&ep_ptr->recv_buffer,
123 dat_status = dapls_ib_post_recv(ep_ptr, cookie, num_segments,
126 dat_status = dapls_ib_post_recv_one(ep_ptr, cookie, local_iov);
129 dapls_cookie_dealloc(&ep_ptr->recv_buffer, cookie);
131 dapl_os_atomic_inc(&ep_ptr->recv_count);
H A Ddapl_rmr_bind.c84 IN DAPL_EP *ep_ptr,
112 if (DAT_EP_STATE_CONNECTED != ep_ptr->param.ep_state) {
114 dapls_ep_state_subtype(ep_ptr));
129 if ((ep_ptr->param.pz_handle != lmr->param.pz_handle) ||
130 (ep_ptr->param.pz_handle != rmr->param.pz_handle)) {
136 ep_ptr->param.ep_attr.request_completion_flags, completion_flags) ||
138 ep_ptr->param.ep_attr.request_completion_flags, completion_flags) ||
141 ep_ptr->param.ep_attr.request_completion_flags, completion_flags)) {
146 dat_status = dapls_rmr_cookie_alloc(&ep_ptr->req_buffer,
154 ep_ptr,
80 dapli_rmr_bind_fuse( IN DAPL_RMR *rmr, IN const DAT_LMR_TRIPLET* lmr_triplet, IN DAT_MEM_PRIV_FLAGS mem_priv, IN DAPL_EP *ep_ptr, IN DAT_RMR_COOKIE user_cookie, IN DAT_COMPLETION_FLAGS completion_flags, OUT DAT_RMR_CONTEXT *rmr_context) argument
186 dapli_rmr_bind_unfuse( IN DAPL_RMR *rmr, IN const DAT_LMR_TRIPLET *lmr_triplet, IN DAPL_EP *ep_ptr, IN DAT_RMR_COOKIE user_cookie, IN DAT_COMPLETION_FLAGS completion_flags) argument
286 DAPL_EP *ep_ptr; local
[all...]
H A Ddapl_rsp_free.c70 DAPL_EP *ep_ptr; local
102 ep_ptr = (DAPL_EP *)sp_ptr->ep_handle;
103 if (ep_ptr->param.ep_state == DAT_EP_STATE_RESERVED) {
104 ep_ptr->param.ep_state = DAT_EP_STATE_UNCONNECTED;
H A Ddapl_rsp_create.c85 DAPL_EP *ep_ptr; local
117 ep_ptr = (DAPL_EP *) ep_handle;
118 if (ep_ptr->param.ep_state != DAT_EP_STATE_UNCONNECTED) {
120 dapls_ep_state_subtype(ep_ptr));
162 ep_ptr->param.ep_state = DAT_EP_STATE_RESERVED;
H A Ddapl_evd_util.c840 dapls_evd_post_premature_events(IN DAPL_EP *ep_ptr) argument
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; local
[all...]
H A Ddapl_ia_util.c141 DAPL_EP *ep_ptr, *next_ep_ptr; local
192 ep_ptr = (dapl_llist_is_empty(&ia_ptr->ep_list_head)
194 while (ep_ptr != NULL) {
196 &ep_ptr->header.ia_list_entry);
197 dat_status = dapl_ep_disconnect(ep_ptr, DAT_CLOSE_ABRUPT_FLAG);
201 ep_ptr,
204 dat_status = dapl_ep_free(ep_ptr);
208 ep_ptr,
211 ep_ptr = next_ep_ptr;
535 * ep_ptr
545 dapl_ia_link_ep( IN DAPL_IA *ia_ptr, IN DAPL_EP *ep_ptr) argument
573 dapl_ia_unlink_ep( IN DAPL_IA *ia_ptr, IN DAPL_EP *ep_ptr) argument
[all...]
H A Ddapl_osd.c370 DAPL_EP *ep_ptr; local
424 ep_ptr = (DAPL_EP *) dapl_llist_peek_head(
426 param = &ep_ptr->param;
445 dapl_ia_unlink_ep(ia_ptr, ep_ptr);
446 dapl_ep_dealloc(ep_ptr);
H A Ddapl_ep_modify.c57 OUT DAPL_EP **ep_ptr,
371 OUT DAPL_EP **ep_ptr,
382 *ep_ptr = NULL;
609 *ep_ptr = ep;
366 dapli_ep_modify_validate_parameters( IN DAT_EP_HANDLE ep_handle, IN DAT_EP_PARAM_MASK ep_param_mask, IN const DAT_EP_PARAM *ep_param, OUT DAPL_IA **ia_ptr, OUT DAPL_EP **ep_ptr, OUT DAT_EP_ATTR *ep_attr_ptr) argument
/osnet-11/usr/src/lib/udapl/udapl_tavor/tavor/
H A Ddapl_tavor_ibtf_dto.c52 IN DAPL_EP *ep_ptr,
68 if (ep_ptr->qp_handle == NULL) {
102 cookie->val.dto.size, ep_ptr->qp_handle->ep_hkey);
113 if (ep_ptr->param.ep_attr.recv_completion_flags &
128 retval = DAPL_RECV(ep_ptr)(ep_ptr, &pr_wr, suppress_notification);
151 IN DAPL_EP *ep_ptr,
161 if (ep_ptr->qp_handle == NULL) {
181 cookie->val.dto.size, ep_ptr->qp_handle->ep_hkey);
188 if (ep_ptr
51 dapls_ib_post_recv( IN DAPL_EP *ep_ptr, IN DAPL_COOKIE *cookie, IN DAT_COUNT num_segments, IN DAT_LMR_TRIPLET *local_iov, IN DAT_COMPLETION_FLAGS completion_flags) argument
150 dapls_ib_post_recv_one( IN DAPL_EP *ep_ptr, IN DAPL_COOKIE *cookie, IN DAT_LMR_TRIPLET *local_iov) argument
301 dapls_ib_post_send(IN DAPL_EP *ep_ptr, IN ib_send_op_type_t op_type, IN DAPL_COOKIE *cookie, IN DAT_COUNT num_segments, IN DAT_LMR_TRIPLET *local_iov, IN const DAT_RMR_TRIPLET *remote_iov, IN DAT_COMPLETION_FLAGS completion_flags) argument
454 dapls_ib_post_send_one(IN DAPL_EP *ep_ptr, IN ib_send_op_type_t op_type, IN DAPL_COOKIE *cookie, IN DAT_LMR_TRIPLET *local_iov, IN const DAT_RMR_TRIPLET *remote_iov) argument
[all...]
H A Ddapl_tavor_ibtf_qp.c44 IN uint32_t qpnum, IN DAPL_EP *ep_ptr);
139 * *ep_ptr pointer to EP INFO
156 IN DAPL_EP *ep_ptr,
185 dapl_os_assert(ep_ptr->param.pz_handle != NULL);
186 dapl_os_assert(ep_ptr->param.connect_evd_handle != NULL);
191 pz_handle = (DAPL_PZ *)ep_ptr->param.pz_handle;
195 (DAPL_EVD *)ep_ptr->param.recv_evd_handle);
199 (DAPL_EVD *)ep_ptr->param.request_evd_handle);
202 evd_handle = (DAPL_EVD *)ep_ptr->param.connect_evd_handle;
205 ep_args.ep_ch_sizes.dcs_sq = ep_ptr
154 dapls_ib_qp_alloc( IN DAPL_IA *ia_ptr, IN DAPL_EP *ep_ptr, IN DAPL_EP *ep_ctx_ptr) argument
431 dapls_ib_qp_free(IN DAPL_IA *ia_ptr, IN DAPL_EP *ep_ptr) argument
496 dapls_ib_qp_modify(IN DAPL_IA *ia_ptr, IN DAPL_EP *ep_ptr, IN DAT_EP_ATTR *ep_attr) argument
798 dapli_ib_srq_add_ep(IN ib_srq_handle_t srq_ptr, IN uint32_t qp_num, IN DAPL_EP *ep_ptr) argument
[all...]
H A Ddapl_tavor_ibtf_cm.c213 dapls_ib_disconnect(IN DAPL_EP *ep_ptr, argument
221 if (ep_ptr->qp_handle == NULL) {
226 args.epd_hkey = ep_ptr->qp_handle->ep_hkey;
228 retval = ioctl(ep_ptr->header.owner_ia->hca_ptr->ib_hca_handle->ia_fd,
231 ep_ptr->qp_state = IBT_STATE_ERROR;
239 s = (struct sockaddr *)ep_ptr->param.remote_ia_address_ptr;
242 dapls_inet_ntop(s, addr_buf, 64), ep_ptr->param.remote_port_qual);
254 dapls_ib_connected(IN DAPL_EP *ep_ptr) argument
256 ep_ptr->qp_state = IBT_STATE_RTS;
267 * ep_ptr DAPL_E
278 dapls_ib_disconnect_clean(IN DAPL_EP *ep_ptr, IN DAT_BOOLEAN active, IN const ib_cm_events_t ib_cm_event) argument
315 dapls_ib_reinit_ep(IN DAPL_EP *ep_ptr) argument
[all...]
/osnet-11/usr/src/lib/udapl/udapl_tavor/include/
H A Ddapl_adapter_util.h79 IN DAPL_EP *ep_ptr,
84 IN DAPL_EP *ep_ptr);
88 IN DAPL_EP *ep_ptr,
100 IN DAPL_EP *ep_ptr,
235 IN DAPL_EP *ep_ptr);
238 IN DAPL_EP *ep_ptr);
241 IN DAPL_EP *ep_ptr,
260 IN DAPL_EP *ep_ptr,
265 IN DAPL_EP *ep_ptr,
299 IN DAPL_EP *ep_ptr,
[all...]
H A Ddapl_ep_util.h58 IN DAPL_EP *ep_ptr);
87 IN DAPL_EP *ep_ptr);

Completed in 50 milliseconds

12