/osnet-11/usr/src/lib/udapl/udapl_tavor/common/ |
H A D | dapl_psp_free.c | 70 DAPL_SP *sp_ptr; local 73 sp_ptr = (DAPL_SP *) psp_handle; 80 if (DAPL_BAD_HANDLE(sp_ptr, DAPL_MAGIC_PSP)) { 86 /* ia_ptr = (DAPL_IA *)sp_ptr->header.owner_ia; */ 87 ia_ptr = sp_ptr->header.owner_ia; 95 dapl_os_lock(&sp_ptr->header.lock); 96 sp_ptr->listening = DAT_FALSE; 102 if (sp_ptr->evd_handle) { 103 dapl_os_atomic_dec(&((DAPL_EVD *)sp_ptr->evd_handle)-> 105 sp_ptr [all...] |
H A D | dapl_psp_query.c | 68 DAPL_SP *sp_ptr; local 90 sp_ptr = (DAPL_SP *) psp_handle; 95 psp_param->ia_handle = sp_ptr->ia_handle; 96 psp_param->conn_qual = sp_ptr->conn_qual; 97 psp_param->evd_handle = sp_ptr->evd_handle; 98 psp_param->psp_flags = sp_ptr->psp_flags;
|
H A D | dapl_rsp_free.c | 69 DAPL_SP *sp_ptr; local 75 sp_ptr = (DAPL_SP *)rsp_handle; 82 if (DAPL_BAD_HANDLE(sp_ptr, DAPL_MAGIC_RSP)) { 88 /* ia_ptr = (DAPL_IA *)sp_ptr->header.owner_ia; */ 89 ia_ptr = sp_ptr->header.owner_ia; 96 dapl_os_lock(&sp_ptr->header.lock); 102 ep_ptr = (DAPL_EP *)sp_ptr->ep_handle; 106 sp_ptr->ep_handle = NULL; 109 dapl_os_atomic_dec(&((DAPL_EVD *)sp_ptr->evd_handle)->evd_ref_count); 110 sp_ptr [all...] |
H A D | dapl_rsp_query.c | 68 DAPL_SP *sp_ptr; local 89 sp_ptr = (DAPL_SP *)rsp_handle; 94 rsp_param->ia_handle = sp_ptr->ia_handle; 95 rsp_param->conn_qual = sp_ptr->conn_qual; 96 rsp_param->evd_handle = sp_ptr->evd_handle; 97 rsp_param->ep_handle = sp_ptr->ep_handle;
|
H A D | dapl_cr_reject.c | 74 DAPL_SP *sp_ptr; local 101 IB_CM_REJ_REASON_CONSUMER_REJ, cr_ptr->sp_ptr); 116 sp_ptr = cr_ptr->sp_ptr; 118 sp_ptr->psp_flags == DAT_PSP_PROVIDER_FLAG) { 122 dapl_sp_remove_cr(cr_ptr->sp_ptr, cr_ptr);
|
H A D | dapl_psp_create_any.c | 85 DAPL_SP *sp_ptr; local 129 sp_ptr = dapls_sp_alloc(ia_ptr, DAT_TRUE); 130 if (sp_ptr == NULL) { 139 sp_ptr->ia_handle = ia_handle; 140 sp_ptr->evd_handle = evd_handle; 141 sp_ptr->psp_flags = psp_flags; 142 sp_ptr->ep_handle = NULL; 150 dapl_ia_link_psp(ia_ptr, sp_ptr); 156 sp_ptr->state = DAPL_SP_STATE_PSP_LISTENING; 157 sp_ptr [all...] |
H A D | dapl_psp_create.c | 82 DAPL_SP *sp_ptr; local 135 sp_ptr = dapls_ia_sp_search(ia_ptr, conn_qual, DAT_TRUE); 137 if (sp_ptr == NULL) { 140 sp_ptr = dapls_sp_alloc(ia_ptr, DAT_TRUE); 142 if (sp_ptr == NULL) { 147 } else if (sp_ptr->listening == DAT_TRUE) { 155 sp_ptr->ia_handle = ia_handle; 156 sp_ptr->conn_qual = conn_qual; 157 sp_ptr->evd_handle = evd_handle; 158 sp_ptr [all...] |
H A D | dapl_rsp_create.c | 83 DAPL_SP *sp_ptr; local 131 sp_ptr = dapls_ia_sp_search(ia_ptr, conn_qual, DAT_FALSE); 133 if (sp_ptr == NULL) { 137 sp_ptr = dapls_sp_alloc(ia_ptr, DAT_FALSE); 138 if (sp_ptr == NULL) { 148 sp_ptr->ia_handle = ia_handle; 149 sp_ptr->conn_qual = conn_qual; 150 sp_ptr->evd_handle = evd_handle; 151 sp_ptr->psp_flags = 0; 152 sp_ptr [all...] |
H A D | dapl_sp_util.c | 57 * sp_ptr 69 DAPL_SP *sp_ptr; local 72 sp_ptr = (DAPL_SP *)dapl_os_alloc(sizeof (DAPL_SP)); 73 if (sp_ptr == NULL) { 78 (void) dapl_os_memzero(sp_ptr, sizeof (DAPL_SP)); 83 sp_ptr->header.provider = ia_ptr->header.provider; 85 sp_ptr->header.magic = DAPL_MAGIC_PSP; 86 sp_ptr->header.handle_type = DAT_HANDLE_TYPE_PSP; 88 sp_ptr->header.magic = DAPL_MAGIC_RSP; 89 sp_ptr 122 dapls_sp_free_sp( IN DAPL_SP *sp_ptr) argument 154 dapl_sp_link_cr( IN DAPL_SP *sp_ptr, IN DAPL_CR *cr_ptr) argument 184 dapl_sp_search_cr( IN DAPL_SP *sp_ptr, IN ib_cm_handle_t ib_cm_handle) argument 226 dapl_sp_remove_cr( IN DAPL_SP *sp_ptr, IN DAPL_CR *cr_ptr) argument [all...] |
H A D | dapl_cr_callback.c | 57 IN DAPL_SP *sp_ptr, 63 IN DAPL_SP *sp_ptr, 92 DAPL_SP *sp_ptr; local 112 sp_ptr = (DAPL_SP *) context; 127 evd_ptr = sp_ptr->evd_handle; 129 ep_ptr = dapli_get_sp_ep(ib_cm_handle, sp_ptr, ib_cm_event); 147 dapl_os_lock(&sp_ptr->header.lock); 148 if (sp_ptr->listening == DAT_FALSE) { 149 dapl_os_unlock(&sp_ptr->header.lock); 155 if (sp_ptr 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 474 dapli_get_sp_ep( IN ib_cm_handle_t ib_cm_handle, IN DAPL_SP *sp_ptr, IN const ib_cm_events_t ib_cm_event) argument [all...] |
H A D | dapl_osd.c | 373 DAPL_SP *sp_ptr; local 415 sp_ptr = (DAPL_SP *) dapl_llist_peek_head( 417 dapl_os_atomic_dec(&((DAPL_EVD *)sp_ptr-> 419 dapls_ia_unlink_sp(ia_ptr, sp_ptr); 420 dapls_sp_free_sp(sp_ptr); 465 sp_ptr = (DAPL_SP *) dapl_llist_peek_head( 467 while (!dapl_llist_is_empty(&sp_ptr-> 471 &sp_ptr->cr_list_head); 472 dapl_sp_remove_cr(sp_ptr, cr_ptr); 476 dapls_ia_unlink_sp(ia_ptr, sp_ptr); [all...] |
H A D | dapl_ia_util.c | 147 DAPL_SP *sp_ptr, *next_sp_ptr; /* for PSP and RSP queues */ local 177 sp_ptr = (dapl_llist_is_empty(&ia_ptr->rsp_list_head) 179 while (sp_ptr != NULL) { 181 &sp_ptr->header.ia_list_entry); 182 dat_status = dapl_rsp_free(sp_ptr); 186 sp_ptr, 189 sp_ptr = next_sp_ptr; 229 sp_ptr = (dapl_llist_is_empty(&ia_ptr->psp_list_head) 231 while (sp_ptr != NULL) { 233 &sp_ptr 875 dapl_ia_link_psp( IN DAPL_IA *ia_ptr, IN DAPL_SP *sp_ptr) argument 903 dapls_ia_unlink_sp( IN DAPL_IA *ia_ptr, IN DAPL_SP *sp_ptr) argument 945 DAPL_SP *sp_ptr; local 990 dapl_ia_link_rsp( IN DAPL_IA *ia_ptr, IN DAPL_SP *sp_ptr) argument [all...] |
/osnet-11/usr/src/lib/udapl/udapl_tavor/tavor/ |
H A D | dapl_tavor_ibtf_cm.c | 401 IN DAT_UINT64 ServiceID, IN DAPL_SP *sp_ptr) 408 DAPL_EVD *evd_p = (DAPL_EVD *)sp_ptr->evd_handle; 431 args.sr_sp_cookie = (uintptr_t)sp_ptr; 442 sp_ptr->cm_srvc_handle = srvc_hdl; 443 sp_ptr->conn_qual = args.sr_retsid; 449 sp_ptr->conn_qual); 471 dapls_ib_remove_conn_listener(IN DAPL_IA *ia_ptr, IN DAPL_SP *sp_ptr) argument 485 srvc_hdl = (struct dapls_ib_cm_srvc_handle *)sp_ptr-> 497 sp_ptr->cm_srvc_handle = NULL; 503 sp_ptr 400 dapls_ib_setup_conn_listener(IN DAPL_IA *ia_ptr, IN DAT_UINT64 ServiceID, IN DAPL_SP *sp_ptr) argument 525 dapls_ib_reject_connection(IN ib_cm_handle_t cm_handle, IN int reject_reason, IN DAPL_SP *sp_ptr) argument [all...] |
/osnet-11/usr/src/lib/udapl/udapl_tavor/include/ |
H A D | dapl.h | 588 DAPL_SP *sp_ptr; member in struct:dapl_cr
|