clients/ibd/ibd.c

2514 	 *    can be referred to when the swqe/rwqe change is requested via
3643 	ibd_swqe_t *swqe;
3669 	 * Allocate and setup the swqe list
3674 	swqe = state->id_tx_wqes;
3676 	for (i = 0; i < state->id_ud_num_swqe; i++, swqe++, bufaddr += len) {
3677 		swqe->swqe_next = NULL;
3678 		swqe->swqe_im_mblk = NULL;
3680 		swqe->swqe_copybuf.ic_sgl.ds_va = (ib_vaddr_t)(uintptr_t)
3682 		swqe->swqe_copybuf.ic_sgl.ds_key = lkey;
3683 		swqe->swqe_copybuf.ic_sgl.ds_len = 0; /* set in send */
3685 		swqe->w_swr.wr_id = (ibt_wrid_t)(uintptr_t)swqe;
3686 		swqe->w_swr.wr_flags = IBT_WR_NO_FLAGS;
3687 		swqe->w_swr.wr_trans = IBT_UD_SRV;
3690 		swqe->w_swr.wr_nds = 0;
3691 		swqe->w_swr.wr_sgl = NULL;
3692 		swqe->w_swr.wr_opcode = IBT_WRC_SEND;
3696 		swqe->swqe_next = state->id_tx_list.dl_head;
3697 		state->id_tx_list.dl_head = SWQE_TO_WQE(swqe);
5381 	 * plus #swqe cqe's, except that the CQ will be signaled for
5457 		ibd_print_warn(state, "Setting #swqe = %d instead of default "
6558 	} else {	/* no free swqe */
7021 			 * If we don't have an swqe available, schedule a
7036 			ibd_print_warn(state, "ibd_send: no swqe, pkt drop");
7045 	 * Initialize the commonly used fields in swqe to NULL to protect
7536 			 * Add this swqe to the list to be cleaned up.
7735  * Unmap the memory area associated with a given swqe.
7738 ibd_unmap_mem(ibd_state_t *state, ibd_swqe_t *swqe)
7742 	DPRINT(20, "ibd_unmap_mem: wqe=%p, seg=%d\n", swqe, swqe->w_swr.wr_nds);
7744 	if (swqe->w_mi_hdl) {
7746 		    swqe->w_mi_hdl)) != IBT_SUCCESS) {
7750 		swqe->w_mi_hdl = NULL;
7752 	swqe->w_swr.wr_nds = 0;
7819 ibd_tx_cleanup(ibd_state_t *state, ibd_swqe_t *swqe)
7821 	ibd_ace_t *ace = swqe->w_ahandle;
7823 	DPRINT(20, "ibd_tx_cleanup %p\n", swqe);
7830 	 * the copybuf (present in each swqe), we don't need to release it.
7832 	if (swqe->swqe_im_mblk != NULL) {
7833 		if (swqe->w_buftype == IBD_WQE_MAPPED) {
7834 			ibd_unmap_mem(state, swqe);
7835 		} else if (swqe->w_buftype == IBD_WQE_LSOBUF) {
7837 			    swqe->w_swr.wr_sgl, swqe->w_swr.wr_nds);
7839 		ibd_free_lsohdr(swqe, swqe->swqe_im_mblk);
7840 		freemsg(swqe->swqe_im_mblk);
7841 		swqe->swqe_im_mblk = NULL;
7859 	swqe->swqe_next = NULL;
7860 	ibd_release_swqe(state, swqe, swqe, 1);
7867 	ibd_swqe_t *swqe;
7872 	for (swqe = head; swqe != NULL; swqe = WQE_TO_SWQE(swqe->swqe_next)) {
7879 		 * send using the copybuf (present in each swqe), we don't need
7882 		if (swqe->swqe_im_mblk != NULL) {
7883 			if (swqe->w_buftype == IBD_WQE_MAPPED) {
7884 				ibd_unmap_mem(state, swqe);
7885 			} else if (swqe->w_buftype == IBD_WQE_LSOBUF) {
7887 				    swqe->w_swr.wr_sgl, swqe->w_swr.wr_nds);
7889 			ibd_free_lsohdr(swqe, swqe->swqe_im_mblk);
7890 			freemsg(swqe->swqe_im_mblk);
7891 			swqe->swqe_im_mblk = NULL;
7902 		ace = swqe->w_ahandle;