mgt/ibmf/ibmf_send.c

49 ibmf_i_issue_pkt(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp,
62 	    "ibmf_i_issue_pkt() enter, clientp = %p, msg = %p, "
63 	    "qp_hdl = %p,  swqep = %p\n", tnf_opaque, clientp, clientp,
68 	ASSERT(MUTEX_NOT_HELD(&clientp->ic_mutex));
77 		ibt_qp_handle = clientp->ic_qp->iq_qp_handle;
84 	ibmf_i_init_send_wqe(clientp, msgimplp, sgl, send_wqep,
97 		mutex_enter(&clientp->ic_kstat_mutex);
98 		IBMF_ADD32_KSTATS(clientp, send_pkt_failed, 1);
99 		mutex_exit(&clientp->ic_kstat_mutex);
114 		mutex_enter(&clientp->ic_mutex);
115 		clientp->ic_sends_active++;
116 		mutex_exit(&clientp->ic_mutex);
117 		mutex_enter(&clientp->ic_kstat_mutex);
118 		IBMF_ADD32_KSTATS(clientp, sends_active, 1);
119 		mutex_exit(&clientp->ic_kstat_mutex);
125 		mutex_enter(&clientp->ic_kstat_mutex);
126 		IBMF_ADD32_KSTATS(clientp, sends_active, 1);
127 		mutex_exit(&clientp->ic_kstat_mutex);
140 ibmf_i_send_pkt(ibmf_client_t *clientp, ibmf_qp_handle_t ibmf_qp_handle,
148 	    "ibmf_i_send_pkt(): clientp = 0x%p, qp_hdl = 0x%p, "
149 	    "msgp = 0x%p, block = %d\n", tnf_opaque, clientp, clientp,
167 	status = ibmf_i_alloc_send_resources(clientp->ic_myci,
193 	status = ibmf_i_issue_pkt(clientp, msgimplp, ibmf_qp_handle, send_wqep);
195 		ibmf_i_free_send_resources(clientp->ic_myci, msgimplp,
218 ibmf_i_send_single_pkt(ibmf_client_t *clientp, ibmf_qp_handle_t ibmf_qp_handle,
225 	    "ibmf_i_send_single_pkt(): clientp = 0x%p, qp_hdl = 0x%p, "
226 	    "msgp = 0x%p, block = %d\n", tnf_opaque, clientp, clientp,
232 	status = ibmf_i_send_pkt(clientp, ibmf_qp_handle, msgimplp, block);
258 	ibmf_client_t		*clientp, *cclientp;
281 	cclientp =  clientp = send_wqep->send_client;
284 	if (clientp == NULL) {
316 	ASSERT(clientp != NULL);
320 		mutex_enter(&clientp->ic_mutex);
321 		clientp->ic_sends_active--;
322 		mutex_exit(&clientp->ic_mutex);
329 	mutex_enter(&clientp->ic_kstat_mutex);
330 	IBMF_SUB32_KSTATS(clientp, sends_active, 1);
331 	mutex_exit(&clientp->ic_kstat_mutex);
342 		mutex_enter(&clientp->ic_kstat_mutex);
343 		IBMF_ADD32_KSTATS(clientp, send_cb_active, 1);
344 		mutex_exit(&clientp->ic_kstat_mutex);
346 		mutex_enter(&clientp->ic_kstat_mutex);
347 		IBMF_SUB32_KSTATS(clientp, send_cb_active, 1);
348 		mutex_exit(&clientp->ic_kstat_mutex);
359 	mutex_enter(&clientp->ic_kstat_mutex);
360 	IBMF_ADD32_KSTATS(clientp, send_cb_active, 1);
361 	mutex_exit(&clientp->ic_kstat_mutex);
364 	if ((clientp->ic_reg_flags & IBMF_REG_FLAG_NO_OFFLOAD) == 0) {
378 	mutex_enter(&clientp->ic_kstat_mutex);
379 	IBMF_SUB32_KSTATS(clientp, send_cb_active, 1);
380 	mutex_exit(&clientp->ic_kstat_mutex);
398 	ibmf_client_t		*clientp;
417 	clientp = send_wqep->send_client;
418 	cip = clientp->ic_myci;
434 	found = ibmf_i_find_msg_client(clientp, msgimplp, inc_refcnt);
548 			ibmf_i_notify_sequence(clientp, msgimplp, msg_flags);
577 	ibmf_i_do_send_compl((ibmf_handle_t)clientp, msgimplp, send_wqep);
639 		ibmf_i_client_rem_msg(clientp, msgimplp, &ref_cnt);
650 			ibmf_i_notify_sequence(clientp, msgimplp, msg_flags);