Lines Matching defs:srq_ptr

75 	DAPL_SRQ	*srq_ptr;
126 srq_ptr = dapl_srq_alloc(ia_ptr, srq_attr);
127 if (srq_ptr == NULL) {
139 srq_ptr->param.ia_handle = ia_handle;
140 srq_ptr->param.srq_state = DAT_SRQ_STATE_OPERATIONAL;
141 srq_ptr->param.pz_handle = pz_handle;
142 srq_ptr->param.max_recv_dtos = srq_attr->max_recv_dtos;
143 srq_ptr->param.max_recv_iov = srq_attr->max_recv_iov;
144 srq_ptr->param.low_watermark = DAT_SRQ_LW_DEFAULT;
146 srq_ptr->param.available_dto_count = DAT_VALUE_UNKNOWN;
147 srq_ptr->param.outstanding_dto_count = 0;
149 dat_status = dapls_ib_srq_alloc(ia_ptr, srq_ptr);
152 dapl_srq_dealloc(srq_ptr);
156 dapl_ia_link_srq(ia_ptr, srq_ptr);
158 *srq_handle = srq_ptr;
187 DAPL_SRQ *srq_ptr;
198 srq_ptr = (DAPL_SRQ *)srq_handle;
199 param = &srq_ptr->param;
200 if (0 != srq_ptr->srq_ref_count) {
203 srq_ptr, srq_ptr->srq_ref_count);
209 ia_ptr = srq_ptr->header.owner_ia;
212 dapls_ib_srq_free(ia_ptr, srq_ptr);
215 dapl_ia_unlink_srq(ia_ptr, srq_ptr);
221 dapl_srq_dealloc(srq_ptr);
260 DAPL_SRQ *srq_ptr;
277 srq_ptr = (DAPL_SRQ *) srq_handle;
283 dat_status = dapls_dto_cookie_alloc(&srq_ptr->recv_buffer,
294 dat_status = dapls_ib_post_srq(srq_ptr, cookie, num_segments,
298 dapls_cookie_dealloc(&srq_ptr->recv_buffer, cookie);
300 dapl_os_atomic_inc(&srq_ptr->recv_count);
339 DAPL_SRQ *srq_ptr;
360 srq_ptr = (DAPL_SRQ *)srq_handle;
362 *srq_param = srq_ptr->param;
364 srq_param->outstanding_dto_count = srq_ptr->recv_count;
433 DAPL_SRQ *srq_ptr;
439 srq_ptr = (DAPL_SRQ *)srq_handle;
447 if (srq_max_recv_dtos < srq_ptr->recv_count) {
455 if (srq_max_recv_dtos <= srq_ptr->param.max_recv_dtos) {
461 dat_status = dapls_ib_query_hca(srq_ptr->header.owner_ia->hca_ptr,
472 dat_status = dapls_cb_resize(&srq_ptr->recv_buffer, srq_max_recv_dtos,
478 dat_status = dapls_ib_srq_resize(srq_ptr, srq_max_recv_dtos);
483 dapls_cb_free(&srq_ptr->recv_buffer);
484 srq_ptr->recv_buffer = new_cb; /* struct copy */
485 srq_ptr->param.max_recv_dtos = srq_max_recv_dtos;