drivers/infiniband/hw/amso1100/c2_mm.c - kernel/panda - Git at Google

 /*
  * Copyright (c) 2005 Ammasso, Inc. All rights reserved.
  * Copyright (c) 2005 Open Grid Computing, Inc. All rights reserved.
  *
  * This software is available to you under a choice of one of two
  * licenses.  You may choose to be licensed under the terms of the GNU
  * General Public License (GPL) Version 2, available from the file
  * COPYING in the main directory of this source tree, or the
  * OpenIB.org BSD license below:
  *
  *     Redistribution and use in source and binary forms, with or
  *     without modification, are permitted provided that the following
  *     conditions are met:
  *
  *      - Redistributions of source code must retain the above
  *        copyright notice, this list of conditions and the following
  *        disclaimer.
  *
  *      - Redistributions in binary form must reproduce the above
  *        copyright notice, this list of conditions and the following
  *        disclaimer in the documentation and/or other materials
  *        provided with the distribution.
  *
  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
  * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
  * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  * SOFTWARE.
  */
 #include "c2.h"
 #include "c2_vq.h"

 #define PBL_VIRT 1
 #define PBL_PHYS 2

 /*
  * Send all the PBL messages to convey the remainder of the PBL
  * Wait for the adapter's reply on the last one.
  * This is indicated by setting the MEM_PBL_COMPLETE in the flags.
  *
  * NOTE:  vq_req is _not_ freed by this function.  The VQ Host
  *	  Reply buffer _is_ freed by this function.
  */
 static int
 send_pbl_messages(struct c2_dev *c2dev, u32 stag_index,
 		  unsigned long va, u32 pbl_depth,
 		  struct c2_vq_req *vq_req, int pbl_type)
 {
 	u32 pbe_count;		/* amt that fits in a PBL msg */
 	u32 count;		/* amt in this PBL MSG. */
 	struct c2wr_nsmr_pbl_req *wr;	/* PBL WR ptr */
 	struct c2wr_nsmr_pbl_rep *reply;	/* reply ptr */
  	int err, pbl_virt, pbl_index, i;

 	switch (pbl_type) {
 	case PBL_VIRT:
 		pbl_virt = 1;
 		break;
 	case PBL_PHYS:
 		pbl_virt = 0;
 		break;
 	default:
 		return -EINVAL;
 		break;
 	}

 	pbe_count = (c2dev->req_vq.msg_size -
 		     sizeof(struct c2wr_nsmr_pbl_req)) / sizeof(u64);
 	wr = kmalloc(c2dev->req_vq.msg_size, GFP_KERNEL);
 	if (!wr) {
 		return -ENOMEM;
 	}
 	c2_wr_set_id(wr, CCWR_NSMR_PBL);

 	/*
 	 * Only the last PBL message will generate a reply from the verbs,
 	 * so we set the context to 0 indicating there is no kernel verbs
 	 * handler blocked awaiting this reply.
 	 */
 	wr->hdr.context = 0;
 	wr->rnic_handle = c2dev->adapter_handle;
 	wr->stag_index = stag_index;	/* already swapped */
 	wr->flags = 0;
 	pbl_index = 0;
 	while (pbl_depth) {
 		count = min(pbe_count, pbl_depth);
 		wr->addrs_length = cpu_to_be32(count);

 		/*
 		 *  If this is the last message, then reference the
 		 *  vq request struct cuz we're gonna wait for a reply.
 		 *  also make this PBL msg as the last one.
 		 */
 		if (count == pbl_depth) {
 			/*
 			 * reference the request struct.  dereferenced in the
 			 * int handler.
 			 */
 			vq_req_get(c2dev, vq_req);
 			wr->flags = cpu_to_be32(MEM_PBL_COMPLETE);

 			/*
 			 * This is the last PBL message.
 			 * Set the context to our VQ Request Object so we can
 			 * wait for the reply.
 			 */
 			wr->hdr.context = (unsigned long) vq_req;
 		}

 		/*
 		 * If pbl_virt is set then va is a virtual address
 		 * that describes a virtually contiguous memory
 		 * allocation. The wr needs the start of each virtual page
 		 * to be converted to the corresponding physical address
 		 * of the page. If pbl_virt is not set then va is an array
 		 * of physical addresses and there is no conversion to do.
 		 * Just fill in the wr with what is in the array.
 		 */
 		for (i = 0; i < count; i++) {
 			if (pbl_virt) {
 				va += PAGE_SIZE;
 			} else {
  				wr->paddrs[i] =
 				    cpu_to_be64(((u64 *)va)[pbl_index + i]);
 			}
 		}

 		/*
 		 * Send WR to adapter
 		 */
 		err = vq_send_wr(c2dev, (union c2wr *) wr);
 		if (err) {
 			if (count <= pbe_count) {
 				vq_req_put(c2dev, vq_req);
 			}
 			goto bail0;
 		}
 		pbl_depth -= count;
 		pbl_index += count;
 	}

 	/*
 	 *  Now wait for the reply...
 	 */
 	err = vq_wait_for_reply(c2dev, vq_req);
 	if (err) {
 		goto bail0;
 	}

 	/*
 	 * Process reply
 	 */
 	reply = (struct c2wr_nsmr_pbl_rep *) (unsigned long) vq_req->reply_msg;
 	if (!reply) {
 		err = -ENOMEM;
 		goto bail0;
 	}

 	err = c2_errno(reply);

 	vq_repbuf_free(c2dev, reply);
       bail0:
 	kfree(wr);
 	return err;
 }

 #define C2_PBL_MAX_DEPTH 131072
 int
 c2_nsmr_register_phys_kern(struct c2_dev *c2dev, u64 *addr_list,
  			   int page_size, int pbl_depth, u32 length,
  			   u32 offset, u64 *va, enum c2_acf acf,
 			   struct c2_mr *mr)
 {
 	struct c2_vq_req *vq_req;
 	struct c2wr_nsmr_register_req *wr;
 	struct c2wr_nsmr_register_rep *reply;
 	u16 flags;
 	int i, pbe_count, count;
 	int err;

 	if (!va || !length || !addr_list || !pbl_depth)
 		return -EINTR;

 	/*
 	 * Verify PBL depth is within rnic max
 	 */
 	if (pbl_depth > C2_PBL_MAX_DEPTH) {
 		return -EINTR;
 	}

 	/*
 	 * allocate verbs request object
 	 */
 	vq_req = vq_req_alloc(c2dev);
 	if (!vq_req)
 		return -ENOMEM;

 	wr = kmalloc(c2dev->req_vq.msg_size, GFP_KERNEL);
 	if (!wr) {
 		err = -ENOMEM;
 		goto bail0;
 	}

 	/*
 	 * build the WR
 	 */
 	c2_wr_set_id(wr, CCWR_NSMR_REGISTER);
 	wr->hdr.context = (unsigned long) vq_req;
 	wr->rnic_handle = c2dev->adapter_handle;

 	flags = (acf | MEM_VA_BASED | MEM_REMOTE);

 	/*
 	 * compute how many pbes can fit in the message
 	 */
 	pbe_count = (c2dev->req_vq.msg_size -
 		     sizeof(struct c2wr_nsmr_register_req)) / sizeof(u64);

 	if (pbl_depth <= pbe_count) {
 		flags |= MEM_PBL_COMPLETE;
 	}
 	wr->flags = cpu_to_be16(flags);
 	wr->stag_key = 0;	//stag_key;
 	wr->va = cpu_to_be64(*va);
 	wr->pd_id = mr->pd->pd_id;
 	wr->pbe_size = cpu_to_be32(page_size);
 	wr->length = cpu_to_be32(length);
 	wr->pbl_depth = cpu_to_be32(pbl_depth);
 	wr->fbo = cpu_to_be32(offset);
 	count = min(pbl_depth, pbe_count);
 	wr->addrs_length = cpu_to_be32(count);

 	/*
 	 * fill out the PBL for this message
 	 */
 	for (i = 0; i < count; i++) {
 		wr->paddrs[i] = cpu_to_be64(addr_list[i]);
 	}

 	/*
 	 * regerence the request struct
 	 */
 	vq_req_get(c2dev, vq_req);

 	/*
 	 * send the WR to the adapter
 	 */
 	err = vq_send_wr(c2dev, (union c2wr *) wr);
 	if (err) {
 		vq_req_put(c2dev, vq_req);
 		goto bail1;
 	}

 	/*
 	 * wait for reply from adapter
 	 */
 	err = vq_wait_for_reply(c2dev, vq_req);
 	if (err) {
 		goto bail1;
 	}

 	/*
 	 * process reply
 	 */
 	reply =
 	    (struct c2wr_nsmr_register_rep *) (unsigned long) (vq_req->reply_msg);
 	if (!reply) {
 		err = -ENOMEM;
 		goto bail1;
 	}
 	if ((err = c2_errno(reply))) {
 		goto bail2;
 	}
 	//*p_pb_entries = be32_to_cpu(reply->pbl_depth);
 	mr->ibmr.lkey = mr->ibmr.rkey = be32_to_cpu(reply->stag_index);
 	vq_repbuf_free(c2dev, reply);

 	/*
 	 * if there are still more PBEs we need to send them to
 	 * the adapter and wait for a reply on the final one.
 	 * reuse vq_req for this purpose.
 	 */
 	pbl_depth -= count;
 	if (pbl_depth) {

 		vq_req->reply_msg = (unsigned long) NULL;
 		atomic_set(&vq_req->reply_ready, 0);
 		err = send_pbl_messages(c2dev,
 					cpu_to_be32(mr->ibmr.lkey),
 					(unsigned long) &addr_list[i],
 					pbl_depth, vq_req, PBL_PHYS);
 		if (err) {
 			goto bail1;
 		}
 	}

 	vq_req_free(c2dev, vq_req);
 	kfree(wr);

 	return err;

       bail2:
 	vq_repbuf_free(c2dev, reply);
       bail1:
 	kfree(wr);
       bail0:
 	vq_req_free(c2dev, vq_req);
 	return err;
 }

 int c2_stag_dealloc(struct c2_dev *c2dev, u32 stag_index)
 {
 	struct c2_vq_req *vq_req;	/* verbs request object */
 	struct c2wr_stag_dealloc_req wr;	/* work request */
 	struct c2wr_stag_dealloc_rep *reply;	/* WR reply  */
 	int err;


 	/*
 	 * allocate verbs request object
 	 */
 	vq_req = vq_req_alloc(c2dev);
 	if (!vq_req) {
 		return -ENOMEM;
 	}

 	/*
 	 * Build the WR
 	 */
 	c2_wr_set_id(&wr, CCWR_STAG_DEALLOC);
 	wr.hdr.context = (u64) (unsigned long) vq_req;
 	wr.rnic_handle = c2dev->adapter_handle;
 	wr.stag_index = cpu_to_be32(stag_index);

 	/*
 	 * reference the request struct.  dereferenced in the int handler.
 	 */
 	vq_req_get(c2dev, vq_req);

 	/*
 	 * Send WR to adapter
 	 */
 	err = vq_send_wr(c2dev, (union c2wr *) & wr);
 	if (err) {
 		vq_req_put(c2dev, vq_req);
 		goto bail0;
 	}

 	/*
 	 * Wait for reply from adapter
 	 */
 	err = vq_wait_for_reply(c2dev, vq_req);
 	if (err) {
 		goto bail0;
 	}

 	/*
 	 * Process reply
 	 */
 	reply = (struct c2wr_stag_dealloc_rep *) (unsigned long) vq_req->reply_msg;
 	if (!reply) {
 		err = -ENOMEM;
 		goto bail0;
 	}

 	err = c2_errno(reply);

 	vq_repbuf_free(c2dev, reply);
       bail0:
 	vq_req_free(c2dev, vq_req);
 	return err;
 }
	/*
	* Copyright (c) 2005 Ammasso, Inc. All rights reserved.
	* Copyright (c) 2005 Open Grid Computing, Inc. All rights reserved.
	*
	* This software is available to you under a choice of one of two
	* licenses. You may choose to be licensed under the terms of the GNU
	* General Public License (GPL) Version 2, available from the file
	* COPYING in the main directory of this source tree, or the
	* OpenIB.org BSD license below:
	*
	* Redistribution and use in source and binary forms, with or
	* without modification, are permitted provided that the following
	* conditions are met:
	*
	* - Redistributions of source code must retain the above
	* copyright notice, this list of conditions and the following
	* disclaimer.
	*
	* - Redistributions in binary form must reproduce the above
	* copyright notice, this list of conditions and the following
	* disclaimer in the documentation and/or other materials
	* provided with the distribution.
	*
	* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
	* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
	* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
	* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
	* BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
	* ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
	* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
	* SOFTWARE.
	*/
	#include "c2.h"
	#include "c2_vq.h"

	#define PBL_VIRT 1
	#define PBL_PHYS 2

	/*
	* Send all the PBL messages to convey the remainder of the PBL
	* Wait for the adapter's reply on the last one.
	* This is indicated by setting the MEM_PBL_COMPLETE in the flags.
	*
	* NOTE: vq_req is _not_ freed by this function. The VQ Host
	* Reply buffer _is_ freed by this function.
	*/
	static int
	send_pbl_messages(struct c2_dev *c2dev, u32 stag_index,
	unsigned long va, u32 pbl_depth,
	struct c2_vq_req *vq_req, int pbl_type)
	{
	u32 pbe_count; /* amt that fits in a PBL msg */
	u32 count; /* amt in this PBL MSG. */
	struct c2wr_nsmr_pbl_req wr; / PBL WR ptr */
	struct c2wr_nsmr_pbl_rep reply; / reply ptr */
	int err, pbl_virt, pbl_index, i;

	switch (pbl_type) {
	case PBL_VIRT:
	pbl_virt = 1;
	break;
	case PBL_PHYS:
	pbl_virt = 0;
	break;
	default:
	return -EINVAL;
	break;
	}

	pbe_count = (c2dev->req_vq.msg_size -
	sizeof(struct c2wr_nsmr_pbl_req)) / sizeof(u64);
	wr = kmalloc(c2dev->req_vq.msg_size, GFP_KERNEL);
	if (!wr) {
	return -ENOMEM;
	}
	c2_wr_set_id(wr, CCWR_NSMR_PBL);

	/*
	* Only the last PBL message will generate a reply from the verbs,
	* so we set the context to 0 indicating there is no kernel verbs
	* handler blocked awaiting this reply.
	*/
	wr->hdr.context = 0;
	wr->rnic_handle = c2dev->adapter_handle;
	wr->stag_index = stag_index; /* already swapped */
	wr->flags = 0;
	pbl_index = 0;
	while (pbl_depth) {
	count = min(pbe_count, pbl_depth);
	wr->addrs_length = cpu_to_be32(count);

	/*
	* If this is the last message, then reference the
	* vq request struct cuz we're gonna wait for a reply.
	* also make this PBL msg as the last one.
	*/
	if (count == pbl_depth) {
	/*
	* reference the request struct. dereferenced in the
	* int handler.
	*/
	vq_req_get(c2dev, vq_req);
	wr->flags = cpu_to_be32(MEM_PBL_COMPLETE);

	/*
	* This is the last PBL message.
	* Set the context to our VQ Request Object so we can
	* wait for the reply.
	*/
	wr->hdr.context = (unsigned long) vq_req;
	}

	/*
	* If pbl_virt is set then va is a virtual address
	* that describes a virtually contiguous memory
	* allocation. The wr needs the start of each virtual page
	* to be converted to the corresponding physical address
	* of the page. If pbl_virt is not set then va is an array
	* of physical addresses and there is no conversion to do.
	* Just fill in the wr with what is in the array.
	*/
	for (i = 0; i < count; i++) {
	if (pbl_virt) {
	va += PAGE_SIZE;
	} else {
	wr->paddrs[i] =
	cpu_to_be64(((u64 *)va)[pbl_index + i]);
	}
	}

	/*
	* Send WR to adapter
	*/
	err = vq_send_wr(c2dev, (union c2wr *) wr);
	if (err) {
	if (count <= pbe_count) {
	vq_req_put(c2dev, vq_req);
	}
	goto bail0;
	}
	pbl_depth -= count;
	pbl_index += count;
	}

	/*
	* Now wait for the reply...
	*/
	err = vq_wait_for_reply(c2dev, vq_req);
	if (err) {
	goto bail0;
	}

	/*
	* Process reply
	*/
	reply = (struct c2wr_nsmr_pbl_rep *) (unsigned long) vq_req->reply_msg;
	if (!reply) {
	err = -ENOMEM;
	goto bail0;
	}

	err = c2_errno(reply);

	vq_repbuf_free(c2dev, reply);
	bail0:
	kfree(wr);
	return err;
	}

	#define C2_PBL_MAX_DEPTH 131072
	int
	c2_nsmr_register_phys_kern(struct c2_dev c2dev, u64 addr_list,
	int page_size, int pbl_depth, u32 length,
	u32 offset, u64 *va, enum c2_acf acf,
	struct c2_mr *mr)
	{
	struct c2_vq_req *vq_req;
	struct c2wr_nsmr_register_req *wr;
	struct c2wr_nsmr_register_rep *reply;
	u16 flags;
	int i, pbe_count, count;
	int err;

	if (!va \|\| !length \|\| !addr_list \|\| !pbl_depth)
	return -EINTR;

	/*
	* Verify PBL depth is within rnic max
	*/
	if (pbl_depth > C2_PBL_MAX_DEPTH) {
	return -EINTR;
	}

	/*
	* allocate verbs request object
	*/
	vq_req = vq_req_alloc(c2dev);
	if (!vq_req)
	return -ENOMEM;

	wr = kmalloc(c2dev->req_vq.msg_size, GFP_KERNEL);
	if (!wr) {
	err = -ENOMEM;
	goto bail0;
	}

	/*
	* build the WR
	*/
	c2_wr_set_id(wr, CCWR_NSMR_REGISTER);
	wr->hdr.context = (unsigned long) vq_req;
	wr->rnic_handle = c2dev->adapter_handle;

	flags = (acf \| MEM_VA_BASED \| MEM_REMOTE);

	/*
	* compute how many pbes can fit in the message
	*/
	pbe_count = (c2dev->req_vq.msg_size -
	sizeof(struct c2wr_nsmr_register_req)) / sizeof(u64);

	if (pbl_depth <= pbe_count) {
	flags \|= MEM_PBL_COMPLETE;
	}
	wr->flags = cpu_to_be16(flags);
	wr->stag_key = 0; //stag_key;
	wr->va = cpu_to_be64(*va);
	wr->pd_id = mr->pd->pd_id;
	wr->pbe_size = cpu_to_be32(page_size);
	wr->length = cpu_to_be32(length);
	wr->pbl_depth = cpu_to_be32(pbl_depth);
	wr->fbo = cpu_to_be32(offset);
	count = min(pbl_depth, pbe_count);
	wr->addrs_length = cpu_to_be32(count);

	/*
	* fill out the PBL for this message
	*/
	for (i = 0; i < count; i++) {
	wr->paddrs[i] = cpu_to_be64(addr_list[i]);
	}

	/*
	* regerence the request struct
	*/
	vq_req_get(c2dev, vq_req);

	/*
	* send the WR to the adapter
	*/
	err = vq_send_wr(c2dev, (union c2wr *) wr);
	if (err) {
	vq_req_put(c2dev, vq_req);
	goto bail1;
	}

	/*
	* wait for reply from adapter
	*/
	err = vq_wait_for_reply(c2dev, vq_req);
	if (err) {
	goto bail1;
	}

	/*
	* process reply
	*/
	reply =
	(struct c2wr_nsmr_register_rep *) (unsigned long) (vq_req->reply_msg);
	if (!reply) {
	err = -ENOMEM;
	goto bail1;
	}
	if ((err = c2_errno(reply))) {
	goto bail2;
	}
	//*p_pb_entries = be32_to_cpu(reply->pbl_depth);
	mr->ibmr.lkey = mr->ibmr.rkey = be32_to_cpu(reply->stag_index);
	vq_repbuf_free(c2dev, reply);

	/*
	* if there are still more PBEs we need to send them to
	* the adapter and wait for a reply on the final one.
	* reuse vq_req for this purpose.
	*/
	pbl_depth -= count;
	if (pbl_depth) {

	vq_req->reply_msg = (unsigned long) NULL;
	atomic_set(&vq_req->reply_ready, 0);
	err = send_pbl_messages(c2dev,
	cpu_to_be32(mr->ibmr.lkey),
	(unsigned long) &addr_list[i],
	pbl_depth, vq_req, PBL_PHYS);
	if (err) {
	goto bail1;
	}
	}

	vq_req_free(c2dev, vq_req);
	kfree(wr);

	return err;

	bail2:
	vq_repbuf_free(c2dev, reply);
	bail1:
	kfree(wr);
	bail0:
	vq_req_free(c2dev, vq_req);
	return err;
	}

	int c2_stag_dealloc(struct c2_dev *c2dev, u32 stag_index)
	{
	struct c2_vq_req vq_req; / verbs request object */
	struct c2wr_stag_dealloc_req wr; /* work request */
	struct c2wr_stag_dealloc_rep reply; / WR reply */
	int err;


	/*
	* allocate verbs request object
	*/
	vq_req = vq_req_alloc(c2dev);
	if (!vq_req) {
	return -ENOMEM;
	}

	/*
	* Build the WR
	*/
	c2_wr_set_id(&wr, CCWR_STAG_DEALLOC);
	wr.hdr.context = (u64) (unsigned long) vq_req;
	wr.rnic_handle = c2dev->adapter_handle;
	wr.stag_index = cpu_to_be32(stag_index);

	/*
	* reference the request struct. dereferenced in the int handler.
	*/
	vq_req_get(c2dev, vq_req);

	/*
	* Send WR to adapter
	*/
	err = vq_send_wr(c2dev, (union c2wr *) & wr);
	if (err) {
	vq_req_put(c2dev, vq_req);
	goto bail0;
	}

	/*
	* Wait for reply from adapter
	*/
	err = vq_wait_for_reply(c2dev, vq_req);
	if (err) {
	goto bail0;
	}

	/*
	* Process reply
	*/
	reply = (struct c2wr_stag_dealloc_rep *) (unsigned long) vq_req->reply_msg;
	if (!reply) {
	err = -ENOMEM;
	goto bail0;
	}

	err = c2_errno(reply);

	vq_repbuf_free(c2dev, reply);
	bail0:
	vq_req_free(c2dev, vq_req);
	return err;
	}