 /* * If this is a userspace QP, we don't actually have to * allocate anything.  All we need is to calculate the WQE * sizes and the send_wqe_offset, so we're done now. */ if (pd->ibpd.uobject) return 0;  
static int mthca_alloc_wqe_buf(struct mthca_dev *dev,			       struct mthca_pd *pd,			       struct mthca_qp *qp){	int size;	int i;	int npages, shift;	dma_addr_t t;	u64 *dma_list = NULL;	int err = -ENOMEM;	size = sizeof (struct mthca_next_seg) +		qp->rq.max_gs * sizeof (struct mthca_data_seg);	for (qp->rq.wqe_shift = 6; 1 << qp->rq.wqe_shift < size;	     qp->rq.wqe_shift++)		; /* nothing */	size = sizeof (struct mthca_next_seg) +		qp->sq.max_gs * sizeof (struct mthca_data_seg);	switch (qp->transport) {	case MLX:		size += 2 * sizeof (struct mthca_data_seg);		break;	case UD:		if (mthca_is_memfree(dev))			size += sizeof (struct mthca_arbel_ud_seg);		else			size += sizeof (struct mthca_tavor_ud_seg);		break;	default:		/* bind seg is as big as atomic + raddr segs */		size += sizeof (struct mthca_bind_seg);	}	for (qp->sq.wqe_shift = 6; 1 << qp->sq.wqe_shift < size;	     qp->sq.wqe_shift++)		; /* nothing */	qp->send_wqe_offset = ALIGN(qp->rq.max << qp->rq.wqe_shift,				    1 << qp->sq.wqe_shift);	size = PAGE_ALIGN(qp->send_wqe_offset +			  (qp->sq.max << qp->sq.wqe_shift));	qp->wrid = kmalloc((qp->rq.max + qp->sq.max) * sizeof (u64),			   GFP_KERNEL);	if (!qp->wrid)		goto err_out;	if (size <= MTHCA_MAX_DIRECT_QP_SIZE) {		qp->is_direct = 1;		npages = 1;		shift = get_order(size) + PAGE_SHIFT;		if (0)			mthca_dbg(dev, "Creating direct QP of size %d (shift %d)\n",				  size, shift);		qp->queue.direct.buf = dma_alloc_coherent(&dev->pdev->dev, size,							  &t, GFP_KERNEL);		if (!qp->queue.direct.buf)			goto err_out;		pci_unmap_addr_set(&qp->queue.direct, mapping, t);		memset(qp->queue.direct.buf, 0, size);		while (t & ((1 << shift) - 1)) {			--shift;			npages *= 2;		}		dma_list = kmalloc(npages * sizeof *dma_list, GFP_KERNEL);		if (!dma_list)			goto err_out_free;		for (i = 0; i < npages; ++i)			dma_list[i] = t + i * (1 << shift);	} else {		qp->is_direct = 0;		npages = size / PAGE_SIZE;		shift = PAGE_SHIFT;		if (0)			mthca_dbg(dev, "Creating indirect QP with %d pages\n", npages);		dma_list = kmalloc(npages * sizeof *dma_list, GFP_KERNEL);		if (!dma_list)			goto err_out;		qp->queue.page_list = kmalloc(npages *					      sizeof *qp->queue.page_list,					      GFP_KERNEL);		if (!qp->queue.page_list)			goto err_out;		for (i = 0; i < npages; ++i) {			qp->queue.page_list[i].buf =				dma_alloc_coherent(&dev->pdev->dev, PAGE_SIZE,						   &t, GFP_KERNEL);			if (!qp->queue.page_list[i].buf)				goto err_out_free;			memset(qp->queue.page_list[i].buf, 0, PAGE_SIZE);			pci_unmap_addr_set(&qp->queue.page_list[i], mapping, t);			dma_list[i] = t;		}	}	err = mthca_mr_alloc_phys(dev, pd->pd_num, dma_list, shift,				  npages, 0, size,				  MTHCA_MPT_FLAG_LOCAL_READ,				  &qp->mr);	if (err)		goto err_out_free;	kfree(dma_list);	return 0; err_out_free:	if (qp->is_direct) {		dma_free_coherent(&dev->pdev->dev, size, qp->queue.direct.buf,				  pci_unmap_addr(&qp->queue.direct, mapping));	} else		for (i = 0; i < npages; ++i) {			if (qp->queue.page_list[i].buf)				dma_free_coherent(&dev->pdev->dev, PAGE_SIZE,						  qp->queue.page_list[i].buf,						  pci_unmap_addr(&qp->queue.page_list[i],								 mapping));		} err_out:	kfree(qp->wrid);	kfree(dma_list);	return err;}
10457	/local/tlutelli/issta_data/temp/c/2005_temp/2005/10457/80c8ec2c04e539aac4e9810a46bc04c1b424b4dd/mthca_qp.c/buggy/drivers/infiniband/hw/mthca/mthca_qp.c