1/* 2 * Copyright (c) 2006 - 2009 Intel Corporation. All rights reserved. 3 * 4 * This software is available to you under a choice of one of two 5 * licenses. You may choose to be licensed under the terms of the GNU 6 * General Public License (GPL) Version 2, available from the file 7 * COPYING in the main directory of this source tree, or the 8 * OpenIB.org BSD license below: 9 * 10 * Redistribution and use in source and binary forms, with or 11 * without modification, are permitted provided that the following 12 * conditions are met: 13 * 14 * - Redistributions of source code must retain the above 15 * copyright notice, this list of conditions and the following 16 * disclaimer. 17 * 18 * - Redistributions in binary form must reproduce the above 19 * copyright notice, this list of conditions and the following 20 * disclaimer in the documentation and/or other materials 21 * provided with the distribution. 22 * 23 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, 24 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF 25 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND 26 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS 27 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN 28 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN 29 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE 30 * SOFTWARE. 31 * 32 */ 33 34#include <linux/module.h> 35#include <linux/moduleparam.h> 36#include <linux/random.h> 37#include <linux/highmem.h> 38#include <linux/slab.h> 39#include <asm/byteorder.h> 40 41#include <rdma/ib_verbs.h> 42#include <rdma/iw_cm.h> 43#include <rdma/ib_user_verbs.h> 44 45#include "nes.h" 46 47#include <rdma/ib_umem.h> 48 49atomic_t mod_qp_timouts; 50atomic_t qps_created; 51atomic_t sw_qps_destroyed; 52 53static void nes_unregister_ofa_device(struct nes_ib_device *nesibdev); 54 55/** 56 * nes_alloc_mw 57 */ 58static struct ib_mw *nes_alloc_mw(struct ib_pd *ibpd) { 59 struct nes_pd *nespd = to_nespd(ibpd); 60 struct nes_vnic *nesvnic = to_nesvnic(ibpd->device); 61 struct nes_device *nesdev = nesvnic->nesdev; 62 struct nes_adapter *nesadapter = nesdev->nesadapter; 63 struct nes_cqp_request *cqp_request; 64 struct nes_mr *nesmr; 65 struct ib_mw *ibmw; 66 struct nes_hw_cqp_wqe *cqp_wqe; 67 int ret; 68 u32 stag; 69 u32 stag_index = 0; 70 u32 next_stag_index = 0; 71 u32 driver_key = 0; 72 u8 stag_key = 0; 73 74 get_random_bytes(&next_stag_index, sizeof(next_stag_index)); 75 stag_key = (u8)next_stag_index; 76 77 driver_key = 0; 78 79 next_stag_index >>= 8; 80 next_stag_index %= nesadapter->max_mr; 81 82 ret = nes_alloc_resource(nesadapter, nesadapter->allocated_mrs, 83 nesadapter->max_mr, &stag_index, &next_stag_index); 84 if (ret) { 85 return ERR_PTR(ret); 86 } 87 88 nesmr = kzalloc(sizeof(*nesmr), GFP_KERNEL); 89 if (!nesmr) { 90 nes_free_resource(nesadapter, nesadapter->allocated_mrs, stag_index); 91 return ERR_PTR(-ENOMEM); 92 } 93 94 stag = stag_index << 8; 95 stag |= driver_key; 96 stag += (u32)stag_key; 97 98 nes_debug(NES_DBG_MR, "Registering STag 0x%08X, index = 0x%08X\n", 99 stag, stag_index); 100 101 /* Register the region with the adapter */ 102 cqp_request = nes_get_cqp_request(nesdev); 103 if (cqp_request == NULL) { 104 kfree(nesmr); 105 nes_free_resource(nesadapter, nesadapter->allocated_mrs, stag_index); 106 return ERR_PTR(-ENOMEM); 107 } 108 109 cqp_request->waiting = 1; 110 cqp_wqe = &cqp_request->cqp_wqe; 111 112 cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] = 113 cpu_to_le32( NES_CQP_ALLOCATE_STAG | NES_CQP_STAG_RIGHTS_REMOTE_READ | 114 NES_CQP_STAG_RIGHTS_REMOTE_WRITE | NES_CQP_STAG_VA_TO | 115 NES_CQP_STAG_REM_ACC_EN); 116 117 nes_fill_init_cqp_wqe(cqp_wqe, nesdev); 118 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_LEN_HIGH_PD_IDX, (nespd->pd_id & 0x00007fff)); 119 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_STAG_IDX, stag); 120 121 atomic_set(&cqp_request->refcount, 2); 122 nes_post_cqp_request(nesdev, cqp_request); 123 124 /* Wait for CQP */ 125 ret = wait_event_timeout(cqp_request->waitq, (cqp_request->request_done != 0), 126 NES_EVENT_TIMEOUT); 127 nes_debug(NES_DBG_MR, "Register STag 0x%08X completed, wait_event_timeout ret = %u," 128 " CQP Major:Minor codes = 0x%04X:0x%04X.\n", 129 stag, ret, cqp_request->major_code, cqp_request->minor_code); 130 if ((!ret) || (cqp_request->major_code)) { 131 nes_put_cqp_request(nesdev, cqp_request); 132 kfree(nesmr); 133 nes_free_resource(nesadapter, nesadapter->allocated_mrs, stag_index); 134 if (!ret) { 135 return ERR_PTR(-ETIME); 136 } else { 137 return ERR_PTR(-ENOMEM); 138 } 139 } 140 nes_put_cqp_request(nesdev, cqp_request); 141 142 nesmr->ibmw.rkey = stag; 143 nesmr->mode = IWNES_MEMREG_TYPE_MW; 144 ibmw = &nesmr->ibmw; 145 nesmr->pbl_4k = 0; 146 nesmr->pbls_used = 0; 147 148 return ibmw; 149} 150 151 152/** 153 * nes_dealloc_mw 154 */ 155static int nes_dealloc_mw(struct ib_mw *ibmw) 156{ 157 struct nes_mr *nesmr = to_nesmw(ibmw); 158 struct nes_vnic *nesvnic = to_nesvnic(ibmw->device); 159 struct nes_device *nesdev = nesvnic->nesdev; 160 struct nes_adapter *nesadapter = nesdev->nesadapter; 161 struct nes_hw_cqp_wqe *cqp_wqe; 162 struct nes_cqp_request *cqp_request; 163 int err = 0; 164 int ret; 165 166 /* Deallocate the window with the adapter */ 167 cqp_request = nes_get_cqp_request(nesdev); 168 if (cqp_request == NULL) { 169 nes_debug(NES_DBG_MR, "Failed to get a cqp_request.\n"); 170 return -ENOMEM; 171 } 172 cqp_request->waiting = 1; 173 cqp_wqe = &cqp_request->cqp_wqe; 174 nes_fill_init_cqp_wqe(cqp_wqe, nesdev); 175 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX, NES_CQP_DEALLOCATE_STAG); 176 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_STAG_IDX, ibmw->rkey); 177 178 atomic_set(&cqp_request->refcount, 2); 179 nes_post_cqp_request(nesdev, cqp_request); 180 181 /* Wait for CQP */ 182 nes_debug(NES_DBG_MR, "Waiting for deallocate STag 0x%08X to complete.\n", 183 ibmw->rkey); 184 ret = wait_event_timeout(cqp_request->waitq, (0 != cqp_request->request_done), 185 NES_EVENT_TIMEOUT); 186 nes_debug(NES_DBG_MR, "Deallocate STag completed, wait_event_timeout ret = %u," 187 " CQP Major:Minor codes = 0x%04X:0x%04X.\n", 188 ret, cqp_request->major_code, cqp_request->minor_code); 189 if (!ret) 190 err = -ETIME; 191 else if (cqp_request->major_code) 192 err = -EIO; 193 194 nes_put_cqp_request(nesdev, cqp_request); 195 196 nes_free_resource(nesadapter, nesadapter->allocated_mrs, 197 (ibmw->rkey & 0x0fffff00) >> 8); 198 kfree(nesmr); 199 200 return err; 201} 202 203 204/** 205 * nes_bind_mw 206 */ 207static int nes_bind_mw(struct ib_qp *ibqp, struct ib_mw *ibmw, 208 struct ib_mw_bind *ibmw_bind) 209{ 210 u64 u64temp; 211 struct nes_vnic *nesvnic = to_nesvnic(ibqp->device); 212 struct nes_device *nesdev = nesvnic->nesdev; 213 /* struct nes_mr *nesmr = to_nesmw(ibmw); */ 214 struct nes_qp *nesqp = to_nesqp(ibqp); 215 struct nes_hw_qp_wqe *wqe; 216 unsigned long flags = 0; 217 u32 head; 218 u32 wqe_misc = 0; 219 u32 qsize; 220 221 if (nesqp->ibqp_state > IB_QPS_RTS) 222 return -EINVAL; 223 224 spin_lock_irqsave(&nesqp->lock, flags); 225 226 head = nesqp->hwqp.sq_head; 227 qsize = nesqp->hwqp.sq_tail; 228 229 /* Check for SQ overflow */ 230 if (((head + (2 * qsize) - nesqp->hwqp.sq_tail) % qsize) == (qsize - 1)) { 231 spin_unlock_irqrestore(&nesqp->lock, flags); 232 return -ENOMEM; 233 } 234 235 wqe = &nesqp->hwqp.sq_vbase[head]; 236 /* nes_debug(NES_DBG_MR, "processing sq wqe at %p, head = %u.\n", wqe, head); */ 237 nes_fill_init_qp_wqe(wqe, nesqp, head); 238 u64temp = ibmw_bind->wr_id; 239 set_wqe_64bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_COMP_SCRATCH_LOW_IDX, u64temp); 240 wqe_misc = NES_IWARP_SQ_OP_BIND; 241 242 wqe_misc |= NES_IWARP_SQ_WQE_LOCAL_FENCE; 243 244 if (ibmw_bind->send_flags & IB_SEND_SIGNALED) 245 wqe_misc |= NES_IWARP_SQ_WQE_SIGNALED_COMPL; 246 247 if (ibmw_bind->mw_access_flags & IB_ACCESS_REMOTE_WRITE) { 248 wqe_misc |= NES_CQP_STAG_RIGHTS_REMOTE_WRITE; 249 } 250 if (ibmw_bind->mw_access_flags & IB_ACCESS_REMOTE_READ) { 251 wqe_misc |= NES_CQP_STAG_RIGHTS_REMOTE_READ; 252 } 253 254 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_MISC_IDX, wqe_misc); 255 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_BIND_WQE_MR_IDX, ibmw_bind->mr->lkey); 256 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_BIND_WQE_MW_IDX, ibmw->rkey); 257 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_BIND_WQE_LENGTH_LOW_IDX, 258 ibmw_bind->length); 259 wqe->wqe_words[NES_IWARP_SQ_BIND_WQE_LENGTH_HIGH_IDX] = 0; 260 u64temp = (u64)ibmw_bind->addr; 261 set_wqe_64bit_value(wqe->wqe_words, NES_IWARP_SQ_BIND_WQE_VA_FBO_LOW_IDX, u64temp); 262 263 head++; 264 if (head >= qsize) 265 head = 0; 266 267 nesqp->hwqp.sq_head = head; 268 barrier(); 269 270 nes_write32(nesdev->regs+NES_WQE_ALLOC, 271 (1 << 24) | 0x00800000 | nesqp->hwqp.qp_id); 272 273 spin_unlock_irqrestore(&nesqp->lock, flags); 274 275 return 0; 276} 277 278 279/* 280 * nes_alloc_fast_mr 281 */ 282static int alloc_fast_reg_mr(struct nes_device *nesdev, struct nes_pd *nespd, 283 u32 stag, u32 page_count) 284{ 285 struct nes_hw_cqp_wqe *cqp_wqe; 286 struct nes_cqp_request *cqp_request; 287 unsigned long flags; 288 int ret; 289 struct nes_adapter *nesadapter = nesdev->nesadapter; 290 u32 opcode = 0; 291 u16 major_code; 292 u64 region_length = page_count * PAGE_SIZE; 293 294 295 cqp_request = nes_get_cqp_request(nesdev); 296 if (cqp_request == NULL) { 297 nes_debug(NES_DBG_MR, "Failed to get a cqp_request.\n"); 298 return -ENOMEM; 299 } 300 nes_debug(NES_DBG_MR, "alloc_fast_reg_mr: page_count = %d, " 301 "region_length = %llu\n", 302 page_count, region_length); 303 cqp_request->waiting = 1; 304 cqp_wqe = &cqp_request->cqp_wqe; 305 306 spin_lock_irqsave(&nesadapter->pbl_lock, flags); 307 if (nesadapter->free_4kpbl > 0) { 308 nesadapter->free_4kpbl--; 309 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 310 } else { 311 /* No 4kpbl's available: */ 312 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 313 nes_debug(NES_DBG_MR, "Out of Pbls\n"); 314 nes_free_cqp_request(nesdev, cqp_request); 315 return -ENOMEM; 316 } 317 318 opcode = NES_CQP_ALLOCATE_STAG | NES_CQP_STAG_MR | 319 NES_CQP_STAG_PBL_BLK_SIZE | NES_CQP_STAG_VA_TO | 320 NES_CQP_STAG_REM_ACC_EN; 321 /* 322 * The current OFED API does not support the zero based TO option. 323 * If added then need to changed the NES_CQP_STAG_VA* option. Also, 324 * the API does not support that ability to have the MR set for local 325 * access only when created and not allow the SQ op to override. Given 326 * this the remote enable must be set here. 327 */ 328 329 nes_fill_init_cqp_wqe(cqp_wqe, nesdev); 330 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX, opcode); 331 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_PBL_BLK_COUNT_IDX, 1); 332 333 cqp_wqe->wqe_words[NES_CQP_STAG_WQE_LEN_HIGH_PD_IDX] = 334 cpu_to_le32((u32)(region_length >> 8) & 0xff000000); 335 cqp_wqe->wqe_words[NES_CQP_STAG_WQE_LEN_HIGH_PD_IDX] |= 336 cpu_to_le32(nespd->pd_id & 0x00007fff); 337 338 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_STAG_IDX, stag); 339 set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_VA_LOW_IDX, 0); 340 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_LEN_LOW_IDX, 0); 341 set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_PA_LOW_IDX, 0); 342 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_PBL_LEN_IDX, (page_count * 8)); 343 cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] |= cpu_to_le32(NES_CQP_STAG_PBL_BLK_SIZE); 344 barrier(); 345 346 atomic_set(&cqp_request->refcount, 2); 347 nes_post_cqp_request(nesdev, cqp_request); 348 349 /* Wait for CQP */ 350 ret = wait_event_timeout(cqp_request->waitq, 351 (0 != cqp_request->request_done), 352 NES_EVENT_TIMEOUT); 353 354 nes_debug(NES_DBG_MR, "Allocate STag 0x%08X completed, " 355 "wait_event_timeout ret = %u, CQP Major:Minor codes = " 356 "0x%04X:0x%04X.\n", stag, ret, cqp_request->major_code, 357 cqp_request->minor_code); 358 major_code = cqp_request->major_code; 359 nes_put_cqp_request(nesdev, cqp_request); 360 361 if (!ret || major_code) { 362 spin_lock_irqsave(&nesadapter->pbl_lock, flags); 363 nesadapter->free_4kpbl++; 364 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 365 } 366 367 if (!ret) 368 return -ETIME; 369 else if (major_code) 370 return -EIO; 371 return 0; 372} 373 374/* 375 * nes_alloc_fast_reg_mr 376 */ 377static struct ib_mr *nes_alloc_fast_reg_mr(struct ib_pd *ibpd, int max_page_list_len) 378{ 379 struct nes_pd *nespd = to_nespd(ibpd); 380 struct nes_vnic *nesvnic = to_nesvnic(ibpd->device); 381 struct nes_device *nesdev = nesvnic->nesdev; 382 struct nes_adapter *nesadapter = nesdev->nesadapter; 383 384 u32 next_stag_index; 385 u8 stag_key = 0; 386 u32 driver_key = 0; 387 int err = 0; 388 u32 stag_index = 0; 389 struct nes_mr *nesmr; 390 u32 stag; 391 int ret; 392 struct ib_mr *ibmr; 393/* 394 * Note: Set to always use a fixed length single page entry PBL. This is to allow 395 * for the fast_reg_mr operation to always know the size of the PBL. 396 */ 397 if (max_page_list_len > (NES_4K_PBL_CHUNK_SIZE / sizeof(u64))) 398 return ERR_PTR(-E2BIG); 399 400 get_random_bytes(&next_stag_index, sizeof(next_stag_index)); 401 stag_key = (u8)next_stag_index; 402 next_stag_index >>= 8; 403 next_stag_index %= nesadapter->max_mr; 404 405 err = nes_alloc_resource(nesadapter, nesadapter->allocated_mrs, 406 nesadapter->max_mr, &stag_index, 407 &next_stag_index); 408 if (err) 409 return ERR_PTR(err); 410 411 nesmr = kzalloc(sizeof(*nesmr), GFP_KERNEL); 412 if (!nesmr) { 413 nes_free_resource(nesadapter, nesadapter->allocated_mrs, stag_index); 414 return ERR_PTR(-ENOMEM); 415 } 416 417 stag = stag_index << 8; 418 stag |= driver_key; 419 stag += (u32)stag_key; 420 421 nes_debug(NES_DBG_MR, "Allocating STag 0x%08X index = 0x%08X\n", 422 stag, stag_index); 423 424 ret = alloc_fast_reg_mr(nesdev, nespd, stag, max_page_list_len); 425 426 if (ret == 0) { 427 nesmr->ibmr.rkey = stag; 428 nesmr->ibmr.lkey = stag; 429 nesmr->mode = IWNES_MEMREG_TYPE_FMEM; 430 ibmr = &nesmr->ibmr; 431 } else { 432 kfree(nesmr); 433 nes_free_resource(nesadapter, nesadapter->allocated_mrs, stag_index); 434 ibmr = ERR_PTR(-ENOMEM); 435 } 436 return ibmr; 437} 438 439/* 440 * nes_alloc_fast_reg_page_list 441 */ 442static struct ib_fast_reg_page_list *nes_alloc_fast_reg_page_list( 443 struct ib_device *ibdev, 444 int page_list_len) 445{ 446 struct nes_vnic *nesvnic = to_nesvnic(ibdev); 447 struct nes_device *nesdev = nesvnic->nesdev; 448 struct ib_fast_reg_page_list *pifrpl; 449 struct nes_ib_fast_reg_page_list *pnesfrpl; 450 451 if (page_list_len > (NES_4K_PBL_CHUNK_SIZE / sizeof(u64))) 452 return ERR_PTR(-E2BIG); 453 /* 454 * Allocate the ib_fast_reg_page_list structure, the 455 * nes_fast_bpl structure, and the PLB table. 456 */ 457 pnesfrpl = kmalloc(sizeof(struct nes_ib_fast_reg_page_list) + 458 page_list_len * sizeof(u64), GFP_KERNEL); 459 460 if (!pnesfrpl) 461 return ERR_PTR(-ENOMEM); 462 463 pifrpl = &pnesfrpl->ibfrpl; 464 pifrpl->page_list = &pnesfrpl->pbl; 465 pifrpl->max_page_list_len = page_list_len; 466 /* 467 * Allocate the WQE PBL 468 */ 469 pnesfrpl->nes_wqe_pbl.kva = pci_alloc_consistent(nesdev->pcidev, 470 page_list_len * sizeof(u64), 471 &pnesfrpl->nes_wqe_pbl.paddr); 472 473 if (!pnesfrpl->nes_wqe_pbl.kva) { 474 kfree(pnesfrpl); 475 return ERR_PTR(-ENOMEM); 476 } 477 nes_debug(NES_DBG_MR, "nes_alloc_fast_reg_pbl: nes_frpl = %p, " 478 "ibfrpl = %p, ibfrpl.page_list = %p, pbl.kva = %p, " 479 "pbl.paddr= %p\n", pnesfrpl, &pnesfrpl->ibfrpl, 480 pnesfrpl->ibfrpl.page_list, pnesfrpl->nes_wqe_pbl.kva, 481 (void *)pnesfrpl->nes_wqe_pbl.paddr); 482 483 return pifrpl; 484} 485 486/* 487 * nes_free_fast_reg_page_list 488 */ 489static void nes_free_fast_reg_page_list(struct ib_fast_reg_page_list *pifrpl) 490{ 491 struct nes_vnic *nesvnic = to_nesvnic(pifrpl->device); 492 struct nes_device *nesdev = nesvnic->nesdev; 493 struct nes_ib_fast_reg_page_list *pnesfrpl; 494 495 pnesfrpl = container_of(pifrpl, struct nes_ib_fast_reg_page_list, ibfrpl); 496 /* 497 * Free the WQE PBL. 498 */ 499 pci_free_consistent(nesdev->pcidev, 500 pifrpl->max_page_list_len * sizeof(u64), 501 pnesfrpl->nes_wqe_pbl.kva, 502 pnesfrpl->nes_wqe_pbl.paddr); 503 /* 504 * Free the PBL structure 505 */ 506 kfree(pnesfrpl); 507} 508 509/** 510 * nes_query_device 511 */ 512static int nes_query_device(struct ib_device *ibdev, struct ib_device_attr *props) 513{ 514 struct nes_vnic *nesvnic = to_nesvnic(ibdev); 515 struct nes_device *nesdev = nesvnic->nesdev; 516 struct nes_ib_device *nesibdev = nesvnic->nesibdev; 517 518 memset(props, 0, sizeof(*props)); 519 memcpy(&props->sys_image_guid, nesvnic->netdev->dev_addr, 6); 520 521 props->fw_ver = nesdev->nesadapter->firmware_version; 522 props->device_cap_flags = nesdev->nesadapter->device_cap_flags; 523 props->vendor_id = nesdev->nesadapter->vendor_id; 524 props->vendor_part_id = nesdev->nesadapter->vendor_part_id; 525 props->hw_ver = nesdev->nesadapter->hw_rev; 526 props->max_mr_size = 0x80000000; 527 props->max_qp = nesibdev->max_qp; 528 props->max_qp_wr = nesdev->nesadapter->max_qp_wr - 2; 529 props->max_sge = nesdev->nesadapter->max_sge; 530 props->max_cq = nesibdev->max_cq; 531 props->max_cqe = nesdev->nesadapter->max_cqe; 532 props->max_mr = nesibdev->max_mr; 533 props->max_mw = nesibdev->max_mr; 534 props->max_pd = nesibdev->max_pd; 535 props->max_sge_rd = 1; 536 switch (nesdev->nesadapter->max_irrq_wr) { 537 case 0: 538 props->max_qp_rd_atom = 2; 539 break; 540 case 1: 541 props->max_qp_rd_atom = 8; 542 break; 543 case 2: 544 props->max_qp_rd_atom = 32; 545 break; 546 case 3: 547 props->max_qp_rd_atom = 64; 548 break; 549 default: 550 props->max_qp_rd_atom = 0; 551 } 552 props->max_qp_init_rd_atom = props->max_qp_rd_atom; 553 props->atomic_cap = IB_ATOMIC_NONE; 554 props->max_map_per_fmr = 1; 555 556 return 0; 557} 558 559 560/** 561 * nes_query_port 562 */ 563static int nes_query_port(struct ib_device *ibdev, u8 port, struct ib_port_attr *props) 564{ 565 struct nes_vnic *nesvnic = to_nesvnic(ibdev); 566 struct net_device *netdev = nesvnic->netdev; 567 568 memset(props, 0, sizeof(*props)); 569 570 props->max_mtu = IB_MTU_4096; 571 572 if (netdev->mtu >= 4096) 573 props->active_mtu = IB_MTU_4096; 574 else if (netdev->mtu >= 2048) 575 props->active_mtu = IB_MTU_2048; 576 else if (netdev->mtu >= 1024) 577 props->active_mtu = IB_MTU_1024; 578 else if (netdev->mtu >= 512) 579 props->active_mtu = IB_MTU_512; 580 else 581 props->active_mtu = IB_MTU_256; 582 583 props->lid = 1; 584 props->lmc = 0; 585 props->sm_lid = 0; 586 props->sm_sl = 0; 587 if (nesvnic->linkup) 588 props->state = IB_PORT_ACTIVE; 589 else 590 props->state = IB_PORT_DOWN; 591 props->phys_state = 0; 592 props->port_cap_flags = IB_PORT_CM_SUP | IB_PORT_REINIT_SUP | 593 IB_PORT_VENDOR_CLASS_SUP | IB_PORT_BOOT_MGMT_SUP; 594 props->gid_tbl_len = 1; 595 props->pkey_tbl_len = 1; 596 props->qkey_viol_cntr = 0; 597 props->active_width = IB_WIDTH_4X; 598 props->active_speed = 1; 599 props->max_msg_sz = 0x80000000; 600 601 return 0; 602} 603 604 605/** 606 * nes_modify_port 607 */ 608static int nes_modify_port(struct ib_device *ibdev, u8 port, 609 int port_modify_mask, struct ib_port_modify *props) 610{ 611 return 0; 612} 613 614 615/** 616 * nes_query_pkey 617 */ 618static int nes_query_pkey(struct ib_device *ibdev, u8 port, u16 index, u16 *pkey) 619{ 620 *pkey = 0; 621 return 0; 622} 623 624 625/** 626 * nes_query_gid 627 */ 628static int nes_query_gid(struct ib_device *ibdev, u8 port, 629 int index, union ib_gid *gid) 630{ 631 struct nes_vnic *nesvnic = to_nesvnic(ibdev); 632 633 memset(&(gid->raw[0]), 0, sizeof(gid->raw)); 634 memcpy(&(gid->raw[0]), nesvnic->netdev->dev_addr, 6); 635 636 return 0; 637} 638 639 640/** 641 * nes_alloc_ucontext - Allocate the user context data structure. This keeps track 642 * of all objects associated with a particular user-mode client. 643 */ 644static struct ib_ucontext *nes_alloc_ucontext(struct ib_device *ibdev, 645 struct ib_udata *udata) 646{ 647 struct nes_vnic *nesvnic = to_nesvnic(ibdev); 648 struct nes_device *nesdev = nesvnic->nesdev; 649 struct nes_adapter *nesadapter = nesdev->nesadapter; 650 struct nes_alloc_ucontext_req req; 651 struct nes_alloc_ucontext_resp uresp; 652 struct nes_ucontext *nes_ucontext; 653 struct nes_ib_device *nesibdev = nesvnic->nesibdev; 654 655 656 if (ib_copy_from_udata(&req, udata, sizeof(struct nes_alloc_ucontext_req))) { 657 printk(KERN_ERR PFX "Invalid structure size on allocate user context.\n"); 658 return ERR_PTR(-EINVAL); 659 } 660 661 if (req.userspace_ver != NES_ABI_USERSPACE_VER) { 662 printk(KERN_ERR PFX "Invalid userspace driver version detected. Detected version %d, should be %d\n", 663 req.userspace_ver, NES_ABI_USERSPACE_VER); 664 return ERR_PTR(-EINVAL); 665 } 666 667 668 memset(&uresp, 0, sizeof uresp); 669 670 uresp.max_qps = nesibdev->max_qp; 671 uresp.max_pds = nesibdev->max_pd; 672 uresp.wq_size = nesdev->nesadapter->max_qp_wr * 2; 673 uresp.virtwq = nesadapter->virtwq; 674 uresp.kernel_ver = NES_ABI_KERNEL_VER; 675 676 nes_ucontext = kzalloc(sizeof *nes_ucontext, GFP_KERNEL); 677 if (!nes_ucontext) 678 return ERR_PTR(-ENOMEM); 679 680 nes_ucontext->nesdev = nesdev; 681 nes_ucontext->mmap_wq_offset = uresp.max_pds; 682 nes_ucontext->mmap_cq_offset = nes_ucontext->mmap_wq_offset + 683 ((sizeof(struct nes_hw_qp_wqe) * uresp.max_qps * 2) + PAGE_SIZE-1) / 684 PAGE_SIZE; 685 686 687 if (ib_copy_to_udata(udata, &uresp, sizeof uresp)) { 688 kfree(nes_ucontext); 689 return ERR_PTR(-EFAULT); 690 } 691 692 INIT_LIST_HEAD(&nes_ucontext->cq_reg_mem_list); 693 INIT_LIST_HEAD(&nes_ucontext->qp_reg_mem_list); 694 atomic_set(&nes_ucontext->usecnt, 1); 695 return &nes_ucontext->ibucontext; 696} 697 698 699/** 700 * nes_dealloc_ucontext 701 */ 702static int nes_dealloc_ucontext(struct ib_ucontext *context) 703{ 704 /* struct nes_vnic *nesvnic = to_nesvnic(context->device); */ 705 /* struct nes_device *nesdev = nesvnic->nesdev; */ 706 struct nes_ucontext *nes_ucontext = to_nesucontext(context); 707 708 if (!atomic_dec_and_test(&nes_ucontext->usecnt)) 709 return 0; 710 kfree(nes_ucontext); 711 return 0; 712} 713 714 715/** 716 * nes_mmap 717 */ 718static int nes_mmap(struct ib_ucontext *context, struct vm_area_struct *vma) 719{ 720 unsigned long index; 721 struct nes_vnic *nesvnic = to_nesvnic(context->device); 722 struct nes_device *nesdev = nesvnic->nesdev; 723 /* struct nes_adapter *nesadapter = nesdev->nesadapter; */ 724 struct nes_ucontext *nes_ucontext; 725 struct nes_qp *nesqp; 726 727 nes_ucontext = to_nesucontext(context); 728 729 730 if (vma->vm_pgoff >= nes_ucontext->mmap_wq_offset) { 731 index = (vma->vm_pgoff - nes_ucontext->mmap_wq_offset) * PAGE_SIZE; 732 index /= ((sizeof(struct nes_hw_qp_wqe) * nesdev->nesadapter->max_qp_wr * 2) + 733 PAGE_SIZE-1) & (~(PAGE_SIZE-1)); 734 if (!test_bit(index, nes_ucontext->allocated_wqs)) { 735 nes_debug(NES_DBG_MMAP, "wq %lu not allocated\n", index); 736 return -EFAULT; 737 } 738 nesqp = nes_ucontext->mmap_nesqp[index]; 739 if (nesqp == NULL) { 740 nes_debug(NES_DBG_MMAP, "wq %lu has a NULL QP base.\n", index); 741 return -EFAULT; 742 } 743 if (remap_pfn_range(vma, vma->vm_start, 744 virt_to_phys(nesqp->hwqp.sq_vbase) >> PAGE_SHIFT, 745 vma->vm_end - vma->vm_start, 746 vma->vm_page_prot)) { 747 nes_debug(NES_DBG_MMAP, "remap_pfn_range failed.\n"); 748 return -EAGAIN; 749 } 750 vma->vm_private_data = nesqp; 751 return 0; 752 } else { 753 index = vma->vm_pgoff; 754 if (!test_bit(index, nes_ucontext->allocated_doorbells)) 755 return -EFAULT; 756 757 vma->vm_page_prot = pgprot_noncached(vma->vm_page_prot); 758 if (io_remap_pfn_range(vma, vma->vm_start, 759 (nesdev->doorbell_start + 760 ((nes_ucontext->mmap_db_index[index] - nesdev->base_doorbell_index) * 4096)) 761 >> PAGE_SHIFT, PAGE_SIZE, vma->vm_page_prot)) 762 return -EAGAIN; 763 vma->vm_private_data = nes_ucontext; 764 return 0; 765 } 766 767 return -ENOSYS; 768} 769 770 771/** 772 * nes_alloc_pd 773 */ 774static struct ib_pd *nes_alloc_pd(struct ib_device *ibdev, 775 struct ib_ucontext *context, struct ib_udata *udata) 776{ 777 struct nes_pd *nespd; 778 struct nes_vnic *nesvnic = to_nesvnic(ibdev); 779 struct nes_device *nesdev = nesvnic->nesdev; 780 struct nes_adapter *nesadapter = nesdev->nesadapter; 781 struct nes_ucontext *nesucontext; 782 struct nes_alloc_pd_resp uresp; 783 u32 pd_num = 0; 784 int err; 785 786 nes_debug(NES_DBG_PD, "nesvnic=%p, netdev=%p %s, ibdev=%p, context=%p, netdev refcnt=%u\n", 787 nesvnic, nesdev->netdev[0], nesdev->netdev[0]->name, ibdev, context, 788 atomic_read(&nesvnic->netdev->refcnt)); 789 790 err = nes_alloc_resource(nesadapter, nesadapter->allocated_pds, 791 nesadapter->max_pd, &pd_num, &nesadapter->next_pd); 792 if (err) { 793 return ERR_PTR(err); 794 } 795 796 nespd = kzalloc(sizeof (struct nes_pd), GFP_KERNEL); 797 if (!nespd) { 798 nes_free_resource(nesadapter, nesadapter->allocated_pds, pd_num); 799 return ERR_PTR(-ENOMEM); 800 } 801 802 nes_debug(NES_DBG_PD, "Allocating PD (%p) for ib device %s\n", 803 nespd, nesvnic->nesibdev->ibdev.name); 804 805 nespd->pd_id = (pd_num << (PAGE_SHIFT-12)) + nesadapter->base_pd; 806 807 if (context) { 808 nesucontext = to_nesucontext(context); 809 nespd->mmap_db_index = find_next_zero_bit(nesucontext->allocated_doorbells, 810 NES_MAX_USER_DB_REGIONS, nesucontext->first_free_db); 811 nes_debug(NES_DBG_PD, "find_first_zero_biton doorbells returned %u, mapping pd_id %u.\n", 812 nespd->mmap_db_index, nespd->pd_id); 813 if (nespd->mmap_db_index >= NES_MAX_USER_DB_REGIONS) { 814 nes_debug(NES_DBG_PD, "mmap_db_index > MAX\n"); 815 nes_free_resource(nesadapter, nesadapter->allocated_pds, pd_num); 816 kfree(nespd); 817 return ERR_PTR(-ENOMEM); 818 } 819 820 uresp.pd_id = nespd->pd_id; 821 uresp.mmap_db_index = nespd->mmap_db_index; 822 if (ib_copy_to_udata(udata, &uresp, sizeof (struct nes_alloc_pd_resp))) { 823 nes_free_resource(nesadapter, nesadapter->allocated_pds, pd_num); 824 kfree(nespd); 825 return ERR_PTR(-EFAULT); 826 } 827 828 set_bit(nespd->mmap_db_index, nesucontext->allocated_doorbells); 829 nesucontext->mmap_db_index[nespd->mmap_db_index] = nespd->pd_id; 830 nesucontext->first_free_db = nespd->mmap_db_index + 1; 831 } 832 833 nes_debug(NES_DBG_PD, "PD%u structure located @%p.\n", nespd->pd_id, nespd); 834 return &nespd->ibpd; 835} 836 837 838/** 839 * nes_dealloc_pd 840 */ 841static int nes_dealloc_pd(struct ib_pd *ibpd) 842{ 843 struct nes_ucontext *nesucontext; 844 struct nes_pd *nespd = to_nespd(ibpd); 845 struct nes_vnic *nesvnic = to_nesvnic(ibpd->device); 846 struct nes_device *nesdev = nesvnic->nesdev; 847 struct nes_adapter *nesadapter = nesdev->nesadapter; 848 849 if ((ibpd->uobject) && (ibpd->uobject->context)) { 850 nesucontext = to_nesucontext(ibpd->uobject->context); 851 nes_debug(NES_DBG_PD, "Clearing bit %u from allocated doorbells\n", 852 nespd->mmap_db_index); 853 clear_bit(nespd->mmap_db_index, nesucontext->allocated_doorbells); 854 nesucontext->mmap_db_index[nespd->mmap_db_index] = 0; 855 if (nesucontext->first_free_db > nespd->mmap_db_index) { 856 nesucontext->first_free_db = nespd->mmap_db_index; 857 } 858 } 859 860 nes_debug(NES_DBG_PD, "Deallocating PD%u structure located @%p.\n", 861 nespd->pd_id, nespd); 862 nes_free_resource(nesadapter, nesadapter->allocated_pds, 863 (nespd->pd_id-nesadapter->base_pd)>>(PAGE_SHIFT-12)); 864 kfree(nespd); 865 866 return 0; 867} 868 869 870/** 871 * nes_create_ah 872 */ 873static struct ib_ah *nes_create_ah(struct ib_pd *pd, struct ib_ah_attr *ah_attr) 874{ 875 return ERR_PTR(-ENOSYS); 876} 877 878 879/** 880 * nes_destroy_ah 881 */ 882static int nes_destroy_ah(struct ib_ah *ah) 883{ 884 return -ENOSYS; 885} 886 887 888/** 889 * nes_get_encoded_size 890 */ 891static inline u8 nes_get_encoded_size(int *size) 892{ 893 u8 encoded_size = 0; 894 if (*size <= 32) { 895 *size = 32; 896 encoded_size = 1; 897 } else if (*size <= 128) { 898 *size = 128; 899 encoded_size = 2; 900 } else if (*size <= 512) { 901 *size = 512; 902 encoded_size = 3; 903 } 904 return (encoded_size); 905} 906 907 908 909/** 910 * nes_setup_virt_qp 911 */ 912static int nes_setup_virt_qp(struct nes_qp *nesqp, struct nes_pbl *nespbl, 913 struct nes_vnic *nesvnic, int sq_size, int rq_size) 914{ 915 unsigned long flags; 916 void *mem; 917 __le64 *pbl = NULL; 918 __le64 *tpbl; 919 __le64 *pblbuffer; 920 struct nes_device *nesdev = nesvnic->nesdev; 921 struct nes_adapter *nesadapter = nesdev->nesadapter; 922 u32 pbl_entries; 923 u8 rq_pbl_entries; 924 u8 sq_pbl_entries; 925 926 pbl_entries = nespbl->pbl_size >> 3; 927 nes_debug(NES_DBG_QP, "Userspace PBL, pbl_size=%u, pbl_entries = %d pbl_vbase=%p, pbl_pbase=%lx\n", 928 nespbl->pbl_size, pbl_entries, 929 (void *)nespbl->pbl_vbase, 930 (unsigned long) nespbl->pbl_pbase); 931 pbl = (__le64 *) nespbl->pbl_vbase; /* points to first pbl entry */ 932 /* now lets set the sq_vbase as well as rq_vbase addrs we will assign */ 933 /* the first pbl to be fro the rq_vbase... */ 934 rq_pbl_entries = (rq_size * sizeof(struct nes_hw_qp_wqe)) >> 12; 935 sq_pbl_entries = (sq_size * sizeof(struct nes_hw_qp_wqe)) >> 12; 936 nesqp->hwqp.sq_pbase = (le32_to_cpu(((__le32 *)pbl)[0])) | ((u64)((le32_to_cpu(((__le32 *)pbl)[1]))) << 32); 937 if (!nespbl->page) { 938 nes_debug(NES_DBG_QP, "QP nespbl->page is NULL \n"); 939 kfree(nespbl); 940 return -ENOMEM; 941 } 942 943 nesqp->hwqp.sq_vbase = kmap(nespbl->page); 944 nesqp->page = nespbl->page; 945 if (!nesqp->hwqp.sq_vbase) { 946 nes_debug(NES_DBG_QP, "QP sq_vbase kmap failed\n"); 947 kfree(nespbl); 948 return -ENOMEM; 949 } 950 951 /* Now to get to sq.. we need to calculate how many */ 952 /* PBL entries were used by the rq.. */ 953 pbl += sq_pbl_entries; 954 nesqp->hwqp.rq_pbase = (le32_to_cpu(((__le32 *)pbl)[0])) | ((u64)((le32_to_cpu(((__le32 *)pbl)[1]))) << 32); 955 /* nesqp->hwqp.rq_vbase = bus_to_virt(*pbl); */ 956 /*nesqp->hwqp.rq_vbase = phys_to_virt(*pbl); */ 957 958 nes_debug(NES_DBG_QP, "QP sq_vbase= %p sq_pbase=%lx rq_vbase=%p rq_pbase=%lx\n", 959 nesqp->hwqp.sq_vbase, (unsigned long) nesqp->hwqp.sq_pbase, 960 nesqp->hwqp.rq_vbase, (unsigned long) nesqp->hwqp.rq_pbase); 961 spin_lock_irqsave(&nesadapter->pbl_lock, flags); 962 if (!nesadapter->free_256pbl) { 963 pci_free_consistent(nesdev->pcidev, nespbl->pbl_size, nespbl->pbl_vbase, 964 nespbl->pbl_pbase); 965 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 966 kunmap(nesqp->page); 967 kfree(nespbl); 968 return -ENOMEM; 969 } 970 nesadapter->free_256pbl--; 971 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 972 973 nesqp->pbl_vbase = pci_alloc_consistent(nesdev->pcidev, 256, &nesqp->pbl_pbase); 974 pblbuffer = nesqp->pbl_vbase; 975 if (!nesqp->pbl_vbase) { 976 /* memory allocated during nes_reg_user_mr() */ 977 pci_free_consistent(nesdev->pcidev, nespbl->pbl_size, nespbl->pbl_vbase, 978 nespbl->pbl_pbase); 979 kfree(nespbl); 980 spin_lock_irqsave(&nesadapter->pbl_lock, flags); 981 nesadapter->free_256pbl++; 982 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 983 kunmap(nesqp->page); 984 return -ENOMEM; 985 } 986 memset(nesqp->pbl_vbase, 0, 256); 987 /* fill in the page address in the pbl buffer.. */ 988 tpbl = pblbuffer + 16; 989 pbl = (__le64 *)nespbl->pbl_vbase; 990 while (sq_pbl_entries--) 991 *tpbl++ = *pbl++; 992 tpbl = pblbuffer; 993 while (rq_pbl_entries--) 994 *tpbl++ = *pbl++; 995 996 /* done with memory allocated during nes_reg_user_mr() */ 997 pci_free_consistent(nesdev->pcidev, nespbl->pbl_size, nespbl->pbl_vbase, 998 nespbl->pbl_pbase); 999 kfree(nespbl); 1000 1001 nesqp->qp_mem_size = 1002 max((u32)sizeof(struct nes_qp_context), ((u32)256)) + 256; /* this is Q2 */ 1003 /* Round up to a multiple of a page */ 1004 nesqp->qp_mem_size += PAGE_SIZE - 1; 1005 nesqp->qp_mem_size &= ~(PAGE_SIZE - 1); 1006 1007 mem = pci_alloc_consistent(nesdev->pcidev, nesqp->qp_mem_size, 1008 &nesqp->hwqp.q2_pbase); 1009 1010 if (!mem) { 1011 pci_free_consistent(nesdev->pcidev, 256, nesqp->pbl_vbase, nesqp->pbl_pbase); 1012 nesqp->pbl_vbase = NULL; 1013 spin_lock_irqsave(&nesadapter->pbl_lock, flags); 1014 nesadapter->free_256pbl++; 1015 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 1016 kunmap(nesqp->page); 1017 return -ENOMEM; 1018 } 1019 nesqp->sq_kmapped = 1; 1020 nesqp->hwqp.q2_vbase = mem; 1021 mem += 256; 1022 memset(nesqp->hwqp.q2_vbase, 0, 256); 1023 nesqp->nesqp_context = mem; 1024 memset(nesqp->nesqp_context, 0, sizeof(*nesqp->nesqp_context)); 1025 nesqp->nesqp_context_pbase = nesqp->hwqp.q2_pbase + 256; 1026 1027 return 0; 1028} 1029 1030 1031/** 1032 * nes_setup_mmap_qp 1033 */ 1034static int nes_setup_mmap_qp(struct nes_qp *nesqp, struct nes_vnic *nesvnic, 1035 int sq_size, int rq_size) 1036{ 1037 void *mem; 1038 struct nes_device *nesdev = nesvnic->nesdev; 1039 1040 nesqp->qp_mem_size = (sizeof(struct nes_hw_qp_wqe) * sq_size) + 1041 (sizeof(struct nes_hw_qp_wqe) * rq_size) + 1042 max((u32)sizeof(struct nes_qp_context), ((u32)256)) + 1043 256; /* this is Q2 */ 1044 /* Round up to a multiple of a page */ 1045 nesqp->qp_mem_size += PAGE_SIZE - 1; 1046 nesqp->qp_mem_size &= ~(PAGE_SIZE - 1); 1047 1048 mem = pci_alloc_consistent(nesdev->pcidev, nesqp->qp_mem_size, 1049 &nesqp->hwqp.sq_pbase); 1050 if (!mem) 1051 return -ENOMEM; 1052 nes_debug(NES_DBG_QP, "PCI consistent memory for " 1053 "host descriptor rings located @ %p (pa = 0x%08lX.) size = %u.\n", 1054 mem, (unsigned long)nesqp->hwqp.sq_pbase, nesqp->qp_mem_size); 1055 1056 memset(mem, 0, nesqp->qp_mem_size); 1057 1058 nesqp->hwqp.sq_vbase = mem; 1059 mem += sizeof(struct nes_hw_qp_wqe) * sq_size; 1060 1061 nesqp->hwqp.rq_vbase = mem; 1062 nesqp->hwqp.rq_pbase = nesqp->hwqp.sq_pbase + 1063 sizeof(struct nes_hw_qp_wqe) * sq_size; 1064 mem += sizeof(struct nes_hw_qp_wqe) * rq_size; 1065 1066 nesqp->hwqp.q2_vbase = mem; 1067 nesqp->hwqp.q2_pbase = nesqp->hwqp.rq_pbase + 1068 sizeof(struct nes_hw_qp_wqe) * rq_size; 1069 mem += 256; 1070 memset(nesqp->hwqp.q2_vbase, 0, 256); 1071 1072 nesqp->nesqp_context = mem; 1073 nesqp->nesqp_context_pbase = nesqp->hwqp.q2_pbase + 256; 1074 memset(nesqp->nesqp_context, 0, sizeof(*nesqp->nesqp_context)); 1075 return 0; 1076} 1077 1078 1079/** 1080 * nes_free_qp_mem() is to free up the qp's pci_alloc_consistent() memory. 1081 */ 1082static inline void nes_free_qp_mem(struct nes_device *nesdev, 1083 struct nes_qp *nesqp, int virt_wqs) 1084{ 1085 unsigned long flags; 1086 struct nes_adapter *nesadapter = nesdev->nesadapter; 1087 if (!virt_wqs) { 1088 pci_free_consistent(nesdev->pcidev, nesqp->qp_mem_size, 1089 nesqp->hwqp.sq_vbase, nesqp->hwqp.sq_pbase); 1090 }else { 1091 spin_lock_irqsave(&nesadapter->pbl_lock, flags); 1092 nesadapter->free_256pbl++; 1093 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 1094 pci_free_consistent(nesdev->pcidev, nesqp->qp_mem_size, nesqp->hwqp.q2_vbase, nesqp->hwqp.q2_pbase); 1095 pci_free_consistent(nesdev->pcidev, 256, nesqp->pbl_vbase, nesqp->pbl_pbase ); 1096 nesqp->pbl_vbase = NULL; 1097 if (nesqp->sq_kmapped) { 1098 nesqp->sq_kmapped = 0; 1099 kunmap(nesqp->page); 1100 } 1101 } 1102} 1103 1104 1105/** 1106 * nes_create_qp 1107 */ 1108static struct ib_qp *nes_create_qp(struct ib_pd *ibpd, 1109 struct ib_qp_init_attr *init_attr, struct ib_udata *udata) 1110{ 1111 u64 u64temp= 0; 1112 u64 u64nesqp = 0; 1113 struct nes_pd *nespd = to_nespd(ibpd); 1114 struct nes_vnic *nesvnic = to_nesvnic(ibpd->device); 1115 struct nes_device *nesdev = nesvnic->nesdev; 1116 struct nes_adapter *nesadapter = nesdev->nesadapter; 1117 struct nes_qp *nesqp; 1118 struct nes_cq *nescq; 1119 struct nes_ucontext *nes_ucontext; 1120 struct nes_hw_cqp_wqe *cqp_wqe; 1121 struct nes_cqp_request *cqp_request; 1122 struct nes_create_qp_req req; 1123 struct nes_create_qp_resp uresp; 1124 struct nes_pbl *nespbl = NULL; 1125 u32 qp_num = 0; 1126 u32 opcode = 0; 1127 /* u32 counter = 0; */ 1128 void *mem; 1129 unsigned long flags; 1130 int ret; 1131 int err; 1132 int virt_wqs = 0; 1133 int sq_size; 1134 int rq_size; 1135 u8 sq_encoded_size; 1136 u8 rq_encoded_size; 1137 /* int counter; */ 1138 1139 if (init_attr->create_flags) 1140 return ERR_PTR(-EINVAL); 1141 1142 atomic_inc(&qps_created); 1143 switch (init_attr->qp_type) { 1144 case IB_QPT_RC: 1145 if (nes_drv_opt & NES_DRV_OPT_NO_INLINE_DATA) { 1146 init_attr->cap.max_inline_data = 0; 1147 } else { 1148 init_attr->cap.max_inline_data = 64; 1149 } 1150 sq_size = init_attr->cap.max_send_wr; 1151 rq_size = init_attr->cap.max_recv_wr; 1152 1153 /* check if the encoded sizes are OK or not... */ 1154 sq_encoded_size = nes_get_encoded_size(&sq_size); 1155 rq_encoded_size = nes_get_encoded_size(&rq_size); 1156 1157 if ((!sq_encoded_size) || (!rq_encoded_size)) { 1158 nes_debug(NES_DBG_QP, "ERROR bad rq (%u) or sq (%u) size\n", 1159 rq_size, sq_size); 1160 return ERR_PTR(-EINVAL); 1161 } 1162 1163 init_attr->cap.max_send_wr = sq_size -2; 1164 init_attr->cap.max_recv_wr = rq_size -1; 1165 nes_debug(NES_DBG_QP, "RQ size=%u, SQ Size=%u\n", rq_size, sq_size); 1166 1167 ret = nes_alloc_resource(nesadapter, nesadapter->allocated_qps, 1168 nesadapter->max_qp, &qp_num, &nesadapter->next_qp); 1169 if (ret) { 1170 return ERR_PTR(ret); 1171 } 1172 1173 /* Need 512 (actually now 1024) byte alignment on this structure */ 1174 mem = kzalloc(sizeof(*nesqp)+NES_SW_CONTEXT_ALIGN-1, GFP_KERNEL); 1175 if (!mem) { 1176 nes_free_resource(nesadapter, nesadapter->allocated_qps, qp_num); 1177 nes_debug(NES_DBG_QP, "Unable to allocate QP\n"); 1178 return ERR_PTR(-ENOMEM); 1179 } 1180 u64nesqp = (unsigned long)mem; 1181 u64nesqp += ((u64)NES_SW_CONTEXT_ALIGN) - 1; 1182 u64temp = ((u64)NES_SW_CONTEXT_ALIGN) - 1; 1183 u64nesqp &= ~u64temp; 1184 nesqp = (struct nes_qp *)(unsigned long)u64nesqp; 1185 /* nes_debug(NES_DBG_QP, "nesqp=%p, allocated buffer=%p. Rounded to closest %u\n", 1186 nesqp, mem, NES_SW_CONTEXT_ALIGN); */ 1187 nesqp->allocated_buffer = mem; 1188 1189 if (udata) { 1190 if (ib_copy_from_udata(&req, udata, sizeof(struct nes_create_qp_req))) { 1191 nes_free_resource(nesadapter, nesadapter->allocated_qps, qp_num); 1192 kfree(nesqp->allocated_buffer); 1193 nes_debug(NES_DBG_QP, "ib_copy_from_udata() Failed \n"); 1194 return NULL; 1195 } 1196 if (req.user_wqe_buffers) { 1197 virt_wqs = 1; 1198 } 1199 if ((ibpd->uobject) && (ibpd->uobject->context)) { 1200 nesqp->user_mode = 1; 1201 nes_ucontext = to_nesucontext(ibpd->uobject->context); 1202 if (virt_wqs) { 1203 err = 1; 1204 list_for_each_entry(nespbl, &nes_ucontext->qp_reg_mem_list, list) { 1205 if (nespbl->user_base == (unsigned long )req.user_wqe_buffers) { 1206 list_del(&nespbl->list); 1207 err = 0; 1208 nes_debug(NES_DBG_QP, "Found PBL for virtual QP. nespbl=%p. user_base=0x%lx\n", 1209 nespbl, nespbl->user_base); 1210 break; 1211 } 1212 } 1213 if (err) { 1214 nes_debug(NES_DBG_QP, "Didn't Find PBL for virtual QP. address = %llx.\n", 1215 (long long unsigned int)req.user_wqe_buffers); 1216 nes_free_resource(nesadapter, nesadapter->allocated_qps, qp_num); 1217 kfree(nesqp->allocated_buffer); 1218 return ERR_PTR(-EFAULT); 1219 } 1220 } 1221 1222 nes_ucontext = to_nesucontext(ibpd->uobject->context); 1223 nesqp->mmap_sq_db_index = 1224 find_next_zero_bit(nes_ucontext->allocated_wqs, 1225 NES_MAX_USER_WQ_REGIONS, nes_ucontext->first_free_wq); 1226 /* nes_debug(NES_DBG_QP, "find_first_zero_biton wqs returned %u\n", 1227 nespd->mmap_db_index); */ 1228 if (nesqp->mmap_sq_db_index >= NES_MAX_USER_WQ_REGIONS) { 1229 nes_debug(NES_DBG_QP, 1230 "db index > max user regions, failing create QP\n"); 1231 nes_free_resource(nesadapter, nesadapter->allocated_qps, qp_num); 1232 if (virt_wqs) { 1233 pci_free_consistent(nesdev->pcidev, nespbl->pbl_size, nespbl->pbl_vbase, 1234 nespbl->pbl_pbase); 1235 kfree(nespbl); 1236 } 1237 kfree(nesqp->allocated_buffer); 1238 return ERR_PTR(-ENOMEM); 1239 } 1240 set_bit(nesqp->mmap_sq_db_index, nes_ucontext->allocated_wqs); 1241 nes_ucontext->mmap_nesqp[nesqp->mmap_sq_db_index] = nesqp; 1242 nes_ucontext->first_free_wq = nesqp->mmap_sq_db_index + 1; 1243 } else { 1244 nes_free_resource(nesadapter, nesadapter->allocated_qps, qp_num); 1245 kfree(nesqp->allocated_buffer); 1246 return ERR_PTR(-EFAULT); 1247 } 1248 } 1249 err = (!virt_wqs) ? nes_setup_mmap_qp(nesqp, nesvnic, sq_size, rq_size) : 1250 nes_setup_virt_qp(nesqp, nespbl, nesvnic, sq_size, rq_size); 1251 if (err) { 1252 nes_debug(NES_DBG_QP, 1253 "error geting qp mem code = %d\n", err); 1254 nes_free_resource(nesadapter, nesadapter->allocated_qps, qp_num); 1255 kfree(nesqp->allocated_buffer); 1256 return ERR_PTR(-ENOMEM); 1257 } 1258 1259 nesqp->hwqp.sq_size = sq_size; 1260 nesqp->hwqp.sq_encoded_size = sq_encoded_size; 1261 nesqp->hwqp.sq_head = 1; 1262 nesqp->hwqp.rq_size = rq_size; 1263 nesqp->hwqp.rq_encoded_size = rq_encoded_size; 1264 /* nes_debug(NES_DBG_QP, "nesqp->nesqp_context_pbase = %p\n", 1265 (void *)nesqp->nesqp_context_pbase); 1266 */ 1267 nesqp->hwqp.qp_id = qp_num; 1268 nesqp->ibqp.qp_num = nesqp->hwqp.qp_id; 1269 nesqp->nespd = nespd; 1270 1271 nescq = to_nescq(init_attr->send_cq); 1272 nesqp->nesscq = nescq; 1273 nescq = to_nescq(init_attr->recv_cq); 1274 nesqp->nesrcq = nescq; 1275 1276 nesqp->nesqp_context->misc |= cpu_to_le32((u32)PCI_FUNC(nesdev->pcidev->devfn) << 1277 NES_QPCONTEXT_MISC_PCI_FCN_SHIFT); 1278 nesqp->nesqp_context->misc |= cpu_to_le32((u32)nesqp->hwqp.rq_encoded_size << 1279 NES_QPCONTEXT_MISC_RQ_SIZE_SHIFT); 1280 nesqp->nesqp_context->misc |= cpu_to_le32((u32)nesqp->hwqp.sq_encoded_size << 1281 NES_QPCONTEXT_MISC_SQ_SIZE_SHIFT); 1282 if (!udata) { 1283 nesqp->nesqp_context->misc |= cpu_to_le32(NES_QPCONTEXT_MISC_PRIV_EN); 1284 nesqp->nesqp_context->misc |= cpu_to_le32(NES_QPCONTEXT_MISC_FAST_REGISTER_EN); 1285 } 1286 nesqp->nesqp_context->cqs = cpu_to_le32(nesqp->nesscq->hw_cq.cq_number + 1287 ((u32)nesqp->nesrcq->hw_cq.cq_number << 16)); 1288 u64temp = (u64)nesqp->hwqp.sq_pbase; 1289 nesqp->nesqp_context->sq_addr_low = cpu_to_le32((u32)u64temp); 1290 nesqp->nesqp_context->sq_addr_high = cpu_to_le32((u32)(u64temp >> 32)); 1291 1292 1293 if (!virt_wqs) { 1294 u64temp = (u64)nesqp->hwqp.sq_pbase; 1295 nesqp->nesqp_context->sq_addr_low = cpu_to_le32((u32)u64temp); 1296 nesqp->nesqp_context->sq_addr_high = cpu_to_le32((u32)(u64temp >> 32)); 1297 u64temp = (u64)nesqp->hwqp.rq_pbase; 1298 nesqp->nesqp_context->rq_addr_low = cpu_to_le32((u32)u64temp); 1299 nesqp->nesqp_context->rq_addr_high = cpu_to_le32((u32)(u64temp >> 32)); 1300 } else { 1301 u64temp = (u64)nesqp->pbl_pbase; 1302 nesqp->nesqp_context->rq_addr_low = cpu_to_le32((u32)u64temp); 1303 nesqp->nesqp_context->rq_addr_high = cpu_to_le32((u32)(u64temp >> 32)); 1304 } 1305 1306 /* nes_debug(NES_DBG_QP, "next_qp_nic_index=%u, using nic_index=%d\n", 1307 nesvnic->next_qp_nic_index, 1308 nesvnic->qp_nic_index[nesvnic->next_qp_nic_index]); */ 1309 spin_lock_irqsave(&nesdev->cqp.lock, flags); 1310 nesqp->nesqp_context->misc2 |= cpu_to_le32( 1311 (u32)nesvnic->qp_nic_index[nesvnic->next_qp_nic_index] << 1312 NES_QPCONTEXT_MISC2_NIC_INDEX_SHIFT); 1313 nesvnic->next_qp_nic_index++; 1314 if ((nesvnic->next_qp_nic_index > 3) || 1315 (nesvnic->qp_nic_index[nesvnic->next_qp_nic_index] == 0xf)) { 1316 nesvnic->next_qp_nic_index = 0; 1317 } 1318 spin_unlock_irqrestore(&nesdev->cqp.lock, flags); 1319 1320 nesqp->nesqp_context->pd_index_wscale |= cpu_to_le32((u32)nesqp->nespd->pd_id << 16); 1321 u64temp = (u64)nesqp->hwqp.q2_pbase; 1322 nesqp->nesqp_context->q2_addr_low = cpu_to_le32((u32)u64temp); 1323 nesqp->nesqp_context->q2_addr_high = cpu_to_le32((u32)(u64temp >> 32)); 1324 nesqp->nesqp_context->aeq_token_low = cpu_to_le32((u32)((unsigned long)(nesqp))); 1325 nesqp->nesqp_context->aeq_token_high = cpu_to_le32((u32)(upper_32_bits((unsigned long)(nesqp)))); 1326 nesqp->nesqp_context->ird_ord_sizes = cpu_to_le32(NES_QPCONTEXT_ORDIRD_ALSMM | 1327 NES_QPCONTEXT_ORDIRD_AAH | 1328 ((((u32)nesadapter->max_irrq_wr) << 1329 NES_QPCONTEXT_ORDIRD_IRDSIZE_SHIFT) & NES_QPCONTEXT_ORDIRD_IRDSIZE_MASK)); 1330 if (disable_mpa_crc) { 1331 nes_debug(NES_DBG_QP, "Disabling MPA crc checking due to module option.\n"); 1332 nesqp->nesqp_context->ird_ord_sizes |= cpu_to_le32(NES_QPCONTEXT_ORDIRD_RNMC); 1333 } 1334 1335 1336 /* Create the QP */ 1337 cqp_request = nes_get_cqp_request(nesdev); 1338 if (cqp_request == NULL) { 1339 nes_debug(NES_DBG_QP, "Failed to get a cqp_request\n"); 1340 nes_free_resource(nesadapter, nesadapter->allocated_qps, qp_num); 1341 nes_free_qp_mem(nesdev, nesqp,virt_wqs); 1342 kfree(nesqp->allocated_buffer); 1343 return ERR_PTR(-ENOMEM); 1344 } 1345 cqp_request->waiting = 1; 1346 cqp_wqe = &cqp_request->cqp_wqe; 1347 1348 if (!virt_wqs) { 1349 opcode = NES_CQP_CREATE_QP | NES_CQP_QP_TYPE_IWARP | 1350 NES_CQP_QP_IWARP_STATE_IDLE; 1351 } else { 1352 opcode = NES_CQP_CREATE_QP | NES_CQP_QP_TYPE_IWARP | NES_CQP_QP_VIRT_WQS | 1353 NES_CQP_QP_IWARP_STATE_IDLE; 1354 } 1355 opcode |= NES_CQP_QP_CQS_VALID; 1356 nes_fill_init_cqp_wqe(cqp_wqe, nesdev); 1357 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX, opcode); 1358 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_ID_IDX, nesqp->hwqp.qp_id); 1359 1360 u64temp = (u64)nesqp->nesqp_context_pbase; 1361 set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_QP_WQE_CONTEXT_LOW_IDX, u64temp); 1362 1363 atomic_set(&cqp_request->refcount, 2); 1364 nes_post_cqp_request(nesdev, cqp_request); 1365 1366 /* Wait for CQP */ 1367 nes_debug(NES_DBG_QP, "Waiting for create iWARP QP%u to complete.\n", 1368 nesqp->hwqp.qp_id); 1369 ret = wait_event_timeout(cqp_request->waitq, 1370 (cqp_request->request_done != 0), NES_EVENT_TIMEOUT); 1371 nes_debug(NES_DBG_QP, "Create iwarp QP%u completed, wait_event_timeout ret=%u," 1372 " nesdev->cqp_head = %u, nesdev->cqp.sq_tail = %u," 1373 " CQP Major:Minor codes = 0x%04X:0x%04X.\n", 1374 nesqp->hwqp.qp_id, ret, nesdev->cqp.sq_head, nesdev->cqp.sq_tail, 1375 cqp_request->major_code, cqp_request->minor_code); 1376 if ((!ret) || (cqp_request->major_code)) { 1377 nes_put_cqp_request(nesdev, cqp_request); 1378 nes_free_resource(nesadapter, nesadapter->allocated_qps, qp_num); 1379 nes_free_qp_mem(nesdev, nesqp,virt_wqs); 1380 kfree(nesqp->allocated_buffer); 1381 if (!ret) { 1382 return ERR_PTR(-ETIME); 1383 } else { 1384 return ERR_PTR(-EIO); 1385 } 1386 } 1387 1388 nes_put_cqp_request(nesdev, cqp_request); 1389 1390 if (ibpd->uobject) { 1391 uresp.mmap_sq_db_index = nesqp->mmap_sq_db_index; 1392 uresp.actual_sq_size = sq_size; 1393 uresp.actual_rq_size = rq_size; 1394 uresp.qp_id = nesqp->hwqp.qp_id; 1395 uresp.nes_drv_opt = nes_drv_opt; 1396 if (ib_copy_to_udata(udata, &uresp, sizeof uresp)) { 1397 nes_free_resource(nesadapter, nesadapter->allocated_qps, qp_num); 1398 nes_free_qp_mem(nesdev, nesqp,virt_wqs); 1399 kfree(nesqp->allocated_buffer); 1400 return ERR_PTR(-EFAULT); 1401 } 1402 } 1403 1404 nes_debug(NES_DBG_QP, "QP%u structure located @%p.Size = %u.\n", 1405 nesqp->hwqp.qp_id, nesqp, (u32)sizeof(*nesqp)); 1406 spin_lock_init(&nesqp->lock); 1407 nes_add_ref(&nesqp->ibqp); 1408 break; 1409 default: 1410 nes_debug(NES_DBG_QP, "Invalid QP type: %d\n", init_attr->qp_type); 1411 return ERR_PTR(-EINVAL); 1412 } 1413 1414 nesqp->sig_all = (init_attr->sq_sig_type == IB_SIGNAL_ALL_WR); 1415 1416 /* update the QP table */ 1417 nesdev->nesadapter->qp_table[nesqp->hwqp.qp_id-NES_FIRST_QPN] = nesqp; 1418 nes_debug(NES_DBG_QP, "netdev refcnt=%u\n", 1419 atomic_read(&nesvnic->netdev->refcnt)); 1420 1421 return &nesqp->ibqp; 1422} 1423 1424 1425/** 1426 * nes_clean_cq 1427 */ 1428static void nes_clean_cq(struct nes_qp *nesqp, struct nes_cq *nescq) 1429{ 1430 u32 cq_head; 1431 u32 lo; 1432 u32 hi; 1433 u64 u64temp; 1434 unsigned long flags = 0; 1435 1436 spin_lock_irqsave(&nescq->lock, flags); 1437 1438 cq_head = nescq->hw_cq.cq_head; 1439 while (le32_to_cpu(nescq->hw_cq.cq_vbase[cq_head].cqe_words[NES_CQE_OPCODE_IDX]) & NES_CQE_VALID) { 1440 rmb(); 1441 lo = le32_to_cpu(nescq->hw_cq.cq_vbase[cq_head].cqe_words[NES_CQE_COMP_COMP_CTX_LOW_IDX]); 1442 hi = le32_to_cpu(nescq->hw_cq.cq_vbase[cq_head].cqe_words[NES_CQE_COMP_COMP_CTX_HIGH_IDX]); 1443 u64temp = (((u64)hi) << 32) | ((u64)lo); 1444 u64temp &= ~(NES_SW_CONTEXT_ALIGN-1); 1445 if (u64temp == (u64)(unsigned long)nesqp) { 1446 /* Zero the context value so cqe will be ignored */ 1447 nescq->hw_cq.cq_vbase[cq_head].cqe_words[NES_CQE_COMP_COMP_CTX_LOW_IDX] = 0; 1448 nescq->hw_cq.cq_vbase[cq_head].cqe_words[NES_CQE_COMP_COMP_CTX_HIGH_IDX] = 0; 1449 } 1450 1451 if (++cq_head >= nescq->hw_cq.cq_size) 1452 cq_head = 0; 1453 } 1454 1455 spin_unlock_irqrestore(&nescq->lock, flags); 1456} 1457 1458 1459/** 1460 * nes_destroy_qp 1461 */ 1462static int nes_destroy_qp(struct ib_qp *ibqp) 1463{ 1464 struct nes_qp *nesqp = to_nesqp(ibqp); 1465 struct nes_ucontext *nes_ucontext; 1466 struct ib_qp_attr attr; 1467 struct iw_cm_id *cm_id; 1468 struct iw_cm_event cm_event; 1469 int ret; 1470 1471 atomic_inc(&sw_qps_destroyed); 1472 nesqp->destroyed = 1; 1473 1474 /* Blow away the connection if it exists. */ 1475 if (nesqp->ibqp_state >= IB_QPS_INIT && nesqp->ibqp_state <= IB_QPS_RTS) { 1476 /* if (nesqp->ibqp_state == IB_QPS_RTS) { */ 1477 attr.qp_state = IB_QPS_ERR; 1478 nes_modify_qp(&nesqp->ibqp, &attr, IB_QP_STATE, NULL); 1479 } 1480 1481 if (((nesqp->ibqp_state == IB_QPS_INIT) || 1482 (nesqp->ibqp_state == IB_QPS_RTR)) && (nesqp->cm_id)) { 1483 cm_id = nesqp->cm_id; 1484 cm_event.event = IW_CM_EVENT_CONNECT_REPLY; 1485 cm_event.status = IW_CM_EVENT_STATUS_TIMEOUT; 1486 cm_event.local_addr = cm_id->local_addr; 1487 cm_event.remote_addr = cm_id->remote_addr; 1488 cm_event.private_data = NULL; 1489 cm_event.private_data_len = 0; 1490 1491 nes_debug(NES_DBG_QP, "Generating a CM Timeout Event for " 1492 "QP%u. cm_id = %p, refcount = %u. \n", 1493 nesqp->hwqp.qp_id, cm_id, atomic_read(&nesqp->refcount)); 1494 1495 cm_id->rem_ref(cm_id); 1496 ret = cm_id->event_handler(cm_id, &cm_event); 1497 if (ret) 1498 nes_debug(NES_DBG_QP, "OFA CM event_handler returned, ret=%d\n", ret); 1499 } 1500 1501 if (nesqp->user_mode) { 1502 if ((ibqp->uobject)&&(ibqp->uobject->context)) { 1503 nes_ucontext = to_nesucontext(ibqp->uobject->context); 1504 clear_bit(nesqp->mmap_sq_db_index, nes_ucontext->allocated_wqs); 1505 nes_ucontext->mmap_nesqp[nesqp->mmap_sq_db_index] = NULL; 1506 if (nes_ucontext->first_free_wq > nesqp->mmap_sq_db_index) { 1507 nes_ucontext->first_free_wq = nesqp->mmap_sq_db_index; 1508 } 1509 } 1510 if (nesqp->pbl_pbase && nesqp->sq_kmapped) { 1511 nesqp->sq_kmapped = 0; 1512 kunmap(nesqp->page); 1513 } 1514 } else { 1515 /* Clean any pending completions from the cq(s) */ 1516 if (nesqp->nesscq) 1517 nes_clean_cq(nesqp, nesqp->nesscq); 1518 1519 if ((nesqp->nesrcq) && (nesqp->nesrcq != nesqp->nesscq)) 1520 nes_clean_cq(nesqp, nesqp->nesrcq); 1521 } 1522 1523 nes_rem_ref(&nesqp->ibqp); 1524 return 0; 1525} 1526 1527 1528/** 1529 * nes_create_cq 1530 */ 1531static struct ib_cq *nes_create_cq(struct ib_device *ibdev, int entries, 1532 int comp_vector, 1533 struct ib_ucontext *context, struct ib_udata *udata) 1534{ 1535 u64 u64temp; 1536 struct nes_vnic *nesvnic = to_nesvnic(ibdev); 1537 struct nes_device *nesdev = nesvnic->nesdev; 1538 struct nes_adapter *nesadapter = nesdev->nesadapter; 1539 struct nes_cq *nescq; 1540 struct nes_ucontext *nes_ucontext = NULL; 1541 struct nes_cqp_request *cqp_request; 1542 void *mem = NULL; 1543 struct nes_hw_cqp_wqe *cqp_wqe; 1544 struct nes_pbl *nespbl = NULL; 1545 struct nes_create_cq_req req; 1546 struct nes_create_cq_resp resp; 1547 u32 cq_num = 0; 1548 u32 opcode = 0; 1549 u32 pbl_entries = 1; 1550 int err; 1551 unsigned long flags; 1552 int ret; 1553 1554 if (entries > nesadapter->max_cqe) 1555 return ERR_PTR(-EINVAL); 1556 1557 err = nes_alloc_resource(nesadapter, nesadapter->allocated_cqs, 1558 nesadapter->max_cq, &cq_num, &nesadapter->next_cq); 1559 if (err) { 1560 return ERR_PTR(err); 1561 } 1562 1563 nescq = kzalloc(sizeof(struct nes_cq), GFP_KERNEL); 1564 if (!nescq) { 1565 nes_free_resource(nesadapter, nesadapter->allocated_cqs, cq_num); 1566 nes_debug(NES_DBG_CQ, "Unable to allocate nes_cq struct\n"); 1567 return ERR_PTR(-ENOMEM); 1568 } 1569 1570 nescq->hw_cq.cq_size = max(entries + 1, 5); 1571 nescq->hw_cq.cq_number = cq_num; 1572 nescq->ibcq.cqe = nescq->hw_cq.cq_size - 1; 1573 1574 1575 if (context) { 1576 nes_ucontext = to_nesucontext(context); 1577 if (ib_copy_from_udata(&req, udata, sizeof (struct nes_create_cq_req))) { 1578 nes_free_resource(nesadapter, nesadapter->allocated_cqs, cq_num); 1579 kfree(nescq); 1580 return ERR_PTR(-EFAULT); 1581 } 1582 nesvnic->mcrq_ucontext = nes_ucontext; 1583 nes_ucontext->mcrqf = req.mcrqf; 1584 if (nes_ucontext->mcrqf) { 1585 if (nes_ucontext->mcrqf & 0x80000000) 1586 nescq->hw_cq.cq_number = nesvnic->nic.qp_id + 28 + 2 * ((nes_ucontext->mcrqf & 0xf) - 1); 1587 else if (nes_ucontext->mcrqf & 0x40000000) 1588 nescq->hw_cq.cq_number = nes_ucontext->mcrqf & 0xffff; 1589 else 1590 nescq->hw_cq.cq_number = nesvnic->mcrq_qp_id + nes_ucontext->mcrqf-1; 1591 nescq->mcrqf = nes_ucontext->mcrqf; 1592 nes_free_resource(nesadapter, nesadapter->allocated_cqs, cq_num); 1593 } 1594 nes_debug(NES_DBG_CQ, "CQ Virtual Address = %08lX, size = %u.\n", 1595 (unsigned long)req.user_cq_buffer, entries); 1596 err = 1; 1597 list_for_each_entry(nespbl, &nes_ucontext->cq_reg_mem_list, list) { 1598 if (nespbl->user_base == (unsigned long )req.user_cq_buffer) { 1599 list_del(&nespbl->list); 1600 err = 0; 1601 nes_debug(NES_DBG_CQ, "Found PBL for virtual CQ. nespbl=%p.\n", 1602 nespbl); 1603 break; 1604 } 1605 } 1606 if (err) { 1607 nes_free_resource(nesadapter, nesadapter->allocated_cqs, cq_num); 1608 kfree(nescq); 1609 return ERR_PTR(-EFAULT); 1610 } 1611 1612 pbl_entries = nespbl->pbl_size >> 3; 1613 nescq->cq_mem_size = 0; 1614 } else { 1615 nescq->cq_mem_size = nescq->hw_cq.cq_size * sizeof(struct nes_hw_cqe); 1616 nes_debug(NES_DBG_CQ, "Attempting to allocate pci memory (%u entries, %u bytes) for CQ%u.\n", 1617 entries, nescq->cq_mem_size, nescq->hw_cq.cq_number); 1618 1619 /* allocate the physical buffer space */ 1620 mem = pci_alloc_consistent(nesdev->pcidev, nescq->cq_mem_size, 1621 &nescq->hw_cq.cq_pbase); 1622 if (!mem) { 1623 printk(KERN_ERR PFX "Unable to allocate pci memory for cq\n"); 1624 nes_free_resource(nesadapter, nesadapter->allocated_cqs, cq_num); 1625 kfree(nescq); 1626 return ERR_PTR(-ENOMEM); 1627 } 1628 1629 memset(mem, 0, nescq->cq_mem_size); 1630 nescq->hw_cq.cq_vbase = mem; 1631 nescq->hw_cq.cq_head = 0; 1632 nes_debug(NES_DBG_CQ, "CQ%u virtual address @ %p, phys = 0x%08X\n", 1633 nescq->hw_cq.cq_number, nescq->hw_cq.cq_vbase, 1634 (u32)nescq->hw_cq.cq_pbase); 1635 } 1636 1637 nescq->hw_cq.ce_handler = nes_iwarp_ce_handler; 1638 spin_lock_init(&nescq->lock); 1639 1640 /* send CreateCQ request to CQP */ 1641 cqp_request = nes_get_cqp_request(nesdev); 1642 if (cqp_request == NULL) { 1643 nes_debug(NES_DBG_CQ, "Failed to get a cqp_request.\n"); 1644 if (!context) 1645 pci_free_consistent(nesdev->pcidev, nescq->cq_mem_size, mem, 1646 nescq->hw_cq.cq_pbase); 1647 else { 1648 pci_free_consistent(nesdev->pcidev, nespbl->pbl_size, 1649 nespbl->pbl_vbase, nespbl->pbl_pbase); 1650 kfree(nespbl); 1651 } 1652 1653 nes_free_resource(nesadapter, nesadapter->allocated_cqs, cq_num); 1654 kfree(nescq); 1655 return ERR_PTR(-ENOMEM); 1656 } 1657 cqp_request->waiting = 1; 1658 cqp_wqe = &cqp_request->cqp_wqe; 1659 1660 opcode = NES_CQP_CREATE_CQ | NES_CQP_CQ_CEQ_VALID | 1661 NES_CQP_CQ_CHK_OVERFLOW | 1662 NES_CQP_CQ_CEQE_MASK | ((u32)nescq->hw_cq.cq_size << 16); 1663 1664 spin_lock_irqsave(&nesadapter->pbl_lock, flags); 1665 1666 if (pbl_entries != 1) { 1667 if (pbl_entries > 32) { 1668 /* use 4k pbl */ 1669 nes_debug(NES_DBG_CQ, "pbl_entries=%u, use a 4k PBL\n", pbl_entries); 1670 if (nesadapter->free_4kpbl == 0) { 1671 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 1672 nes_free_cqp_request(nesdev, cqp_request); 1673 if (!context) 1674 pci_free_consistent(nesdev->pcidev, nescq->cq_mem_size, mem, 1675 nescq->hw_cq.cq_pbase); 1676 else { 1677 pci_free_consistent(nesdev->pcidev, nespbl->pbl_size, 1678 nespbl->pbl_vbase, nespbl->pbl_pbase); 1679 kfree(nespbl); 1680 } 1681 nes_free_resource(nesadapter, nesadapter->allocated_cqs, cq_num); 1682 kfree(nescq); 1683 return ERR_PTR(-ENOMEM); 1684 } else { 1685 opcode |= (NES_CQP_CQ_VIRT | NES_CQP_CQ_4KB_CHUNK); 1686 nescq->virtual_cq = 2; 1687 nesadapter->free_4kpbl--; 1688 } 1689 } else { 1690 /* use 256 byte pbl */ 1691 nes_debug(NES_DBG_CQ, "pbl_entries=%u, use a 256 byte PBL\n", pbl_entries); 1692 if (nesadapter->free_256pbl == 0) { 1693 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 1694 nes_free_cqp_request(nesdev, cqp_request); 1695 if (!context) 1696 pci_free_consistent(nesdev->pcidev, nescq->cq_mem_size, mem, 1697 nescq->hw_cq.cq_pbase); 1698 else { 1699 pci_free_consistent(nesdev->pcidev, nespbl->pbl_size, 1700 nespbl->pbl_vbase, nespbl->pbl_pbase); 1701 kfree(nespbl); 1702 } 1703 nes_free_resource(nesadapter, nesadapter->allocated_cqs, cq_num); 1704 kfree(nescq); 1705 return ERR_PTR(-ENOMEM); 1706 } else { 1707 opcode |= NES_CQP_CQ_VIRT; 1708 nescq->virtual_cq = 1; 1709 nesadapter->free_256pbl--; 1710 } 1711 } 1712 } 1713 1714 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 1715 1716 nes_fill_init_cqp_wqe(cqp_wqe, nesdev); 1717 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX, opcode); 1718 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_ID_IDX, 1719 (nescq->hw_cq.cq_number | ((u32)nesdev->ceq_index << 16))); 1720 1721 if (context) { 1722 if (pbl_entries != 1) 1723 u64temp = (u64)nespbl->pbl_pbase; 1724 else 1725 u64temp = le64_to_cpu(nespbl->pbl_vbase[0]); 1726 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_CQ_WQE_DOORBELL_INDEX_HIGH_IDX, 1727 nes_ucontext->mmap_db_index[0]); 1728 } else { 1729 u64temp = (u64)nescq->hw_cq.cq_pbase; 1730 cqp_wqe->wqe_words[NES_CQP_CQ_WQE_DOORBELL_INDEX_HIGH_IDX] = 0; 1731 } 1732 set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_CQ_WQE_PBL_LOW_IDX, u64temp); 1733 cqp_wqe->wqe_words[NES_CQP_CQ_WQE_CQ_CONTEXT_HIGH_IDX] = 0; 1734 u64temp = (u64)(unsigned long)&nescq->hw_cq; 1735 cqp_wqe->wqe_words[NES_CQP_CQ_WQE_CQ_CONTEXT_LOW_IDX] = 1736 cpu_to_le32((u32)(u64temp >> 1)); 1737 cqp_wqe->wqe_words[NES_CQP_CQ_WQE_CQ_CONTEXT_HIGH_IDX] = 1738 cpu_to_le32(((u32)((u64temp) >> 33)) & 0x7FFFFFFF); 1739 1740 atomic_set(&cqp_request->refcount, 2); 1741 nes_post_cqp_request(nesdev, cqp_request); 1742 1743 /* Wait for CQP */ 1744 nes_debug(NES_DBG_CQ, "Waiting for create iWARP CQ%u to complete.\n", 1745 nescq->hw_cq.cq_number); 1746 ret = wait_event_timeout(cqp_request->waitq, (0 != cqp_request->request_done), 1747 NES_EVENT_TIMEOUT * 2); 1748 nes_debug(NES_DBG_CQ, "Create iWARP CQ%u completed, wait_event_timeout ret = %d.\n", 1749 nescq->hw_cq.cq_number, ret); 1750 if ((!ret) || (cqp_request->major_code)) { 1751 nes_put_cqp_request(nesdev, cqp_request); 1752 if (!context) 1753 pci_free_consistent(nesdev->pcidev, nescq->cq_mem_size, mem, 1754 nescq->hw_cq.cq_pbase); 1755 else { 1756 pci_free_consistent(nesdev->pcidev, nespbl->pbl_size, 1757 nespbl->pbl_vbase, nespbl->pbl_pbase); 1758 kfree(nespbl); 1759 } 1760 nes_free_resource(nesadapter, nesadapter->allocated_cqs, cq_num); 1761 kfree(nescq); 1762 return ERR_PTR(-EIO); 1763 } 1764 nes_put_cqp_request(nesdev, cqp_request); 1765 1766 if (context) { 1767 /* free the nespbl */ 1768 pci_free_consistent(nesdev->pcidev, nespbl->pbl_size, nespbl->pbl_vbase, 1769 nespbl->pbl_pbase); 1770 kfree(nespbl); 1771 resp.cq_id = nescq->hw_cq.cq_number; 1772 resp.cq_size = nescq->hw_cq.cq_size; 1773 resp.mmap_db_index = 0; 1774 if (ib_copy_to_udata(udata, &resp, sizeof resp)) { 1775 nes_free_resource(nesadapter, nesadapter->allocated_cqs, cq_num); 1776 kfree(nescq); 1777 return ERR_PTR(-EFAULT); 1778 } 1779 } 1780 1781 return &nescq->ibcq; 1782} 1783 1784 1785/** 1786 * nes_destroy_cq 1787 */ 1788static int nes_destroy_cq(struct ib_cq *ib_cq) 1789{ 1790 struct nes_cq *nescq; 1791 struct nes_device *nesdev; 1792 struct nes_vnic *nesvnic; 1793 struct nes_adapter *nesadapter; 1794 struct nes_hw_cqp_wqe *cqp_wqe; 1795 struct nes_cqp_request *cqp_request; 1796 unsigned long flags; 1797 u32 opcode = 0; 1798 int ret; 1799 1800 if (ib_cq == NULL) 1801 return 0; 1802 1803 nescq = to_nescq(ib_cq); 1804 nesvnic = to_nesvnic(ib_cq->device); 1805 nesdev = nesvnic->nesdev; 1806 nesadapter = nesdev->nesadapter; 1807 1808 nes_debug(NES_DBG_CQ, "Destroy CQ%u\n", nescq->hw_cq.cq_number); 1809 1810 /* Send DestroyCQ request to CQP */ 1811 cqp_request = nes_get_cqp_request(nesdev); 1812 if (cqp_request == NULL) { 1813 nes_debug(NES_DBG_CQ, "Failed to get a cqp_request.\n"); 1814 return -ENOMEM; 1815 } 1816 cqp_request->waiting = 1; 1817 cqp_wqe = &cqp_request->cqp_wqe; 1818 opcode = NES_CQP_DESTROY_CQ | (nescq->hw_cq.cq_size << 16); 1819 spin_lock_irqsave(&nesadapter->pbl_lock, flags); 1820 if (nescq->virtual_cq == 1) { 1821 nesadapter->free_256pbl++; 1822 if (nesadapter->free_256pbl > nesadapter->max_256pbl) { 1823 printk(KERN_ERR PFX "%s: free 256B PBLs(%u) has exceeded the max(%u)\n", 1824 __func__, nesadapter->free_256pbl, nesadapter->max_256pbl); 1825 } 1826 } else if (nescq->virtual_cq == 2) { 1827 nesadapter->free_4kpbl++; 1828 if (nesadapter->free_4kpbl > nesadapter->max_4kpbl) { 1829 printk(KERN_ERR PFX "%s: free 4K PBLs(%u) has exceeded the max(%u)\n", 1830 __func__, nesadapter->free_4kpbl, nesadapter->max_4kpbl); 1831 } 1832 opcode |= NES_CQP_CQ_4KB_CHUNK; 1833 } 1834 1835 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 1836 1837 nes_fill_init_cqp_wqe(cqp_wqe, nesdev); 1838 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX, opcode); 1839 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_ID_IDX, 1840 (nescq->hw_cq.cq_number | ((u32)PCI_FUNC(nesdev->pcidev->devfn) << 16))); 1841 if (!nescq->mcrqf) 1842 nes_free_resource(nesadapter, nesadapter->allocated_cqs, nescq->hw_cq.cq_number); 1843 1844 atomic_set(&cqp_request->refcount, 2); 1845 nes_post_cqp_request(nesdev, cqp_request); 1846 1847 /* Wait for CQP */ 1848 nes_debug(NES_DBG_CQ, "Waiting for destroy iWARP CQ%u to complete.\n", 1849 nescq->hw_cq.cq_number); 1850 ret = wait_event_timeout(cqp_request->waitq, (0 != cqp_request->request_done), 1851 NES_EVENT_TIMEOUT); 1852 nes_debug(NES_DBG_CQ, "Destroy iWARP CQ%u completed, wait_event_timeout ret = %u," 1853 " CQP Major:Minor codes = 0x%04X:0x%04X.\n", 1854 nescq->hw_cq.cq_number, ret, cqp_request->major_code, 1855 cqp_request->minor_code); 1856 if (!ret) { 1857 nes_debug(NES_DBG_CQ, "iWARP CQ%u destroy timeout expired\n", 1858 nescq->hw_cq.cq_number); 1859 ret = -ETIME; 1860 } else if (cqp_request->major_code) { 1861 nes_debug(NES_DBG_CQ, "iWARP CQ%u destroy failed\n", 1862 nescq->hw_cq.cq_number); 1863 ret = -EIO; 1864 } else { 1865 ret = 0; 1866 } 1867 nes_put_cqp_request(nesdev, cqp_request); 1868 1869 if (nescq->cq_mem_size) 1870 pci_free_consistent(nesdev->pcidev, nescq->cq_mem_size, 1871 nescq->hw_cq.cq_vbase, nescq->hw_cq.cq_pbase); 1872 kfree(nescq); 1873 1874 return ret; 1875} 1876 1877/** 1878 * root_256 1879 */ 1880static u32 root_256(struct nes_device *nesdev, 1881 struct nes_root_vpbl *root_vpbl, 1882 struct nes_root_vpbl *new_root, 1883 u16 pbl_count_4k) 1884{ 1885 u64 leaf_pbl; 1886 int i, j, k; 1887 1888 if (pbl_count_4k == 1) { 1889 new_root->pbl_vbase = pci_alloc_consistent(nesdev->pcidev, 1890 512, &new_root->pbl_pbase); 1891 1892 if (new_root->pbl_vbase == NULL) 1893 return 0; 1894 1895 leaf_pbl = (u64)root_vpbl->pbl_pbase; 1896 for (i = 0; i < 16; i++) { 1897 new_root->pbl_vbase[i].pa_low = 1898 cpu_to_le32((u32)leaf_pbl); 1899 new_root->pbl_vbase[i].pa_high = 1900 cpu_to_le32((u32)((((u64)leaf_pbl) >> 32))); 1901 leaf_pbl += 256; 1902 } 1903 } else { 1904 for (i = 3; i >= 0; i--) { 1905 j = i * 16; 1906 root_vpbl->pbl_vbase[j] = root_vpbl->pbl_vbase[i]; 1907 leaf_pbl = le32_to_cpu(root_vpbl->pbl_vbase[j].pa_low) + 1908 (((u64)le32_to_cpu(root_vpbl->pbl_vbase[j].pa_high)) 1909 << 32); 1910 for (k = 1; k < 16; k++) { 1911 leaf_pbl += 256; 1912 root_vpbl->pbl_vbase[j + k].pa_low = 1913 cpu_to_le32((u32)leaf_pbl); 1914 root_vpbl->pbl_vbase[j + k].pa_high = 1915 cpu_to_le32((u32)((((u64)leaf_pbl) >> 32))); 1916 } 1917 } 1918 } 1919 1920 return 1; 1921} 1922 1923 1924/** 1925 * nes_reg_mr 1926 */ 1927static int nes_reg_mr(struct nes_device *nesdev, struct nes_pd *nespd, 1928 u32 stag, u64 region_length, struct nes_root_vpbl *root_vpbl, 1929 dma_addr_t single_buffer, u16 pbl_count_4k, 1930 u16 residual_page_count_4k, int acc, u64 *iova_start, 1931 u16 *actual_pbl_cnt, u8 *used_4k_pbls) 1932{ 1933 struct nes_hw_cqp_wqe *cqp_wqe; 1934 struct nes_cqp_request *cqp_request; 1935 unsigned long flags; 1936 int ret; 1937 struct nes_adapter *nesadapter = nesdev->nesadapter; 1938 uint pg_cnt = 0; 1939 u16 pbl_count_256 = 0; 1940 u16 pbl_count = 0; 1941 u8 use_256_pbls = 0; 1942 u8 use_4k_pbls = 0; 1943 u16 use_two_level = (pbl_count_4k > 1) ? 1 : 0; 1944 struct nes_root_vpbl new_root = { 0, NULL, NULL }; 1945 u32 opcode = 0; 1946 u16 major_code; 1947 1948 /* Register the region with the adapter */ 1949 cqp_request = nes_get_cqp_request(nesdev); 1950 if (cqp_request == NULL) { 1951 nes_debug(NES_DBG_MR, "Failed to get a cqp_request.\n"); 1952 return -ENOMEM; 1953 } 1954 cqp_request->waiting = 1; 1955 cqp_wqe = &cqp_request->cqp_wqe; 1956 1957 if (pbl_count_4k) { 1958 spin_lock_irqsave(&nesadapter->pbl_lock, flags); 1959 1960 pg_cnt = ((pbl_count_4k - 1) * 512) + residual_page_count_4k; 1961 pbl_count_256 = (pg_cnt + 31) / 32; 1962 if (pg_cnt <= 32) { 1963 if (pbl_count_256 <= nesadapter->free_256pbl) 1964 use_256_pbls = 1; 1965 else if (pbl_count_4k <= nesadapter->free_4kpbl) 1966 use_4k_pbls = 1; 1967 } else if (pg_cnt <= 2048) { 1968 if (((pbl_count_4k + use_two_level) <= nesadapter->free_4kpbl) && 1969 (nesadapter->free_4kpbl > (nesadapter->max_4kpbl >> 1))) { 1970 use_4k_pbls = 1; 1971 } else if ((pbl_count_256 + 1) <= nesadapter->free_256pbl) { 1972 use_256_pbls = 1; 1973 use_two_level = 1; 1974 } else if ((pbl_count_4k + use_two_level) <= nesadapter->free_4kpbl) { 1975 use_4k_pbls = 1; 1976 } 1977 } else { 1978 if ((pbl_count_4k + 1) <= nesadapter->free_4kpbl) 1979 use_4k_pbls = 1; 1980 } 1981 1982 if (use_256_pbls) { 1983 pbl_count = pbl_count_256; 1984 nesadapter->free_256pbl -= pbl_count + use_two_level; 1985 } else if (use_4k_pbls) { 1986 pbl_count = pbl_count_4k; 1987 nesadapter->free_4kpbl -= pbl_count + use_two_level; 1988 } else { 1989 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 1990 nes_debug(NES_DBG_MR, "Out of Pbls\n"); 1991 nes_free_cqp_request(nesdev, cqp_request); 1992 return -ENOMEM; 1993 } 1994 1995 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 1996 } 1997 1998 if (use_256_pbls && use_two_level) { 1999 if (root_256(nesdev, root_vpbl, &new_root, pbl_count_4k) == 1) { 2000 if (new_root.pbl_pbase != 0) 2001 root_vpbl = &new_root; 2002 } else { 2003 spin_lock_irqsave(&nesadapter->pbl_lock, flags); 2004 nesadapter->free_256pbl += pbl_count_256 + use_two_level; 2005 use_256_pbls = 0; 2006 2007 if (pbl_count_4k == 1) 2008 use_two_level = 0; 2009 pbl_count = pbl_count_4k; 2010 2011 if ((pbl_count_4k + use_two_level) <= nesadapter->free_4kpbl) { 2012 nesadapter->free_4kpbl -= pbl_count + use_two_level; 2013 use_4k_pbls = 1; 2014 } 2015 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 2016 2017 if (use_4k_pbls == 0) 2018 return -ENOMEM; 2019 } 2020 } 2021 2022 opcode = NES_CQP_REGISTER_STAG | NES_CQP_STAG_RIGHTS_LOCAL_READ | 2023 NES_CQP_STAG_VA_TO | NES_CQP_STAG_MR; 2024 if (acc & IB_ACCESS_LOCAL_WRITE) 2025 opcode |= NES_CQP_STAG_RIGHTS_LOCAL_WRITE; 2026 if (acc & IB_ACCESS_REMOTE_WRITE) 2027 opcode |= NES_CQP_STAG_RIGHTS_REMOTE_WRITE | NES_CQP_STAG_REM_ACC_EN; 2028 if (acc & IB_ACCESS_REMOTE_READ) 2029 opcode |= NES_CQP_STAG_RIGHTS_REMOTE_READ | NES_CQP_STAG_REM_ACC_EN; 2030 if (acc & IB_ACCESS_MW_BIND) 2031 opcode |= NES_CQP_STAG_RIGHTS_WINDOW_BIND | NES_CQP_STAG_REM_ACC_EN; 2032 2033 nes_fill_init_cqp_wqe(cqp_wqe, nesdev); 2034 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX, opcode); 2035 set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_VA_LOW_IDX, *iova_start); 2036 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_LEN_LOW_IDX, region_length); 2037 2038 cqp_wqe->wqe_words[NES_CQP_STAG_WQE_LEN_HIGH_PD_IDX] = 2039 cpu_to_le32((u32)(region_length >> 8) & 0xff000000); 2040 cqp_wqe->wqe_words[NES_CQP_STAG_WQE_LEN_HIGH_PD_IDX] |= 2041 cpu_to_le32(nespd->pd_id & 0x00007fff); 2042 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_STAG_IDX, stag); 2043 2044 if (pbl_count == 0) { 2045 set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_PA_LOW_IDX, single_buffer); 2046 } else { 2047 set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_PA_LOW_IDX, root_vpbl->pbl_pbase); 2048 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_PBL_BLK_COUNT_IDX, pbl_count); 2049 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_PBL_LEN_IDX, (pg_cnt * 8)); 2050 2051 if (use_4k_pbls) 2052 cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] |= cpu_to_le32(NES_CQP_STAG_PBL_BLK_SIZE); 2053 } 2054 barrier(); 2055 2056 atomic_set(&cqp_request->refcount, 2); 2057 nes_post_cqp_request(nesdev, cqp_request); 2058 2059 /* Wait for CQP */ 2060 ret = wait_event_timeout(cqp_request->waitq, (0 != cqp_request->request_done), 2061 NES_EVENT_TIMEOUT); 2062 nes_debug(NES_DBG_MR, "Register STag 0x%08X completed, wait_event_timeout ret = %u," 2063 " CQP Major:Minor codes = 0x%04X:0x%04X.\n", 2064 stag, ret, cqp_request->major_code, cqp_request->minor_code); 2065 major_code = cqp_request->major_code; 2066 nes_put_cqp_request(nesdev, cqp_request); 2067 2068 if ((!ret || major_code) && pbl_count != 0) { 2069 spin_lock_irqsave(&nesadapter->pbl_lock, flags); 2070 if (use_256_pbls) 2071 nesadapter->free_256pbl += pbl_count + use_two_level; 2072 else if (use_4k_pbls) 2073 nesadapter->free_4kpbl += pbl_count + use_two_level; 2074 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 2075 } 2076 if (new_root.pbl_pbase) 2077 pci_free_consistent(nesdev->pcidev, 512, new_root.pbl_vbase, 2078 new_root.pbl_pbase); 2079 2080 if (!ret) 2081 return -ETIME; 2082 else if (major_code) 2083 return -EIO; 2084 2085 *actual_pbl_cnt = pbl_count + use_two_level; 2086 *used_4k_pbls = use_4k_pbls; 2087 return 0; 2088} 2089 2090 2091/** 2092 * nes_reg_phys_mr 2093 */ 2094static struct ib_mr *nes_reg_phys_mr(struct ib_pd *ib_pd, 2095 struct ib_phys_buf *buffer_list, int num_phys_buf, int acc, 2096 u64 * iova_start) 2097{ 2098 u64 region_length; 2099 struct nes_pd *nespd = to_nespd(ib_pd); 2100 struct nes_vnic *nesvnic = to_nesvnic(ib_pd->device); 2101 struct nes_device *nesdev = nesvnic->nesdev; 2102 struct nes_adapter *nesadapter = nesdev->nesadapter; 2103 struct nes_mr *nesmr; 2104 struct ib_mr *ibmr; 2105 struct nes_vpbl vpbl; 2106 struct nes_root_vpbl root_vpbl; 2107 u32 stag; 2108 u32 i; 2109 unsigned long mask; 2110 u32 stag_index = 0; 2111 u32 next_stag_index = 0; 2112 u32 driver_key = 0; 2113 u32 root_pbl_index = 0; 2114 u32 cur_pbl_index = 0; 2115 int err = 0; 2116 int ret = 0; 2117 u16 pbl_count = 0; 2118 u8 single_page = 1; 2119 u8 stag_key = 0; 2120 2121 region_length = 0; 2122 vpbl.pbl_vbase = NULL; 2123 root_vpbl.pbl_vbase = NULL; 2124 root_vpbl.pbl_pbase = 0; 2125 2126 get_random_bytes(&next_stag_index, sizeof(next_stag_index)); 2127 stag_key = (u8)next_stag_index; 2128 2129 driver_key = 0; 2130 2131 next_stag_index >>= 8; 2132 next_stag_index %= nesadapter->max_mr; 2133 if (num_phys_buf > (1024*512)) { 2134 return ERR_PTR(-E2BIG); 2135 } 2136 2137 if ((buffer_list[0].addr ^ *iova_start) & ~PAGE_MASK) 2138 return ERR_PTR(-EINVAL); 2139 2140 err = nes_alloc_resource(nesadapter, nesadapter->allocated_mrs, nesadapter->max_mr, 2141 &stag_index, &next_stag_index); 2142 if (err) { 2143 return ERR_PTR(err); 2144 } 2145 2146 nesmr = kzalloc(sizeof(*nesmr), GFP_KERNEL); 2147 if (!nesmr) { 2148 nes_free_resource(nesadapter, nesadapter->allocated_mrs, stag_index); 2149 return ERR_PTR(-ENOMEM); 2150 } 2151 2152 for (i = 0; i < num_phys_buf; i++) { 2153 2154 if ((i & 0x01FF) == 0) { 2155 if (root_pbl_index == 1) { 2156 /* Allocate the root PBL */ 2157 root_vpbl.pbl_vbase = pci_alloc_consistent(nesdev->pcidev, 8192, 2158 &root_vpbl.pbl_pbase); 2159 nes_debug(NES_DBG_MR, "Allocating root PBL, va = %p, pa = 0x%08X\n", 2160 root_vpbl.pbl_vbase, (unsigned int)root_vpbl.pbl_pbase); 2161 if (!root_vpbl.pbl_vbase) { 2162 pci_free_consistent(nesdev->pcidev, 4096, vpbl.pbl_vbase, 2163 vpbl.pbl_pbase); 2164 nes_free_resource(nesadapter, nesadapter->allocated_mrs, stag_index); 2165 kfree(nesmr); 2166 return ERR_PTR(-ENOMEM); 2167 } 2168 root_vpbl.leaf_vpbl = kzalloc(sizeof(*root_vpbl.leaf_vpbl)*1024, GFP_KERNEL); 2169 if (!root_vpbl.leaf_vpbl) { 2170 pci_free_consistent(nesdev->pcidev, 8192, root_vpbl.pbl_vbase, 2171 root_vpbl.pbl_pbase); 2172 pci_free_consistent(nesdev->pcidev, 4096, vpbl.pbl_vbase, 2173 vpbl.pbl_pbase); 2174 nes_free_resource(nesadapter, nesadapter->allocated_mrs, stag_index); 2175 kfree(nesmr); 2176 return ERR_PTR(-ENOMEM); 2177 } 2178 root_vpbl.pbl_vbase[0].pa_low = cpu_to_le32((u32)vpbl.pbl_pbase); 2179 root_vpbl.pbl_vbase[0].pa_high = 2180 cpu_to_le32((u32)((((u64)vpbl.pbl_pbase) >> 32))); 2181 root_vpbl.leaf_vpbl[0] = vpbl; 2182 } 2183 /* Allocate a 4K buffer for the PBL */ 2184 vpbl.pbl_vbase = pci_alloc_consistent(nesdev->pcidev, 4096, 2185 &vpbl.pbl_pbase); 2186 nes_debug(NES_DBG_MR, "Allocating leaf PBL, va = %p, pa = 0x%016lX\n", 2187 vpbl.pbl_vbase, (unsigned long)vpbl.pbl_pbase); 2188 if (!vpbl.pbl_vbase) { 2189 nes_free_resource(nesadapter, nesadapter->allocated_mrs, stag_index); 2190 ibmr = ERR_PTR(-ENOMEM); 2191 kfree(nesmr); 2192 goto reg_phys_err; 2193 } 2194 /* Fill in the root table */ 2195 if (1 <= root_pbl_index) { 2196 root_vpbl.pbl_vbase[root_pbl_index].pa_low = 2197 cpu_to_le32((u32)vpbl.pbl_pbase); 2198 root_vpbl.pbl_vbase[root_pbl_index].pa_high = 2199 cpu_to_le32((u32)((((u64)vpbl.pbl_pbase) >> 32))); 2200 root_vpbl.leaf_vpbl[root_pbl_index] = vpbl; 2201 } 2202 root_pbl_index++; 2203 cur_pbl_index = 0; 2204 } 2205 2206 mask = !buffer_list[i].size; 2207 if (i != 0) 2208 mask |= buffer_list[i].addr; 2209 if (i != num_phys_buf - 1) 2210 mask |= buffer_list[i].addr + buffer_list[i].size; 2211 2212 if (mask & ~PAGE_MASK) { 2213 nes_free_resource(nesadapter, nesadapter->allocated_mrs, stag_index); 2214 nes_debug(NES_DBG_MR, "Invalid buffer addr or size\n"); 2215 ibmr = ERR_PTR(-EINVAL); 2216 kfree(nesmr); 2217 goto reg_phys_err; 2218 } 2219 2220 region_length += buffer_list[i].size; 2221 if ((i != 0) && (single_page)) { 2222 if ((buffer_list[i-1].addr+PAGE_SIZE) != buffer_list[i].addr) 2223 single_page = 0; 2224 } 2225 vpbl.pbl_vbase[cur_pbl_index].pa_low = cpu_to_le32((u32)buffer_list[i].addr & PAGE_MASK); 2226 vpbl.pbl_vbase[cur_pbl_index++].pa_high = 2227 cpu_to_le32((u32)((((u64)buffer_list[i].addr) >> 32))); 2228 } 2229 2230 stag = stag_index << 8; 2231 stag |= driver_key; 2232 stag += (u32)stag_key; 2233 2234 nes_debug(NES_DBG_MR, "Registering STag 0x%08X, VA = 0x%016lX," 2235 " length = 0x%016lX, index = 0x%08X\n", 2236 stag, (unsigned long)*iova_start, (unsigned long)region_length, stag_index); 2237 2238 /* Make the leaf PBL the root if only one PBL */ 2239 if (root_pbl_index == 1) { 2240 root_vpbl.pbl_pbase = vpbl.pbl_pbase; 2241 } 2242 2243 if (single_page) { 2244 pbl_count = 0; 2245 } else { 2246 pbl_count = root_pbl_index; 2247 } 2248 ret = nes_reg_mr(nesdev, nespd, stag, region_length, &root_vpbl, 2249 buffer_list[0].addr, pbl_count, (u16)cur_pbl_index, acc, iova_start, 2250 &nesmr->pbls_used, &nesmr->pbl_4k); 2251 2252 if (ret == 0) { 2253 nesmr->ibmr.rkey = stag; 2254 nesmr->ibmr.lkey = stag; 2255 nesmr->mode = IWNES_MEMREG_TYPE_MEM; 2256 ibmr = &nesmr->ibmr; 2257 } else { 2258 kfree(nesmr); 2259 ibmr = ERR_PTR(-ENOMEM); 2260 } 2261 2262 reg_phys_err: 2263 /* free the resources */ 2264 if (root_pbl_index == 1) { 2265 /* single PBL case */ 2266 pci_free_consistent(nesdev->pcidev, 4096, vpbl.pbl_vbase, vpbl.pbl_pbase); 2267 } else { 2268 for (i=0; i<root_pbl_index; i++) { 2269 pci_free_consistent(nesdev->pcidev, 4096, root_vpbl.leaf_vpbl[i].pbl_vbase, 2270 root_vpbl.leaf_vpbl[i].pbl_pbase); 2271 } 2272 kfree(root_vpbl.leaf_vpbl); 2273 pci_free_consistent(nesdev->pcidev, 8192, root_vpbl.pbl_vbase, 2274 root_vpbl.pbl_pbase); 2275 } 2276 2277 return ibmr; 2278} 2279 2280 2281/** 2282 * nes_get_dma_mr 2283 */ 2284static struct ib_mr *nes_get_dma_mr(struct ib_pd *pd, int acc) 2285{ 2286 struct ib_phys_buf bl; 2287 u64 kva = 0; 2288 2289 nes_debug(NES_DBG_MR, "\n"); 2290 2291 bl.size = (u64)0xffffffffffULL; 2292 bl.addr = 0; 2293 return nes_reg_phys_mr(pd, &bl, 1, acc, &kva); 2294} 2295 2296 2297/** 2298 * nes_reg_user_mr 2299 */ 2300static struct ib_mr *nes_reg_user_mr(struct ib_pd *pd, u64 start, u64 length, 2301 u64 virt, int acc, struct ib_udata *udata) 2302{ 2303 u64 iova_start; 2304 __le64 *pbl; 2305 u64 region_length; 2306 dma_addr_t last_dma_addr = 0; 2307 dma_addr_t first_dma_addr = 0; 2308 struct nes_pd *nespd = to_nespd(pd); 2309 struct nes_vnic *nesvnic = to_nesvnic(pd->device); 2310 struct nes_device *nesdev = nesvnic->nesdev; 2311 struct nes_adapter *nesadapter = nesdev->nesadapter; 2312 struct ib_mr *ibmr = ERR_PTR(-EINVAL); 2313 struct ib_umem_chunk *chunk; 2314 struct nes_ucontext *nes_ucontext; 2315 struct nes_pbl *nespbl; 2316 struct nes_mr *nesmr; 2317 struct ib_umem *region; 2318 struct nes_mem_reg_req req; 2319 struct nes_vpbl vpbl; 2320 struct nes_root_vpbl root_vpbl; 2321 int nmap_index, page_index; 2322 int page_count = 0; 2323 int err, pbl_depth = 0; 2324 int chunk_pages; 2325 int ret; 2326 u32 stag; 2327 u32 stag_index = 0; 2328 u32 next_stag_index; 2329 u32 driver_key; 2330 u32 root_pbl_index = 0; 2331 u32 cur_pbl_index = 0; 2332 u32 skip_pages; 2333 u16 pbl_count; 2334 u8 single_page = 1; 2335 u8 stag_key; 2336 2337 region = ib_umem_get(pd->uobject->context, start, length, acc, 0); 2338 if (IS_ERR(region)) { 2339 return (struct ib_mr *)region; 2340 } 2341 2342 nes_debug(NES_DBG_MR, "User base = 0x%lX, Virt base = 0x%lX, length = %u," 2343 " offset = %u, page size = %u.\n", 2344 (unsigned long int)start, (unsigned long int)virt, (u32)length, 2345 region->offset, region->page_size); 2346 2347 skip_pages = ((u32)region->offset) >> 12; 2348 2349 if (ib_copy_from_udata(&req, udata, sizeof(req))) 2350 return ERR_PTR(-EFAULT); 2351 nes_debug(NES_DBG_MR, "Memory Registration type = %08X.\n", req.reg_type); 2352 2353 switch (req.reg_type) { 2354 case IWNES_MEMREG_TYPE_MEM: 2355 pbl_depth = 0; 2356 region_length = 0; 2357 vpbl.pbl_vbase = NULL; 2358 root_vpbl.pbl_vbase = NULL; 2359 root_vpbl.pbl_pbase = 0; 2360 2361 get_random_bytes(&next_stag_index, sizeof(next_stag_index)); 2362 stag_key = (u8)next_stag_index; 2363 2364 driver_key = next_stag_index & 0x70000000; 2365 2366 next_stag_index >>= 8; 2367 next_stag_index %= nesadapter->max_mr; 2368 2369 err = nes_alloc_resource(nesadapter, nesadapter->allocated_mrs, 2370 nesadapter->max_mr, &stag_index, &next_stag_index); 2371 if (err) { 2372 ib_umem_release(region); 2373 return ERR_PTR(err); 2374 } 2375 2376 nesmr = kzalloc(sizeof(*nesmr), GFP_KERNEL); 2377 if (!nesmr) { 2378 ib_umem_release(region); 2379 nes_free_resource(nesadapter, nesadapter->allocated_mrs, stag_index); 2380 return ERR_PTR(-ENOMEM); 2381 } 2382 nesmr->region = region; 2383 2384 list_for_each_entry(chunk, ®ion->chunk_list, list) { 2385 nes_debug(NES_DBG_MR, "Chunk: nents = %u, nmap = %u .\n", 2386 chunk->nents, chunk->nmap); 2387 for (nmap_index = 0; nmap_index < chunk->nmap; ++nmap_index) { 2388 if (sg_dma_address(&chunk->page_list[nmap_index]) & ~PAGE_MASK) { 2389 ib_umem_release(region); 2390 nes_free_resource(nesadapter, nesadapter->allocated_mrs, stag_index); 2391 nes_debug(NES_DBG_MR, "Unaligned Memory Buffer: 0x%x\n", 2392 (unsigned int) sg_dma_address(&chunk->page_list[nmap_index])); 2393 ibmr = ERR_PTR(-EINVAL); 2394 kfree(nesmr); 2395 goto reg_user_mr_err; 2396 } 2397 2398 if (!sg_dma_len(&chunk->page_list[nmap_index])) { 2399 ib_umem_release(region); 2400 nes_free_resource(nesadapter, nesadapter->allocated_mrs, 2401 stag_index); 2402 nes_debug(NES_DBG_MR, "Invalid Buffer Size\n"); 2403 ibmr = ERR_PTR(-EINVAL); 2404 kfree(nesmr); 2405 goto reg_user_mr_err; 2406 } 2407 2408 region_length += sg_dma_len(&chunk->page_list[nmap_index]); 2409 chunk_pages = sg_dma_len(&chunk->page_list[nmap_index]) >> 12; 2410 region_length -= skip_pages << 12; 2411 for (page_index=skip_pages; page_index < chunk_pages; page_index++) { 2412 skip_pages = 0; 2413 if ((page_count!=0)&&(page_count<<12)-(region->offset&(4096-1))>=region->length) 2414 goto enough_pages; 2415 if ((page_count&0x01FF) == 0) { 2416 if (page_count >= 1024 * 512) { 2417 ib_umem_release(region); 2418 nes_free_resource(nesadapter, 2419 nesadapter->allocated_mrs, stag_index); 2420 kfree(nesmr); 2421 ibmr = ERR_PTR(-E2BIG); 2422 goto reg_user_mr_err; 2423 } 2424 if (root_pbl_index == 1) { 2425 root_vpbl.pbl_vbase = pci_alloc_consistent(nesdev->pcidev, 2426 8192, &root_vpbl.pbl_pbase); 2427 nes_debug(NES_DBG_MR, "Allocating root PBL, va = %p, pa = 0x%08X\n", 2428 root_vpbl.pbl_vbase, (unsigned int)root_vpbl.pbl_pbase); 2429 if (!root_vpbl.pbl_vbase) { 2430 ib_umem_release(region); 2431 pci_free_consistent(nesdev->pcidev, 4096, vpbl.pbl_vbase, 2432 vpbl.pbl_pbase); 2433 nes_free_resource(nesadapter, nesadapter->allocated_mrs, 2434 stag_index); 2435 kfree(nesmr); 2436 ibmr = ERR_PTR(-ENOMEM); 2437 goto reg_user_mr_err; 2438 } 2439 root_vpbl.leaf_vpbl = kzalloc(sizeof(*root_vpbl.leaf_vpbl)*1024, 2440 GFP_KERNEL); 2441 if (!root_vpbl.leaf_vpbl) { 2442 ib_umem_release(region); 2443 pci_free_consistent(nesdev->pcidev, 8192, root_vpbl.pbl_vbase, 2444 root_vpbl.pbl_pbase); 2445 pci_free_consistent(nesdev->pcidev, 4096, vpbl.pbl_vbase, 2446 vpbl.pbl_pbase); 2447 nes_free_resource(nesadapter, nesadapter->allocated_mrs, 2448 stag_index); 2449 kfree(nesmr); 2450 ibmr = ERR_PTR(-ENOMEM); 2451 goto reg_user_mr_err; 2452 } 2453 root_vpbl.pbl_vbase[0].pa_low = 2454 cpu_to_le32((u32)vpbl.pbl_pbase); 2455 root_vpbl.pbl_vbase[0].pa_high = 2456 cpu_to_le32((u32)((((u64)vpbl.pbl_pbase) >> 32))); 2457 root_vpbl.leaf_vpbl[0] = vpbl; 2458 } 2459 vpbl.pbl_vbase = pci_alloc_consistent(nesdev->pcidev, 4096, 2460 &vpbl.pbl_pbase); 2461 nes_debug(NES_DBG_MR, "Allocating leaf PBL, va = %p, pa = 0x%08X\n", 2462 vpbl.pbl_vbase, (unsigned int)vpbl.pbl_pbase); 2463 if (!vpbl.pbl_vbase) { 2464 ib_umem_release(region); 2465 nes_free_resource(nesadapter, nesadapter->allocated_mrs, stag_index); 2466 ibmr = ERR_PTR(-ENOMEM); 2467 kfree(nesmr); 2468 goto reg_user_mr_err; 2469 } 2470 if (1 <= root_pbl_index) { 2471 root_vpbl.pbl_vbase[root_pbl_index].pa_low = 2472 cpu_to_le32((u32)vpbl.pbl_pbase); 2473 root_vpbl.pbl_vbase[root_pbl_index].pa_high = 2474 cpu_to_le32((u32)((((u64)vpbl.pbl_pbase)>>32))); 2475 root_vpbl.leaf_vpbl[root_pbl_index] = vpbl; 2476 } 2477 root_pbl_index++; 2478 cur_pbl_index = 0; 2479 } 2480 if (single_page) { 2481 if (page_count != 0) { 2482 if ((last_dma_addr+4096) != 2483 (sg_dma_address(&chunk->page_list[nmap_index])+ 2484 (page_index*4096))) 2485 single_page = 0; 2486 last_dma_addr = sg_dma_address(&chunk->page_list[nmap_index])+ 2487 (page_index*4096); 2488 } else { 2489 first_dma_addr = sg_dma_address(&chunk->page_list[nmap_index])+ 2490 (page_index*4096); 2491 last_dma_addr = first_dma_addr; 2492 } 2493 } 2494 2495 vpbl.pbl_vbase[cur_pbl_index].pa_low = 2496 cpu_to_le32((u32)(sg_dma_address(&chunk->page_list[nmap_index])+ 2497 (page_index*4096))); 2498 vpbl.pbl_vbase[cur_pbl_index].pa_high = 2499 cpu_to_le32((u32)((((u64)(sg_dma_address(&chunk->page_list[nmap_index])+ 2500 (page_index*4096))) >> 32))); 2501 cur_pbl_index++; 2502 page_count++; 2503 } 2504 } 2505 } 2506 enough_pages: 2507 nes_debug(NES_DBG_MR, "calculating stag, stag_index=0x%08x, driver_key=0x%08x," 2508 " stag_key=0x%08x\n", 2509 stag_index, driver_key, stag_key); 2510 stag = stag_index << 8; 2511 stag |= driver_key; 2512 stag += (u32)stag_key; 2513 2514 iova_start = virt; 2515 /* Make the leaf PBL the root if only one PBL */ 2516 if (root_pbl_index == 1) { 2517 root_vpbl.pbl_pbase = vpbl.pbl_pbase; 2518 } 2519 2520 if (single_page) { 2521 pbl_count = 0; 2522 } else { 2523 pbl_count = root_pbl_index; 2524 first_dma_addr = 0; 2525 } 2526 nes_debug(NES_DBG_MR, "Registering STag 0x%08X, VA = 0x%08X, length = 0x%08X," 2527 " index = 0x%08X, region->length=0x%08llx, pbl_count = %u\n", 2528 stag, (unsigned int)iova_start, 2529 (unsigned int)region_length, stag_index, 2530 (unsigned long long)region->length, pbl_count); 2531 ret = nes_reg_mr(nesdev, nespd, stag, region->length, &root_vpbl, 2532 first_dma_addr, pbl_count, (u16)cur_pbl_index, acc, 2533 &iova_start, &nesmr->pbls_used, &nesmr->pbl_4k); 2534 2535 nes_debug(NES_DBG_MR, "ret=%d\n", ret); 2536 2537 if (ret == 0) { 2538 nesmr->ibmr.rkey = stag; 2539 nesmr->ibmr.lkey = stag; 2540 nesmr->mode = IWNES_MEMREG_TYPE_MEM; 2541 ibmr = &nesmr->ibmr; 2542 } else { 2543 ib_umem_release(region); 2544 kfree(nesmr); 2545 ibmr = ERR_PTR(-ENOMEM); 2546 } 2547 2548 reg_user_mr_err: 2549 /* free the resources */ 2550 if (root_pbl_index == 1) { 2551 pci_free_consistent(nesdev->pcidev, 4096, vpbl.pbl_vbase, 2552 vpbl.pbl_pbase); 2553 } else { 2554 for (page_index=0; page_index<root_pbl_index; page_index++) { 2555 pci_free_consistent(nesdev->pcidev, 4096, 2556 root_vpbl.leaf_vpbl[page_index].pbl_vbase, 2557 root_vpbl.leaf_vpbl[page_index].pbl_pbase); 2558 } 2559 kfree(root_vpbl.leaf_vpbl); 2560 pci_free_consistent(nesdev->pcidev, 8192, root_vpbl.pbl_vbase, 2561 root_vpbl.pbl_pbase); 2562 } 2563 2564 nes_debug(NES_DBG_MR, "Leaving, ibmr=%p", ibmr); 2565 2566 return ibmr; 2567 case IWNES_MEMREG_TYPE_QP: 2568 case IWNES_MEMREG_TYPE_CQ: 2569 nespbl = kzalloc(sizeof(*nespbl), GFP_KERNEL); 2570 if (!nespbl) { 2571 nes_debug(NES_DBG_MR, "Unable to allocate PBL\n"); 2572 ib_umem_release(region); 2573 return ERR_PTR(-ENOMEM); 2574 } 2575 nesmr = kzalloc(sizeof(*nesmr), GFP_KERNEL); 2576 if (!nesmr) { 2577 ib_umem_release(region); 2578 kfree(nespbl); 2579 nes_debug(NES_DBG_MR, "Unable to allocate nesmr\n"); 2580 return ERR_PTR(-ENOMEM); 2581 } 2582 nesmr->region = region; 2583 nes_ucontext = to_nesucontext(pd->uobject->context); 2584 pbl_depth = region->length >> 12; 2585 pbl_depth += (region->length & (4096-1)) ? 1 : 0; 2586 nespbl->pbl_size = pbl_depth*sizeof(u64); 2587 if (req.reg_type == IWNES_MEMREG_TYPE_QP) { 2588 nes_debug(NES_DBG_MR, "Attempting to allocate QP PBL memory"); 2589 } else { 2590 nes_debug(NES_DBG_MR, "Attempting to allocate CP PBL memory"); 2591 } 2592 2593 nes_debug(NES_DBG_MR, " %u bytes, %u entries.\n", 2594 nespbl->pbl_size, pbl_depth); 2595 pbl = pci_alloc_consistent(nesdev->pcidev, nespbl->pbl_size, 2596 &nespbl->pbl_pbase); 2597 if (!pbl) { 2598 ib_umem_release(region); 2599 kfree(nesmr); 2600 kfree(nespbl); 2601 nes_debug(NES_DBG_MR, "Unable to allocate PBL memory\n"); 2602 return ERR_PTR(-ENOMEM); 2603 } 2604 2605 nespbl->pbl_vbase = (u64 *)pbl; 2606 nespbl->user_base = start; 2607 nes_debug(NES_DBG_MR, "Allocated PBL memory, %u bytes, pbl_pbase=%lx," 2608 " pbl_vbase=%p user_base=0x%lx\n", 2609 nespbl->pbl_size, (unsigned long) nespbl->pbl_pbase, 2610 (void *) nespbl->pbl_vbase, nespbl->user_base); 2611 2612 list_for_each_entry(chunk, ®ion->chunk_list, list) { 2613 for (nmap_index = 0; nmap_index < chunk->nmap; ++nmap_index) { 2614 chunk_pages = sg_dma_len(&chunk->page_list[nmap_index]) >> 12; 2615 chunk_pages += (sg_dma_len(&chunk->page_list[nmap_index]) & (4096-1)) ? 1 : 0; 2616 nespbl->page = sg_page(&chunk->page_list[0]); 2617 for (page_index=0; page_index<chunk_pages; page_index++) { 2618 ((__le32 *)pbl)[0] = cpu_to_le32((u32) 2619 (sg_dma_address(&chunk->page_list[nmap_index])+ 2620 (page_index*4096))); 2621 ((__le32 *)pbl)[1] = cpu_to_le32(((u64) 2622 (sg_dma_address(&chunk->page_list[nmap_index])+ 2623 (page_index*4096)))>>32); 2624 nes_debug(NES_DBG_MR, "pbl=%p, *pbl=0x%016llx, 0x%08x%08x\n", pbl, 2625 (unsigned long long)*pbl, 2626 le32_to_cpu(((__le32 *)pbl)[1]), le32_to_cpu(((__le32 *)pbl)[0])); 2627 pbl++; 2628 } 2629 } 2630 } 2631 if (req.reg_type == IWNES_MEMREG_TYPE_QP) { 2632 list_add_tail(&nespbl->list, &nes_ucontext->qp_reg_mem_list); 2633 } else { 2634 list_add_tail(&nespbl->list, &nes_ucontext->cq_reg_mem_list); 2635 } 2636 nesmr->ibmr.rkey = -1; 2637 nesmr->ibmr.lkey = -1; 2638 nesmr->mode = req.reg_type; 2639 return &nesmr->ibmr; 2640 } 2641 2642 return ERR_PTR(-ENOSYS); 2643} 2644 2645 2646/** 2647 * nes_dereg_mr 2648 */ 2649static int nes_dereg_mr(struct ib_mr *ib_mr) 2650{ 2651 struct nes_mr *nesmr = to_nesmr(ib_mr); 2652 struct nes_vnic *nesvnic = to_nesvnic(ib_mr->device); 2653 struct nes_device *nesdev = nesvnic->nesdev; 2654 struct nes_adapter *nesadapter = nesdev->nesadapter; 2655 struct nes_hw_cqp_wqe *cqp_wqe; 2656 struct nes_cqp_request *cqp_request; 2657 unsigned long flags; 2658 int ret; 2659 u16 major_code; 2660 u16 minor_code; 2661 2662 if (nesmr->region) { 2663 ib_umem_release(nesmr->region); 2664 } 2665 if (nesmr->mode != IWNES_MEMREG_TYPE_MEM) { 2666 kfree(nesmr); 2667 return 0; 2668 } 2669 2670 /* Deallocate the region with the adapter */ 2671 2672 cqp_request = nes_get_cqp_request(nesdev); 2673 if (cqp_request == NULL) { 2674 nes_debug(NES_DBG_MR, "Failed to get a cqp_request.\n"); 2675 return -ENOMEM; 2676 } 2677 cqp_request->waiting = 1; 2678 cqp_wqe = &cqp_request->cqp_wqe; 2679 2680 nes_fill_init_cqp_wqe(cqp_wqe, nesdev); 2681 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX, 2682 NES_CQP_DEALLOCATE_STAG | NES_CQP_STAG_VA_TO | 2683 NES_CQP_STAG_DEALLOC_PBLS | NES_CQP_STAG_MR); 2684 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_STAG_WQE_STAG_IDX, ib_mr->rkey); 2685 2686 atomic_set(&cqp_request->refcount, 2); 2687 nes_post_cqp_request(nesdev, cqp_request); 2688 2689 /* Wait for CQP */ 2690 nes_debug(NES_DBG_MR, "Waiting for deallocate STag 0x%08X completed\n", ib_mr->rkey); 2691 ret = wait_event_timeout(cqp_request->waitq, (cqp_request->request_done != 0), 2692 NES_EVENT_TIMEOUT); 2693 nes_debug(NES_DBG_MR, "Deallocate STag 0x%08X completed, wait_event_timeout ret = %u," 2694 " CQP Major:Minor codes = 0x%04X:0x%04X\n", 2695 ib_mr->rkey, ret, cqp_request->major_code, cqp_request->minor_code); 2696 2697 major_code = cqp_request->major_code; 2698 minor_code = cqp_request->minor_code; 2699 2700 nes_put_cqp_request(nesdev, cqp_request); 2701 2702 if (!ret) { 2703 nes_debug(NES_DBG_MR, "Timeout waiting to destroy STag," 2704 " ib_mr=%p, rkey = 0x%08X\n", 2705 ib_mr, ib_mr->rkey); 2706 return -ETIME; 2707 } else if (major_code) { 2708 nes_debug(NES_DBG_MR, "Error (0x%04X:0x%04X) while attempting" 2709 " to destroy STag, ib_mr=%p, rkey = 0x%08X\n", 2710 major_code, minor_code, ib_mr, ib_mr->rkey); 2711 return -EIO; 2712 } 2713 2714 if (nesmr->pbls_used != 0) { 2715 spin_lock_irqsave(&nesadapter->pbl_lock, flags); 2716 if (nesmr->pbl_4k) { 2717 nesadapter->free_4kpbl += nesmr->pbls_used; 2718 if (nesadapter->free_4kpbl > nesadapter->max_4kpbl) 2719 printk(KERN_ERR PFX "free 4KB PBLs(%u) has " 2720 "exceeded the max(%u)\n", 2721 nesadapter->free_4kpbl, 2722 nesadapter->max_4kpbl); 2723 } else { 2724 nesadapter->free_256pbl += nesmr->pbls_used; 2725 if (nesadapter->free_256pbl > nesadapter->max_256pbl) 2726 printk(KERN_ERR PFX "free 256B PBLs(%u) has " 2727 "exceeded the max(%u)\n", 2728 nesadapter->free_256pbl, 2729 nesadapter->max_256pbl); 2730 } 2731 spin_unlock_irqrestore(&nesadapter->pbl_lock, flags); 2732 } 2733 nes_free_resource(nesadapter, nesadapter->allocated_mrs, 2734 (ib_mr->rkey & 0x0fffff00) >> 8); 2735 2736 kfree(nesmr); 2737 2738 return 0; 2739} 2740 2741 2742/** 2743 * show_rev 2744 */ 2745static ssize_t show_rev(struct device *dev, struct device_attribute *attr, 2746 char *buf) 2747{ 2748 struct nes_ib_device *nesibdev = 2749 container_of(dev, struct nes_ib_device, ibdev.dev); 2750 struct nes_vnic *nesvnic = nesibdev->nesvnic; 2751 2752 nes_debug(NES_DBG_INIT, "\n"); 2753 return sprintf(buf, "%x\n", nesvnic->nesdev->nesadapter->hw_rev); 2754} 2755 2756 2757/** 2758 * show_fw_ver 2759 */ 2760static ssize_t show_fw_ver(struct device *dev, struct device_attribute *attr, 2761 char *buf) 2762{ 2763 struct nes_ib_device *nesibdev = 2764 container_of(dev, struct nes_ib_device, ibdev.dev); 2765 struct nes_vnic *nesvnic = nesibdev->nesvnic; 2766 2767 nes_debug(NES_DBG_INIT, "\n"); 2768 return sprintf(buf, "%u.%u\n", 2769 (nesvnic->nesdev->nesadapter->firmware_version >> 16), 2770 (nesvnic->nesdev->nesadapter->firmware_version & 0x000000ff)); 2771} 2772 2773 2774/** 2775 * show_hca 2776 */ 2777static ssize_t show_hca(struct device *dev, struct device_attribute *attr, 2778 char *buf) 2779{ 2780 nes_debug(NES_DBG_INIT, "\n"); 2781 return sprintf(buf, "NES020\n"); 2782} 2783 2784 2785/** 2786 * show_board 2787 */ 2788static ssize_t show_board(struct device *dev, struct device_attribute *attr, 2789 char *buf) 2790{ 2791 nes_debug(NES_DBG_INIT, "\n"); 2792 return sprintf(buf, "%.*s\n", 32, "NES020 Board ID"); 2793} 2794 2795 2796static DEVICE_ATTR(hw_rev, S_IRUGO, show_rev, NULL); 2797static DEVICE_ATTR(fw_ver, S_IRUGO, show_fw_ver, NULL); 2798static DEVICE_ATTR(hca_type, S_IRUGO, show_hca, NULL); 2799static DEVICE_ATTR(board_id, S_IRUGO, show_board, NULL); 2800 2801static struct device_attribute *nes_dev_attributes[] = { 2802 &dev_attr_hw_rev, 2803 &dev_attr_fw_ver, 2804 &dev_attr_hca_type, 2805 &dev_attr_board_id 2806}; 2807 2808 2809/** 2810 * nes_query_qp 2811 */ 2812static int nes_query_qp(struct ib_qp *ibqp, struct ib_qp_attr *attr, 2813 int attr_mask, struct ib_qp_init_attr *init_attr) 2814{ 2815 struct nes_qp *nesqp = to_nesqp(ibqp); 2816 2817 nes_debug(NES_DBG_QP, "\n"); 2818 2819 attr->qp_access_flags = 0; 2820 attr->cap.max_send_wr = nesqp->hwqp.sq_size; 2821 attr->cap.max_recv_wr = nesqp->hwqp.rq_size; 2822 attr->cap.max_recv_sge = 1; 2823 if (nes_drv_opt & NES_DRV_OPT_NO_INLINE_DATA) 2824 attr->cap.max_inline_data = 0; 2825 else 2826 attr->cap.max_inline_data = 64; 2827 2828 init_attr->event_handler = nesqp->ibqp.event_handler; 2829 init_attr->qp_context = nesqp->ibqp.qp_context; 2830 init_attr->send_cq = nesqp->ibqp.send_cq; 2831 init_attr->recv_cq = nesqp->ibqp.recv_cq; 2832 init_attr->srq = nesqp->ibqp.srq = nesqp->ibqp.srq; 2833 init_attr->cap = attr->cap; 2834 2835 return 0; 2836} 2837 2838 2839/** 2840 * nes_hw_modify_qp 2841 */ 2842int nes_hw_modify_qp(struct nes_device *nesdev, struct nes_qp *nesqp, 2843 u32 next_iwarp_state, u32 termlen, u32 wait_completion) 2844{ 2845 struct nes_hw_cqp_wqe *cqp_wqe; 2846 /* struct iw_cm_id *cm_id = nesqp->cm_id; */ 2847 /* struct iw_cm_event cm_event; */ 2848 struct nes_cqp_request *cqp_request; 2849 int ret; 2850 u16 major_code; 2851 2852 nes_debug(NES_DBG_MOD_QP, "QP%u, refcount=%d\n", 2853 nesqp->hwqp.qp_id, atomic_read(&nesqp->refcount)); 2854 2855 cqp_request = nes_get_cqp_request(nesdev); 2856 if (cqp_request == NULL) { 2857 nes_debug(NES_DBG_MOD_QP, "Failed to get a cqp_request.\n"); 2858 return -ENOMEM; 2859 } 2860 if (wait_completion) { 2861 cqp_request->waiting = 1; 2862 } else { 2863 cqp_request->waiting = 0; 2864 } 2865 cqp_wqe = &cqp_request->cqp_wqe; 2866 2867 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX, 2868 NES_CQP_MODIFY_QP | NES_CQP_QP_TYPE_IWARP | next_iwarp_state); 2869 nes_debug(NES_DBG_MOD_QP, "using next_iwarp_state=%08x, wqe_words=%08x\n", 2870 next_iwarp_state, le32_to_cpu(cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX])); 2871 nes_fill_init_cqp_wqe(cqp_wqe, nesdev); 2872 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_ID_IDX, nesqp->hwqp.qp_id); 2873 set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_QP_WQE_CONTEXT_LOW_IDX, (u64)nesqp->nesqp_context_pbase); 2874 2875 /* If sending a terminate message, fill in the length (in words) */ 2876 if (((next_iwarp_state & NES_CQP_QP_IWARP_STATE_MASK) == NES_CQP_QP_IWARP_STATE_TERMINATE) && 2877 !(next_iwarp_state & NES_CQP_QP_TERM_DONT_SEND_TERM_MSG)) { 2878 termlen = ((termlen + 3) >> 2) << NES_CQP_OP_TERMLEN_SHIFT; 2879 set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_QP_WQE_NEW_MSS_IDX, termlen); 2880 } 2881 2882 atomic_set(&cqp_request->refcount, 2); 2883 nes_post_cqp_request(nesdev, cqp_request); 2884 2885 /* Wait for CQP */ 2886 if (wait_completion) { 2887 /* nes_debug(NES_DBG_MOD_QP, "Waiting for modify iWARP QP%u to complete.\n", 2888 nesqp->hwqp.qp_id); */ 2889 ret = wait_event_timeout(cqp_request->waitq, (cqp_request->request_done != 0), 2890 NES_EVENT_TIMEOUT); 2891 nes_debug(NES_DBG_MOD_QP, "Modify iwarp QP%u completed, wait_event_timeout ret=%u, " 2892 "CQP Major:Minor codes = 0x%04X:0x%04X.\n", 2893 nesqp->hwqp.qp_id, ret, cqp_request->major_code, cqp_request->minor_code); 2894 major_code = cqp_request->major_code; 2895 if (major_code) { 2896 nes_debug(NES_DBG_MOD_QP, "Modify iwarp QP%u failed" 2897 "CQP Major:Minor codes = 0x%04X:0x%04X, intended next state = 0x%08X.\n", 2898 nesqp->hwqp.qp_id, cqp_request->major_code, 2899 cqp_request->minor_code, next_iwarp_state); 2900 } 2901 2902 nes_put_cqp_request(nesdev, cqp_request); 2903 2904 if (!ret) 2905 return -ETIME; 2906 else if (major_code) 2907 return -EIO; 2908 else 2909 return 0; 2910 } else { 2911 return 0; 2912 } 2913} 2914 2915 2916/** 2917 * nes_modify_qp 2918 */ 2919int nes_modify_qp(struct ib_qp *ibqp, struct ib_qp_attr *attr, 2920 int attr_mask, struct ib_udata *udata) 2921{ 2922 struct nes_qp *nesqp = to_nesqp(ibqp); 2923 struct nes_vnic *nesvnic = to_nesvnic(ibqp->device); 2924 struct nes_device *nesdev = nesvnic->nesdev; 2925 /* u32 cqp_head; */ 2926 /* u32 counter; */ 2927 u32 next_iwarp_state = 0; 2928 int err; 2929 unsigned long qplockflags; 2930 int ret; 2931 u16 original_last_aeq; 2932 u8 issue_modify_qp = 0; 2933 u8 dont_wait = 0; 2934 2935 nes_debug(NES_DBG_MOD_QP, "QP%u: QP State=%u, cur QP State=%u," 2936 " iwarp_state=0x%X, refcount=%d\n", 2937 nesqp->hwqp.qp_id, attr->qp_state, nesqp->ibqp_state, 2938 nesqp->iwarp_state, atomic_read(&nesqp->refcount)); 2939 2940 spin_lock_irqsave(&nesqp->lock, qplockflags); 2941 2942 nes_debug(NES_DBG_MOD_QP, "QP%u: hw_iwarp_state=0x%X, hw_tcp_state=0x%X," 2943 " QP Access Flags=0x%X, attr_mask = 0x%0x\n", 2944 nesqp->hwqp.qp_id, nesqp->hw_iwarp_state, 2945 nesqp->hw_tcp_state, attr->qp_access_flags, attr_mask); 2946 2947 if (attr_mask & IB_QP_STATE) { 2948 switch (attr->qp_state) { 2949 case IB_QPS_INIT: 2950 nes_debug(NES_DBG_MOD_QP, "QP%u: new state = init\n", 2951 nesqp->hwqp.qp_id); 2952 if (nesqp->iwarp_state > (u32)NES_CQP_QP_IWARP_STATE_IDLE) { 2953 spin_unlock_irqrestore(&nesqp->lock, qplockflags); 2954 return -EINVAL; 2955 } 2956 next_iwarp_state = NES_CQP_QP_IWARP_STATE_IDLE; 2957 issue_modify_qp = 1; 2958 break; 2959 case IB_QPS_RTR: 2960 nes_debug(NES_DBG_MOD_QP, "QP%u: new state = rtr\n", 2961 nesqp->hwqp.qp_id); 2962 if (nesqp->iwarp_state>(u32)NES_CQP_QP_IWARP_STATE_IDLE) { 2963 spin_unlock_irqrestore(&nesqp->lock, qplockflags); 2964 return -EINVAL; 2965 } 2966 next_iwarp_state = NES_CQP_QP_IWARP_STATE_IDLE; 2967 issue_modify_qp = 1; 2968 break; 2969 case IB_QPS_RTS: 2970 nes_debug(NES_DBG_MOD_QP, "QP%u: new state = rts\n", 2971 nesqp->hwqp.qp_id); 2972 if (nesqp->iwarp_state>(u32)NES_CQP_QP_IWARP_STATE_RTS) { 2973 spin_unlock_irqrestore(&nesqp->lock, qplockflags); 2974 return -EINVAL; 2975 } 2976 if (nesqp->cm_id == NULL) { 2977 nes_debug(NES_DBG_MOD_QP, "QP%u: Failing attempt to move QP to RTS without a CM_ID. \n", 2978 nesqp->hwqp.qp_id ); 2979 spin_unlock_irqrestore(&nesqp->lock, qplockflags); 2980 return -EINVAL; 2981 } 2982 next_iwarp_state = NES_CQP_QP_IWARP_STATE_RTS; 2983 if (nesqp->iwarp_state != NES_CQP_QP_IWARP_STATE_RTS) 2984 next_iwarp_state |= NES_CQP_QP_CONTEXT_VALID | 2985 NES_CQP_QP_ARP_VALID | NES_CQP_QP_ORD_VALID; 2986 issue_modify_qp = 1; 2987 nesqp->hw_tcp_state = NES_AEQE_TCP_STATE_ESTABLISHED; 2988 nesqp->hw_iwarp_state = NES_AEQE_IWARP_STATE_RTS; 2989 nesqp->hte_added = 1; 2990 break; 2991 case IB_QPS_SQD: 2992 issue_modify_qp = 1; 2993 nes_debug(NES_DBG_MOD_QP, "QP%u: new state=closing. SQ head=%u, SQ tail=%u\n", 2994 nesqp->hwqp.qp_id, nesqp->hwqp.sq_head, nesqp->hwqp.sq_tail); 2995 if (nesqp->iwarp_state == (u32)NES_CQP_QP_IWARP_STATE_CLOSING) { 2996 spin_unlock_irqrestore(&nesqp->lock, qplockflags); 2997 return 0; 2998 } else { 2999 if (nesqp->iwarp_state > (u32)NES_CQP_QP_IWARP_STATE_CLOSING) { 3000 nes_debug(NES_DBG_MOD_QP, "QP%u: State change to closing" 3001 " ignored due to current iWARP state\n", 3002 nesqp->hwqp.qp_id); 3003 spin_unlock_irqrestore(&nesqp->lock, qplockflags); 3004 return -EINVAL; 3005 } 3006 if (nesqp->hw_iwarp_state != NES_AEQE_IWARP_STATE_RTS) { 3007 nes_debug(NES_DBG_MOD_QP, "QP%u: State change to closing" 3008 " already done based on hw state.\n", 3009 nesqp->hwqp.qp_id); 3010 issue_modify_qp = 0; 3011 } 3012 switch (nesqp->hw_iwarp_state) { 3013 case NES_AEQE_IWARP_STATE_CLOSING: 3014 next_iwarp_state = NES_CQP_QP_IWARP_STATE_CLOSING; 3015 case NES_AEQE_IWARP_STATE_TERMINATE: 3016 next_iwarp_state = NES_CQP_QP_IWARP_STATE_TERMINATE; 3017 break; 3018 case NES_AEQE_IWARP_STATE_ERROR: 3019 next_iwarp_state = NES_CQP_QP_IWARP_STATE_ERROR; 3020 break; 3021 default: 3022 next_iwarp_state = NES_CQP_QP_IWARP_STATE_CLOSING; 3023 nesqp->hw_iwarp_state = NES_AEQE_IWARP_STATE_CLOSING; 3024 break; 3025 } 3026 } 3027 break; 3028 case IB_QPS_SQE: 3029 nes_debug(NES_DBG_MOD_QP, "QP%u: new state = terminate\n", 3030 nesqp->hwqp.qp_id); 3031 if (nesqp->iwarp_state>=(u32)NES_CQP_QP_IWARP_STATE_TERMINATE) { 3032 spin_unlock_irqrestore(&nesqp->lock, qplockflags); 3033 return -EINVAL; 3034 } 3035 /* next_iwarp_state = (NES_CQP_QP_IWARP_STATE_TERMINATE | 0x02000000); */ 3036 next_iwarp_state = NES_CQP_QP_IWARP_STATE_TERMINATE; 3037 nesqp->hw_iwarp_state = NES_AEQE_IWARP_STATE_TERMINATE; 3038 issue_modify_qp = 1; 3039 break; 3040 case IB_QPS_ERR: 3041 case IB_QPS_RESET: 3042 if (nesqp->iwarp_state == (u32)NES_CQP_QP_IWARP_STATE_ERROR) { 3043 spin_unlock_irqrestore(&nesqp->lock, qplockflags); 3044 return -EINVAL; 3045 } 3046 nes_debug(NES_DBG_MOD_QP, "QP%u: new state = error\n", 3047 nesqp->hwqp.qp_id); 3048 if (nesqp->term_flags) 3049 del_timer(&nesqp->terminate_timer); 3050 3051 next_iwarp_state = NES_CQP_QP_IWARP_STATE_ERROR; 3052 /* next_iwarp_state = (NES_CQP_QP_IWARP_STATE_TERMINATE | 0x02000000); */ 3053 if (nesqp->hte_added) { 3054 nes_debug(NES_DBG_MOD_QP, "set CQP_QP_DEL_HTE\n"); 3055 next_iwarp_state |= NES_CQP_QP_DEL_HTE; 3056 nesqp->hte_added = 0; 3057 } 3058 if ((nesqp->hw_tcp_state > NES_AEQE_TCP_STATE_CLOSED) && 3059 (nesdev->iw_status) && 3060 (nesqp->hw_tcp_state != NES_AEQE_TCP_STATE_TIME_WAIT)) { 3061 next_iwarp_state |= NES_CQP_QP_RESET; 3062 } else { 3063 nes_debug(NES_DBG_MOD_QP, "QP%u NOT setting NES_CQP_QP_RESET since TCP state = %u\n", 3064 nesqp->hwqp.qp_id, nesqp->hw_tcp_state); 3065 dont_wait = 1; 3066 } 3067 issue_modify_qp = 1; 3068 nesqp->hw_iwarp_state = NES_AEQE_IWARP_STATE_ERROR; 3069 break; 3070 default: 3071 spin_unlock_irqrestore(&nesqp->lock, qplockflags); 3072 return -EINVAL; 3073 break; 3074 } 3075 3076 nesqp->ibqp_state = attr->qp_state; 3077 if (((nesqp->iwarp_state & NES_CQP_QP_IWARP_STATE_MASK) == 3078 (u32)NES_CQP_QP_IWARP_STATE_RTS) && 3079 ((next_iwarp_state & NES_CQP_QP_IWARP_STATE_MASK) > 3080 (u32)NES_CQP_QP_IWARP_STATE_RTS)) { 3081 nesqp->iwarp_state = next_iwarp_state & NES_CQP_QP_IWARP_STATE_MASK; 3082 nes_debug(NES_DBG_MOD_QP, "Change nesqp->iwarp_state=%08x\n", 3083 nesqp->iwarp_state); 3084 } else { 3085 nesqp->iwarp_state = next_iwarp_state & NES_CQP_QP_IWARP_STATE_MASK; 3086 nes_debug(NES_DBG_MOD_QP, "Change nesqp->iwarp_state=%08x\n", 3087 nesqp->iwarp_state); 3088 } 3089 } 3090 3091 if (attr_mask & IB_QP_ACCESS_FLAGS) { 3092 if (attr->qp_access_flags & IB_ACCESS_LOCAL_WRITE) { 3093 nesqp->nesqp_context->misc |= cpu_to_le32(NES_QPCONTEXT_MISC_RDMA_WRITE_EN | 3094 NES_QPCONTEXT_MISC_RDMA_READ_EN); 3095 issue_modify_qp = 1; 3096 } 3097 if (attr->qp_access_flags & IB_ACCESS_REMOTE_WRITE) { 3098 nesqp->nesqp_context->misc |= cpu_to_le32(NES_QPCONTEXT_MISC_RDMA_WRITE_EN); 3099 issue_modify_qp = 1; 3100 } 3101 if (attr->qp_access_flags & IB_ACCESS_REMOTE_READ) { 3102 nesqp->nesqp_context->misc |= cpu_to_le32(NES_QPCONTEXT_MISC_RDMA_READ_EN); 3103 issue_modify_qp = 1; 3104 } 3105 if (attr->qp_access_flags & IB_ACCESS_MW_BIND) { 3106 nesqp->nesqp_context->misc |= cpu_to_le32(NES_QPCONTEXT_MISC_WBIND_EN); 3107 issue_modify_qp = 1; 3108 } 3109 3110 if (nesqp->user_mode) { 3111 nesqp->nesqp_context->misc |= cpu_to_le32(NES_QPCONTEXT_MISC_RDMA_WRITE_EN | 3112 NES_QPCONTEXT_MISC_RDMA_READ_EN); 3113 issue_modify_qp = 1; 3114 } 3115 } 3116 3117 original_last_aeq = nesqp->last_aeq; 3118 spin_unlock_irqrestore(&nesqp->lock, qplockflags); 3119 3120 nes_debug(NES_DBG_MOD_QP, "issue_modify_qp=%u\n", issue_modify_qp); 3121 3122 ret = 0; 3123 3124 3125 if (issue_modify_qp) { 3126 nes_debug(NES_DBG_MOD_QP, "call nes_hw_modify_qp\n"); 3127 ret = nes_hw_modify_qp(nesdev, nesqp, next_iwarp_state, 0, 1); 3128 if (ret) 3129 nes_debug(NES_DBG_MOD_QP, "nes_hw_modify_qp (next_iwarp_state = 0x%08X)" 3130 " failed for QP%u.\n", 3131 next_iwarp_state, nesqp->hwqp.qp_id); 3132 3133 } 3134 3135 if ((issue_modify_qp) && (nesqp->ibqp_state > IB_QPS_RTS)) { 3136 nes_debug(NES_DBG_MOD_QP, "QP%u Issued ModifyQP refcount (%d)," 3137 " original_last_aeq = 0x%04X. last_aeq = 0x%04X.\n", 3138 nesqp->hwqp.qp_id, atomic_read(&nesqp->refcount), 3139 original_last_aeq, nesqp->last_aeq); 3140 if ((!ret) || 3141 ((original_last_aeq != NES_AEQE_AEID_RDMAP_ROE_BAD_LLP_CLOSE) && 3142 (ret))) { 3143 if (dont_wait) { 3144 if (nesqp->cm_id && nesqp->hw_tcp_state != 0) { 3145 nes_debug(NES_DBG_MOD_QP, "QP%u Queuing fake disconnect for QP refcount (%d)," 3146 " original_last_aeq = 0x%04X. last_aeq = 0x%04X.\n", 3147 nesqp->hwqp.qp_id, atomic_read(&nesqp->refcount), 3148 original_last_aeq, nesqp->last_aeq); 3149 /* this one is for the cm_disconnect thread */ 3150 spin_lock_irqsave(&nesqp->lock, qplockflags); 3151 nesqp->hw_tcp_state = NES_AEQE_TCP_STATE_CLOSED; 3152 nesqp->last_aeq = NES_AEQE_AEID_RESET_SENT; 3153 spin_unlock_irqrestore(&nesqp->lock, qplockflags); 3154 nes_cm_disconn(nesqp); 3155 } else { 3156 nes_debug(NES_DBG_MOD_QP, "QP%u No fake disconnect, QP refcount=%d\n", 3157 nesqp->hwqp.qp_id, atomic_read(&nesqp->refcount)); 3158 } 3159 } else { 3160 spin_lock_irqsave(&nesqp->lock, qplockflags); 3161 if (nesqp->cm_id) { 3162 /* These two are for the timer thread */ 3163 if (atomic_inc_return(&nesqp->close_timer_started) == 1) { 3164 nesqp->cm_id->add_ref(nesqp->cm_id); 3165 nes_debug(NES_DBG_MOD_QP, "QP%u Not decrementing QP refcount (%d)," 3166 " need ae to finish up, original_last_aeq = 0x%04X." 3167 " last_aeq = 0x%04X, scheduling timer.\n", 3168 nesqp->hwqp.qp_id, atomic_read(&nesqp->refcount), 3169 original_last_aeq, nesqp->last_aeq); 3170 schedule_nes_timer(nesqp->cm_node, (struct sk_buff *) nesqp, NES_TIMER_TYPE_CLOSE, 1, 0); 3171 } 3172 spin_unlock_irqrestore(&nesqp->lock, qplockflags); 3173 } else { 3174 spin_unlock_irqrestore(&nesqp->lock, qplockflags); 3175 nes_debug(NES_DBG_MOD_QP, "QP%u Not decrementing QP refcount (%d)," 3176 " need ae to finish up, original_last_aeq = 0x%04X." 3177 " last_aeq = 0x%04X.\n", 3178 nesqp->hwqp.qp_id, atomic_read(&nesqp->refcount), 3179 original_last_aeq, nesqp->last_aeq); 3180 } 3181 } 3182 } else { 3183 nes_debug(NES_DBG_MOD_QP, "QP%u Decrementing QP refcount (%d), No ae to finish up," 3184 " original_last_aeq = 0x%04X. last_aeq = 0x%04X.\n", 3185 nesqp->hwqp.qp_id, atomic_read(&nesqp->refcount), 3186 original_last_aeq, nesqp->last_aeq); 3187 } 3188 } else { 3189 nes_debug(NES_DBG_MOD_QP, "QP%u Decrementing QP refcount (%d), No ae to finish up," 3190 " original_last_aeq = 0x%04X. last_aeq = 0x%04X.\n", 3191 nesqp->hwqp.qp_id, atomic_read(&nesqp->refcount), 3192 original_last_aeq, nesqp->last_aeq); 3193 } 3194 3195 err = 0; 3196 3197 nes_debug(NES_DBG_MOD_QP, "QP%u Leaving, refcount=%d\n", 3198 nesqp->hwqp.qp_id, atomic_read(&nesqp->refcount)); 3199 3200 return err; 3201} 3202 3203 3204/** 3205 * nes_muticast_attach 3206 */ 3207static int nes_multicast_attach(struct ib_qp *ibqp, union ib_gid *gid, u16 lid) 3208{ 3209 nes_debug(NES_DBG_INIT, "\n"); 3210 return -ENOSYS; 3211} 3212 3213 3214/** 3215 * nes_multicast_detach 3216 */ 3217static int nes_multicast_detach(struct ib_qp *ibqp, union ib_gid *gid, u16 lid) 3218{ 3219 nes_debug(NES_DBG_INIT, "\n"); 3220 return -ENOSYS; 3221} 3222 3223 3224/** 3225 * nes_process_mad 3226 */ 3227static int nes_process_mad(struct ib_device *ibdev, int mad_flags, 3228 u8 port_num, struct ib_wc *in_wc, struct ib_grh *in_grh, 3229 struct ib_mad *in_mad, struct ib_mad *out_mad) 3230{ 3231 nes_debug(NES_DBG_INIT, "\n"); 3232 return -ENOSYS; 3233} 3234 3235static inline void 3236fill_wqe_sg_send(struct nes_hw_qp_wqe *wqe, struct ib_send_wr *ib_wr, u32 uselkey) 3237{ 3238 int sge_index; 3239 int total_payload_length = 0; 3240 for (sge_index = 0; sge_index < ib_wr->num_sge; sge_index++) { 3241 set_wqe_64bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_FRAG0_LOW_IDX+(sge_index*4), 3242 ib_wr->sg_list[sge_index].addr); 3243 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_LENGTH0_IDX + (sge_index*4), 3244 ib_wr->sg_list[sge_index].length); 3245 if (uselkey) 3246 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_STAG0_IDX + (sge_index*4), 3247 (ib_wr->sg_list[sge_index].lkey)); 3248 else 3249 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_STAG0_IDX + (sge_index*4), 0); 3250 3251 total_payload_length += ib_wr->sg_list[sge_index].length; 3252 } 3253 nes_debug(NES_DBG_IW_TX, "UC UC UC, sending total_payload_length=%u \n", 3254 total_payload_length); 3255 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_TOTAL_PAYLOAD_IDX, 3256 total_payload_length); 3257} 3258 3259/** 3260 * nes_post_send 3261 */ 3262static int nes_post_send(struct ib_qp *ibqp, struct ib_send_wr *ib_wr, 3263 struct ib_send_wr **bad_wr) 3264{ 3265 u64 u64temp; 3266 unsigned long flags = 0; 3267 struct nes_vnic *nesvnic = to_nesvnic(ibqp->device); 3268 struct nes_device *nesdev = nesvnic->nesdev; 3269 struct nes_qp *nesqp = to_nesqp(ibqp); 3270 struct nes_hw_qp_wqe *wqe; 3271 int err = 0; 3272 u32 qsize = nesqp->hwqp.sq_size; 3273 u32 head; 3274 u32 wqe_misc = 0; 3275 u32 wqe_count = 0; 3276 u32 counter; 3277 3278 if (nesqp->ibqp_state > IB_QPS_RTS) { 3279 err = -EINVAL; 3280 goto out; 3281 } 3282 3283 spin_lock_irqsave(&nesqp->lock, flags); 3284 3285 head = nesqp->hwqp.sq_head; 3286 3287 while (ib_wr) { 3288 /* Check for QP error */ 3289 if (nesqp->term_flags) { 3290 err = -EINVAL; 3291 break; 3292 } 3293 3294 /* Check for SQ overflow */ 3295 if (((head + (2 * qsize) - nesqp->hwqp.sq_tail) % qsize) == (qsize - 1)) { 3296 err = -ENOMEM; 3297 break; 3298 } 3299 3300 wqe = &nesqp->hwqp.sq_vbase[head]; 3301 /* nes_debug(NES_DBG_IW_TX, "processing sq wqe for QP%u at %p, head = %u.\n", 3302 nesqp->hwqp.qp_id, wqe, head); */ 3303 nes_fill_init_qp_wqe(wqe, nesqp, head); 3304 u64temp = (u64)(ib_wr->wr_id); 3305 set_wqe_64bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_COMP_SCRATCH_LOW_IDX, 3306 u64temp); 3307 switch (ib_wr->opcode) { 3308 case IB_WR_SEND: 3309 case IB_WR_SEND_WITH_INV: 3310 if (IB_WR_SEND == ib_wr->opcode) { 3311 if (ib_wr->send_flags & IB_SEND_SOLICITED) 3312 wqe_misc = NES_IWARP_SQ_OP_SENDSE; 3313 else 3314 wqe_misc = NES_IWARP_SQ_OP_SEND; 3315 } else { 3316 if (ib_wr->send_flags & IB_SEND_SOLICITED) 3317 wqe_misc = NES_IWARP_SQ_OP_SENDSEINV; 3318 else 3319 wqe_misc = NES_IWARP_SQ_OP_SENDINV; 3320 3321 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_INV_STAG_LOW_IDX, 3322 ib_wr->ex.invalidate_rkey); 3323 } 3324 3325 if (ib_wr->num_sge > nesdev->nesadapter->max_sge) { 3326 err = -EINVAL; 3327 break; 3328 } 3329 3330 if (ib_wr->send_flags & IB_SEND_FENCE) 3331 wqe_misc |= NES_IWARP_SQ_WQE_LOCAL_FENCE; 3332 3333 if ((ib_wr->send_flags & IB_SEND_INLINE) && 3334 ((nes_drv_opt & NES_DRV_OPT_NO_INLINE_DATA) == 0) && 3335 (ib_wr->sg_list[0].length <= 64)) { 3336 memcpy(&wqe->wqe_words[NES_IWARP_SQ_WQE_IMM_DATA_START_IDX], 3337 (void *)(unsigned long)ib_wr->sg_list[0].addr, ib_wr->sg_list[0].length); 3338 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_TOTAL_PAYLOAD_IDX, 3339 ib_wr->sg_list[0].length); 3340 wqe_misc |= NES_IWARP_SQ_WQE_IMM_DATA; 3341 } else { 3342 fill_wqe_sg_send(wqe, ib_wr, 1); 3343 } 3344 3345 break; 3346 case IB_WR_RDMA_WRITE: 3347 wqe_misc = NES_IWARP_SQ_OP_RDMAW; 3348 if (ib_wr->num_sge > nesdev->nesadapter->max_sge) { 3349 nes_debug(NES_DBG_IW_TX, "Exceeded max sge, ib_wr=%u, max=%u\n", 3350 ib_wr->num_sge, nesdev->nesadapter->max_sge); 3351 err = -EINVAL; 3352 break; 3353 } 3354 3355 if (ib_wr->send_flags & IB_SEND_FENCE) 3356 wqe_misc |= NES_IWARP_SQ_WQE_LOCAL_FENCE; 3357 3358 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_RDMA_STAG_IDX, 3359 ib_wr->wr.rdma.rkey); 3360 set_wqe_64bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_RDMA_TO_LOW_IDX, 3361 ib_wr->wr.rdma.remote_addr); 3362 3363 if ((ib_wr->send_flags & IB_SEND_INLINE) && 3364 ((nes_drv_opt & NES_DRV_OPT_NO_INLINE_DATA) == 0) && 3365 (ib_wr->sg_list[0].length <= 64)) { 3366 memcpy(&wqe->wqe_words[NES_IWARP_SQ_WQE_IMM_DATA_START_IDX], 3367 (void *)(unsigned long)ib_wr->sg_list[0].addr, ib_wr->sg_list[0].length); 3368 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_TOTAL_PAYLOAD_IDX, 3369 ib_wr->sg_list[0].length); 3370 wqe_misc |= NES_IWARP_SQ_WQE_IMM_DATA; 3371 } else { 3372 fill_wqe_sg_send(wqe, ib_wr, 1); 3373 } 3374 3375 wqe->wqe_words[NES_IWARP_SQ_WQE_RDMA_LENGTH_IDX] = 3376 wqe->wqe_words[NES_IWARP_SQ_WQE_TOTAL_PAYLOAD_IDX]; 3377 break; 3378 case IB_WR_RDMA_READ: 3379 case IB_WR_RDMA_READ_WITH_INV: 3380 /* iWARP only supports 1 sge for RDMA reads */ 3381 if (ib_wr->num_sge > 1) { 3382 nes_debug(NES_DBG_IW_TX, "Exceeded max sge, ib_wr=%u, max=1\n", 3383 ib_wr->num_sge); 3384 err = -EINVAL; 3385 break; 3386 } 3387 if (ib_wr->opcode == IB_WR_RDMA_READ) { 3388 wqe_misc = NES_IWARP_SQ_OP_RDMAR; 3389 } else { 3390 wqe_misc = NES_IWARP_SQ_OP_RDMAR_LOCINV; 3391 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_INV_STAG_LOW_IDX, 3392 ib_wr->ex.invalidate_rkey); 3393 } 3394 3395 set_wqe_64bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_RDMA_TO_LOW_IDX, 3396 ib_wr->wr.rdma.remote_addr); 3397 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_RDMA_STAG_IDX, 3398 ib_wr->wr.rdma.rkey); 3399 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_RDMA_LENGTH_IDX, 3400 ib_wr->sg_list->length); 3401 set_wqe_64bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_FRAG0_LOW_IDX, 3402 ib_wr->sg_list->addr); 3403 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_STAG0_IDX, 3404 ib_wr->sg_list->lkey); 3405 break; 3406 case IB_WR_LOCAL_INV: 3407 wqe_misc = NES_IWARP_SQ_OP_LOCINV; 3408 set_wqe_32bit_value(wqe->wqe_words, 3409 NES_IWARP_SQ_LOCINV_WQE_INV_STAG_IDX, 3410 ib_wr->ex.invalidate_rkey); 3411 break; 3412 case IB_WR_FAST_REG_MR: 3413 { 3414 int i; 3415 int flags = ib_wr->wr.fast_reg.access_flags; 3416 struct nes_ib_fast_reg_page_list *pnesfrpl = 3417 container_of(ib_wr->wr.fast_reg.page_list, 3418 struct nes_ib_fast_reg_page_list, 3419 ibfrpl); 3420 u64 *src_page_list = pnesfrpl->ibfrpl.page_list; 3421 u64 *dst_page_list = pnesfrpl->nes_wqe_pbl.kva; 3422 3423 if (ib_wr->wr.fast_reg.page_list_len > 3424 (NES_4K_PBL_CHUNK_SIZE / sizeof(u64))) { 3425 nes_debug(NES_DBG_IW_TX, "SQ_FMR: bad page_list_len\n"); 3426 err = -EINVAL; 3427 break; 3428 } 3429 wqe_misc = NES_IWARP_SQ_OP_FAST_REG; 3430 set_wqe_64bit_value(wqe->wqe_words, 3431 NES_IWARP_SQ_FMR_WQE_VA_FBO_LOW_IDX, 3432 ib_wr->wr.fast_reg.iova_start); 3433 set_wqe_32bit_value(wqe->wqe_words, 3434 NES_IWARP_SQ_FMR_WQE_LENGTH_LOW_IDX, 3435 ib_wr->wr.fast_reg.length); 3436 set_wqe_32bit_value(wqe->wqe_words, 3437 NES_IWARP_SQ_FMR_WQE_MR_STAG_IDX, 3438 ib_wr->wr.fast_reg.rkey); 3439 /* Set page size: */ 3440 if (ib_wr->wr.fast_reg.page_shift == 12) { 3441 wqe_misc |= NES_IWARP_SQ_FMR_WQE_PAGE_SIZE_4K; 3442 } else if (ib_wr->wr.fast_reg.page_shift == 21) { 3443 wqe_misc |= NES_IWARP_SQ_FMR_WQE_PAGE_SIZE_2M; 3444 } else { 3445 nes_debug(NES_DBG_IW_TX, "Invalid page shift," 3446 " ib_wr=%u, max=1\n", ib_wr->num_sge); 3447 err = -EINVAL; 3448 break; 3449 } 3450 /* Set access_flags */ 3451 wqe_misc |= NES_IWARP_SQ_FMR_WQE_RIGHTS_ENABLE_LOCAL_READ; 3452 if (flags & IB_ACCESS_LOCAL_WRITE) 3453 wqe_misc |= NES_IWARP_SQ_FMR_WQE_RIGHTS_ENABLE_LOCAL_WRITE; 3454 3455 if (flags & IB_ACCESS_REMOTE_WRITE) 3456 wqe_misc |= NES_IWARP_SQ_FMR_WQE_RIGHTS_ENABLE_REMOTE_WRITE; 3457 3458 if (flags & IB_ACCESS_REMOTE_READ) 3459 wqe_misc |= NES_IWARP_SQ_FMR_WQE_RIGHTS_ENABLE_REMOTE_READ; 3460 3461 if (flags & IB_ACCESS_MW_BIND) 3462 wqe_misc |= NES_IWARP_SQ_FMR_WQE_RIGHTS_ENABLE_WINDOW_BIND; 3463 3464 /* Fill in PBL info: */ 3465 if (ib_wr->wr.fast_reg.page_list_len > 3466 pnesfrpl->ibfrpl.max_page_list_len) { 3467 nes_debug(NES_DBG_IW_TX, "Invalid page list length," 3468 " ib_wr=%p, value=%u, max=%u\n", 3469 ib_wr, ib_wr->wr.fast_reg.page_list_len, 3470 pnesfrpl->ibfrpl.max_page_list_len); 3471 err = -EINVAL; 3472 break; 3473 } 3474 3475 set_wqe_64bit_value(wqe->wqe_words, 3476 NES_IWARP_SQ_FMR_WQE_PBL_ADDR_LOW_IDX, 3477 pnesfrpl->nes_wqe_pbl.paddr); 3478 3479 set_wqe_32bit_value(wqe->wqe_words, 3480 NES_IWARP_SQ_FMR_WQE_PBL_LENGTH_IDX, 3481 ib_wr->wr.fast_reg.page_list_len * 8); 3482 3483 for (i = 0; i < ib_wr->wr.fast_reg.page_list_len; i++) 3484 dst_page_list[i] = cpu_to_le64(src_page_list[i]); 3485 3486 nes_debug(NES_DBG_IW_TX, "SQ_FMR: iova_start: %p, " 3487 "length: %d, rkey: %0x, pgl_paddr: %p, " 3488 "page_list_len: %u, wqe_misc: %x\n", 3489 (void *)ib_wr->wr.fast_reg.iova_start, 3490 ib_wr->wr.fast_reg.length, 3491 ib_wr->wr.fast_reg.rkey, 3492 (void *)pnesfrpl->nes_wqe_pbl.paddr, 3493 ib_wr->wr.fast_reg.page_list_len, 3494 wqe_misc); 3495 break; 3496 } 3497 default: 3498 /* error */ 3499 err = -EINVAL; 3500 break; 3501 } 3502 3503 if (err) 3504 break; 3505 3506 if ((ib_wr->send_flags & IB_SEND_SIGNALED) || nesqp->sig_all) 3507 wqe_misc |= NES_IWARP_SQ_WQE_SIGNALED_COMPL; 3508 3509 wqe->wqe_words[NES_IWARP_SQ_WQE_MISC_IDX] = cpu_to_le32(wqe_misc); 3510 3511 ib_wr = ib_wr->next; 3512 head++; 3513 wqe_count++; 3514 if (head >= qsize) 3515 head = 0; 3516 3517 } 3518 3519 nesqp->hwqp.sq_head = head; 3520 barrier(); 3521 while (wqe_count) { 3522 counter = min(wqe_count, ((u32)255)); 3523 wqe_count -= counter; 3524 nes_write32(nesdev->regs + NES_WQE_ALLOC, 3525 (counter << 24) | 0x00800000 | nesqp->hwqp.qp_id); 3526 } 3527 3528 spin_unlock_irqrestore(&nesqp->lock, flags); 3529 3530out: 3531 if (err) 3532 *bad_wr = ib_wr; 3533 return err; 3534} 3535 3536 3537/** 3538 * nes_post_recv 3539 */ 3540static int nes_post_recv(struct ib_qp *ibqp, struct ib_recv_wr *ib_wr, 3541 struct ib_recv_wr **bad_wr) 3542{ 3543 u64 u64temp; 3544 unsigned long flags = 0; 3545 struct nes_vnic *nesvnic = to_nesvnic(ibqp->device); 3546 struct nes_device *nesdev = nesvnic->nesdev; 3547 struct nes_qp *nesqp = to_nesqp(ibqp); 3548 struct nes_hw_qp_wqe *wqe; 3549 int err = 0; 3550 int sge_index; 3551 u32 qsize = nesqp->hwqp.rq_size; 3552 u32 head; 3553 u32 wqe_count = 0; 3554 u32 counter; 3555 u32 total_payload_length; 3556 3557 if (nesqp->ibqp_state > IB_QPS_RTS) { 3558 err = -EINVAL; 3559 goto out; 3560 } 3561 3562 spin_lock_irqsave(&nesqp->lock, flags); 3563 3564 head = nesqp->hwqp.rq_head; 3565 3566 while (ib_wr) { 3567 /* Check for QP error */ 3568 if (nesqp->term_flags) { 3569 err = -EINVAL; 3570 break; 3571 } 3572 3573 if (ib_wr->num_sge > nesdev->nesadapter->max_sge) { 3574 err = -EINVAL; 3575 break; 3576 } 3577 /* Check for RQ overflow */ 3578 if (((head + (2 * qsize) - nesqp->hwqp.rq_tail) % qsize) == (qsize - 1)) { 3579 err = -ENOMEM; 3580 break; 3581 } 3582 3583 nes_debug(NES_DBG_IW_RX, "ibwr sge count = %u.\n", ib_wr->num_sge); 3584 wqe = &nesqp->hwqp.rq_vbase[head]; 3585 3586 /* nes_debug(NES_DBG_IW_RX, "QP%u:processing rq wqe at %p, head = %u.\n", 3587 nesqp->hwqp.qp_id, wqe, head); */ 3588 nes_fill_init_qp_wqe(wqe, nesqp, head); 3589 u64temp = (u64)(ib_wr->wr_id); 3590 set_wqe_64bit_value(wqe->wqe_words, NES_IWARP_SQ_WQE_COMP_SCRATCH_LOW_IDX, 3591 u64temp); 3592 total_payload_length = 0; 3593 for (sge_index=0; sge_index < ib_wr->num_sge; sge_index++) { 3594 set_wqe_64bit_value(wqe->wqe_words, NES_IWARP_RQ_WQE_FRAG0_LOW_IDX+(sge_index*4), 3595 ib_wr->sg_list[sge_index].addr); 3596 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_RQ_WQE_LENGTH0_IDX+(sge_index*4), 3597 ib_wr->sg_list[sge_index].length); 3598 set_wqe_32bit_value(wqe->wqe_words,NES_IWARP_RQ_WQE_STAG0_IDX+(sge_index*4), 3599 ib_wr->sg_list[sge_index].lkey); 3600 3601 total_payload_length += ib_wr->sg_list[sge_index].length; 3602 } 3603 set_wqe_32bit_value(wqe->wqe_words, NES_IWARP_RQ_WQE_TOTAL_PAYLOAD_IDX, 3604 total_payload_length); 3605 3606 ib_wr = ib_wr->next; 3607 head++; 3608 wqe_count++; 3609 if (head >= qsize) 3610 head = 0; 3611 } 3612 3613 nesqp->hwqp.rq_head = head; 3614 barrier(); 3615 while (wqe_count) { 3616 counter = min(wqe_count, ((u32)255)); 3617 wqe_count -= counter; 3618 nes_write32(nesdev->regs+NES_WQE_ALLOC, (counter<<24) | nesqp->hwqp.qp_id); 3619 } 3620 3621 spin_unlock_irqrestore(&nesqp->lock, flags); 3622 3623out: 3624 if (err) 3625 *bad_wr = ib_wr; 3626 return err; 3627} 3628 3629 3630/** 3631 * nes_poll_cq 3632 */ 3633static int nes_poll_cq(struct ib_cq *ibcq, int num_entries, struct ib_wc *entry) 3634{ 3635 u64 u64temp; 3636 u64 wrid; 3637 unsigned long flags = 0; 3638 struct nes_vnic *nesvnic = to_nesvnic(ibcq->device); 3639 struct nes_device *nesdev = nesvnic->nesdev; 3640 struct nes_cq *nescq = to_nescq(ibcq); 3641 struct nes_qp *nesqp; 3642 struct nes_hw_cqe cqe; 3643 u32 head; 3644 u32 wq_tail = 0; 3645 u32 cq_size; 3646 u32 cqe_count = 0; 3647 u32 wqe_index; 3648 u32 u32temp; 3649 u32 move_cq_head = 1; 3650 u32 err_code; 3651 3652 nes_debug(NES_DBG_CQ, "\n"); 3653 3654 spin_lock_irqsave(&nescq->lock, flags); 3655 3656 head = nescq->hw_cq.cq_head; 3657 cq_size = nescq->hw_cq.cq_size; 3658 3659 while (cqe_count < num_entries) { 3660 if ((le32_to_cpu(nescq->hw_cq.cq_vbase[head].cqe_words[NES_CQE_OPCODE_IDX]) & 3661 NES_CQE_VALID) == 0) 3662 break; 3663 3664 /* 3665 * Make sure we read CQ entry contents *after* 3666 * we've checked the valid bit. 3667 */ 3668 rmb(); 3669 3670 cqe = nescq->hw_cq.cq_vbase[head]; 3671 u32temp = le32_to_cpu(cqe.cqe_words[NES_CQE_COMP_COMP_CTX_LOW_IDX]); 3672 wqe_index = u32temp & (nesdev->nesadapter->max_qp_wr - 1); 3673 u32temp &= ~(NES_SW_CONTEXT_ALIGN-1); 3674 /* parse CQE, get completion context from WQE (either rq or sq) */ 3675 u64temp = (((u64)(le32_to_cpu(cqe.cqe_words[NES_CQE_COMP_COMP_CTX_HIGH_IDX])))<<32) | 3676 ((u64)u32temp); 3677 3678 if (u64temp) { 3679 nesqp = (struct nes_qp *)(unsigned long)u64temp; 3680 memset(entry, 0, sizeof *entry); 3681 if (cqe.cqe_words[NES_CQE_ERROR_CODE_IDX] == 0) { 3682 entry->status = IB_WC_SUCCESS; 3683 } else { 3684 err_code = le32_to_cpu(cqe.cqe_words[NES_CQE_ERROR_CODE_IDX]); 3685 if (NES_IWARP_CQE_MAJOR_DRV == (err_code >> 16)) { 3686 entry->status = err_code & 0x0000ffff; 3687 3688 /* The rest of the cqe's will be marked as flushed */ 3689 nescq->hw_cq.cq_vbase[head].cqe_words[NES_CQE_ERROR_CODE_IDX] = 3690 cpu_to_le32((NES_IWARP_CQE_MAJOR_FLUSH << 16) | 3691 NES_IWARP_CQE_MINOR_FLUSH); 3692 } else 3693 entry->status = IB_WC_WR_FLUSH_ERR; 3694 } 3695 3696 entry->qp = &nesqp->ibqp; 3697 entry->src_qp = nesqp->hwqp.qp_id; 3698 3699 if (le32_to_cpu(cqe.cqe_words[NES_CQE_OPCODE_IDX]) & NES_CQE_SQ) { 3700 if (nesqp->skip_lsmm) { 3701 nesqp->skip_lsmm = 0; 3702 nesqp->hwqp.sq_tail++; 3703 } 3704 3705 /* Working on a SQ Completion*/ 3706 wrid = (((u64)(cpu_to_le32((u32)nesqp->hwqp.sq_vbase[wqe_index]. 3707 wqe_words[NES_IWARP_SQ_WQE_COMP_SCRATCH_HIGH_IDX]))) << 32) | 3708 ((u64)(cpu_to_le32((u32)nesqp->hwqp.sq_vbase[wqe_index]. 3709 wqe_words[NES_IWARP_SQ_WQE_COMP_SCRATCH_LOW_IDX]))); 3710 entry->byte_len = le32_to_cpu(nesqp->hwqp.sq_vbase[wqe_index]. 3711 wqe_words[NES_IWARP_SQ_WQE_TOTAL_PAYLOAD_IDX]); 3712 3713 switch (le32_to_cpu(nesqp->hwqp.sq_vbase[wqe_index]. 3714 wqe_words[NES_IWARP_SQ_WQE_MISC_IDX]) & 0x3f) { 3715 case NES_IWARP_SQ_OP_RDMAW: 3716 nes_debug(NES_DBG_CQ, "Operation = RDMA WRITE.\n"); 3717 entry->opcode = IB_WC_RDMA_WRITE; 3718 break; 3719 case NES_IWARP_SQ_OP_RDMAR: 3720 nes_debug(NES_DBG_CQ, "Operation = RDMA READ.\n"); 3721 entry->opcode = IB_WC_RDMA_READ; 3722 entry->byte_len = le32_to_cpu(nesqp->hwqp.sq_vbase[wqe_index]. 3723 wqe_words[NES_IWARP_SQ_WQE_RDMA_LENGTH_IDX]); 3724 break; 3725 case NES_IWARP_SQ_OP_SENDINV: 3726 case NES_IWARP_SQ_OP_SENDSEINV: 3727 case NES_IWARP_SQ_OP_SEND: 3728 case NES_IWARP_SQ_OP_SENDSE: 3729 nes_debug(NES_DBG_CQ, "Operation = Send.\n"); 3730 entry->opcode = IB_WC_SEND; 3731 break; 3732 case NES_IWARP_SQ_OP_LOCINV: 3733 entry->opcode = IB_WR_LOCAL_INV; 3734 break; 3735 case NES_IWARP_SQ_OP_FAST_REG: 3736 entry->opcode = IB_WC_FAST_REG_MR; 3737 break; 3738 } 3739 3740 nesqp->hwqp.sq_tail = (wqe_index+1)&(nesqp->hwqp.sq_size - 1); 3741 if ((entry->status != IB_WC_SUCCESS) && (nesqp->hwqp.sq_tail != nesqp->hwqp.sq_head)) { 3742 move_cq_head = 0; 3743 wq_tail = nesqp->hwqp.sq_tail; 3744 } 3745 } else { 3746 /* Working on a RQ Completion*/ 3747 entry->byte_len = le32_to_cpu(cqe.cqe_words[NES_CQE_PAYLOAD_LENGTH_IDX]); 3748 wrid = ((u64)(le32_to_cpu(nesqp->hwqp.rq_vbase[wqe_index].wqe_words[NES_IWARP_RQ_WQE_COMP_SCRATCH_LOW_IDX]))) | 3749 ((u64)(le32_to_cpu(nesqp->hwqp.rq_vbase[wqe_index].wqe_words[NES_IWARP_RQ_WQE_COMP_SCRATCH_HIGH_IDX]))<<32); 3750 entry->opcode = IB_WC_RECV; 3751 3752 nesqp->hwqp.rq_tail = (wqe_index+1)&(nesqp->hwqp.rq_size - 1); 3753 if ((entry->status != IB_WC_SUCCESS) && (nesqp->hwqp.rq_tail != nesqp->hwqp.rq_head)) { 3754 move_cq_head = 0; 3755 wq_tail = nesqp->hwqp.rq_tail; 3756 } 3757 } 3758 3759 entry->wr_id = wrid; 3760 entry++; 3761 cqe_count++; 3762 } 3763 3764 if (move_cq_head) { 3765 nescq->hw_cq.cq_vbase[head].cqe_words[NES_CQE_OPCODE_IDX] = 0; 3766 if (++head >= cq_size) 3767 head = 0; 3768 nescq->polled_completions++; 3769 3770 if ((nescq->polled_completions > (cq_size / 2)) || 3771 (nescq->polled_completions == 255)) { 3772 nes_debug(NES_DBG_CQ, "CQ%u Issuing CQE Allocate since more than half of cqes" 3773 " are pending %u of %u.\n", 3774 nescq->hw_cq.cq_number, nescq->polled_completions, cq_size); 3775 nes_write32(nesdev->regs+NES_CQE_ALLOC, 3776 nescq->hw_cq.cq_number | (nescq->polled_completions << 16)); 3777 nescq->polled_completions = 0; 3778 } 3779 } else { 3780 /* Update the wqe index and set status to flush */ 3781 wqe_index = le32_to_cpu(cqe.cqe_words[NES_CQE_COMP_COMP_CTX_LOW_IDX]); 3782 wqe_index = (wqe_index & (~(nesdev->nesadapter->max_qp_wr - 1))) | wq_tail; 3783 nescq->hw_cq.cq_vbase[head].cqe_words[NES_CQE_COMP_COMP_CTX_LOW_IDX] = 3784 cpu_to_le32(wqe_index); 3785 move_cq_head = 1; /* ready for next pass */ 3786 } 3787 } 3788 3789 if (nescq->polled_completions) { 3790 nes_write32(nesdev->regs+NES_CQE_ALLOC, 3791 nescq->hw_cq.cq_number | (nescq->polled_completions << 16)); 3792 nescq->polled_completions = 0; 3793 } 3794 3795 nescq->hw_cq.cq_head = head; 3796 nes_debug(NES_DBG_CQ, "Reporting %u completions for CQ%u.\n", 3797 cqe_count, nescq->hw_cq.cq_number); 3798 3799 spin_unlock_irqrestore(&nescq->lock, flags); 3800 3801 return cqe_count; 3802} 3803 3804 3805/** 3806 * nes_req_notify_cq 3807 */ 3808static int nes_req_notify_cq(struct ib_cq *ibcq, enum ib_cq_notify_flags notify_flags) 3809 { 3810 struct nes_vnic *nesvnic = to_nesvnic(ibcq->device); 3811 struct nes_device *nesdev = nesvnic->nesdev; 3812 struct nes_cq *nescq = to_nescq(ibcq); 3813 u32 cq_arm; 3814 3815 nes_debug(NES_DBG_CQ, "Requesting notification for CQ%u.\n", 3816 nescq->hw_cq.cq_number); 3817 3818 cq_arm = nescq->hw_cq.cq_number; 3819 if ((notify_flags & IB_CQ_SOLICITED_MASK) == IB_CQ_NEXT_COMP) 3820 cq_arm |= NES_CQE_ALLOC_NOTIFY_NEXT; 3821 else if ((notify_flags & IB_CQ_SOLICITED_MASK) == IB_CQ_SOLICITED) 3822 cq_arm |= NES_CQE_ALLOC_NOTIFY_SE; 3823 else 3824 return -EINVAL; 3825 3826 nes_write32(nesdev->regs+NES_CQE_ALLOC, cq_arm); 3827 nes_read32(nesdev->regs+NES_CQE_ALLOC); 3828 3829 return 0; 3830} 3831 3832 3833/** 3834 * nes_init_ofa_device 3835 */ 3836struct nes_ib_device *nes_init_ofa_device(struct net_device *netdev) 3837{ 3838 struct nes_ib_device *nesibdev; 3839 struct nes_vnic *nesvnic = netdev_priv(netdev); 3840 struct nes_device *nesdev = nesvnic->nesdev; 3841 3842 nesibdev = (struct nes_ib_device *)ib_alloc_device(sizeof(struct nes_ib_device)); 3843 if (nesibdev == NULL) { 3844 return NULL; 3845 } 3846 strlcpy(nesibdev->ibdev.name, "nes%d", IB_DEVICE_NAME_MAX); 3847 nesibdev->ibdev.owner = THIS_MODULE; 3848 3849 nesibdev->ibdev.node_type = RDMA_NODE_RNIC; 3850 memset(&nesibdev->ibdev.node_guid, 0, sizeof(nesibdev->ibdev.node_guid)); 3851 memcpy(&nesibdev->ibdev.node_guid, netdev->dev_addr, 6); 3852 3853 nesibdev->ibdev.uverbs_cmd_mask = 3854 (1ull << IB_USER_VERBS_CMD_GET_CONTEXT) | 3855 (1ull << IB_USER_VERBS_CMD_QUERY_DEVICE) | 3856 (1ull << IB_USER_VERBS_CMD_QUERY_PORT) | 3857 (1ull << IB_USER_VERBS_CMD_ALLOC_PD) | 3858 (1ull << IB_USER_VERBS_CMD_DEALLOC_PD) | 3859 (1ull << IB_USER_VERBS_CMD_REG_MR) | 3860 (1ull << IB_USER_VERBS_CMD_DEREG_MR) | 3861 (1ull << IB_USER_VERBS_CMD_CREATE_COMP_CHANNEL) | 3862 (1ull << IB_USER_VERBS_CMD_CREATE_CQ) | 3863 (1ull << IB_USER_VERBS_CMD_DESTROY_CQ) | 3864 (1ull << IB_USER_VERBS_CMD_CREATE_AH) | 3865 (1ull << IB_USER_VERBS_CMD_DESTROY_AH) | 3866 (1ull << IB_USER_VERBS_CMD_REQ_NOTIFY_CQ) | 3867 (1ull << IB_USER_VERBS_CMD_CREATE_QP) | 3868 (1ull << IB_USER_VERBS_CMD_MODIFY_QP) | 3869 (1ull << IB_USER_VERBS_CMD_POLL_CQ) | 3870 (1ull << IB_USER_VERBS_CMD_DESTROY_QP) | 3871 (1ull << IB_USER_VERBS_CMD_ALLOC_MW) | 3872 (1ull << IB_USER_VERBS_CMD_BIND_MW) | 3873 (1ull << IB_USER_VERBS_CMD_DEALLOC_MW) | 3874 (1ull << IB_USER_VERBS_CMD_POST_RECV) | 3875 (1ull << IB_USER_VERBS_CMD_POST_SEND); 3876 3877 nesibdev->ibdev.phys_port_cnt = 1; 3878 nesibdev->ibdev.num_comp_vectors = 1; 3879 nesibdev->ibdev.dma_device = &nesdev->pcidev->dev; 3880 nesibdev->ibdev.dev.parent = &nesdev->pcidev->dev; 3881 nesibdev->ibdev.query_device = nes_query_device; 3882 nesibdev->ibdev.query_port = nes_query_port; 3883 nesibdev->ibdev.modify_port = nes_modify_port; 3884 nesibdev->ibdev.query_pkey = nes_query_pkey; 3885 nesibdev->ibdev.query_gid = nes_query_gid; 3886 nesibdev->ibdev.alloc_ucontext = nes_alloc_ucontext; 3887 nesibdev->ibdev.dealloc_ucontext = nes_dealloc_ucontext; 3888 nesibdev->ibdev.mmap = nes_mmap; 3889 nesibdev->ibdev.alloc_pd = nes_alloc_pd; 3890 nesibdev->ibdev.dealloc_pd = nes_dealloc_pd; 3891 nesibdev->ibdev.create_ah = nes_create_ah; 3892 nesibdev->ibdev.destroy_ah = nes_destroy_ah; 3893 nesibdev->ibdev.create_qp = nes_create_qp; 3894 nesibdev->ibdev.modify_qp = nes_modify_qp; 3895 nesibdev->ibdev.query_qp = nes_query_qp; 3896 nesibdev->ibdev.destroy_qp = nes_destroy_qp; 3897 nesibdev->ibdev.create_cq = nes_create_cq; 3898 nesibdev->ibdev.destroy_cq = nes_destroy_cq; 3899 nesibdev->ibdev.poll_cq = nes_poll_cq; 3900 nesibdev->ibdev.get_dma_mr = nes_get_dma_mr; 3901 nesibdev->ibdev.reg_phys_mr = nes_reg_phys_mr; 3902 nesibdev->ibdev.reg_user_mr = nes_reg_user_mr; 3903 nesibdev->ibdev.dereg_mr = nes_dereg_mr; 3904 nesibdev->ibdev.alloc_mw = nes_alloc_mw; 3905 nesibdev->ibdev.dealloc_mw = nes_dealloc_mw; 3906 nesibdev->ibdev.bind_mw = nes_bind_mw; 3907 3908 nesibdev->ibdev.alloc_fast_reg_mr = nes_alloc_fast_reg_mr; 3909 nesibdev->ibdev.alloc_fast_reg_page_list = nes_alloc_fast_reg_page_list; 3910 nesibdev->ibdev.free_fast_reg_page_list = nes_free_fast_reg_page_list; 3911 3912 nesibdev->ibdev.attach_mcast = nes_multicast_attach; 3913 nesibdev->ibdev.detach_mcast = nes_multicast_detach; 3914 nesibdev->ibdev.process_mad = nes_process_mad; 3915 3916 nesibdev->ibdev.req_notify_cq = nes_req_notify_cq; 3917 nesibdev->ibdev.post_send = nes_post_send; 3918 nesibdev->ibdev.post_recv = nes_post_recv; 3919 3920 nesibdev->ibdev.iwcm = kzalloc(sizeof(*nesibdev->ibdev.iwcm), GFP_KERNEL); 3921 if (nesibdev->ibdev.iwcm == NULL) { 3922 ib_dealloc_device(&nesibdev->ibdev); 3923 return NULL; 3924 } 3925 nesibdev->ibdev.iwcm->add_ref = nes_add_ref; 3926 nesibdev->ibdev.iwcm->rem_ref = nes_rem_ref; 3927 nesibdev->ibdev.iwcm->get_qp = nes_get_qp; 3928 nesibdev->ibdev.iwcm->connect = nes_connect; 3929 nesibdev->ibdev.iwcm->accept = nes_accept; 3930 nesibdev->ibdev.iwcm->reject = nes_reject; 3931 nesibdev->ibdev.iwcm->create_listen = nes_create_listen; 3932 nesibdev->ibdev.iwcm->destroy_listen = nes_destroy_listen; 3933 3934 return nesibdev; 3935} 3936 3937void nes_port_ibevent(struct nes_vnic *nesvnic) 3938{ 3939 struct nes_ib_device *nesibdev = nesvnic->nesibdev; 3940 struct nes_device *nesdev = nesvnic->nesdev; 3941 struct ib_event event; 3942 event.device = &nesibdev->ibdev; 3943 event.element.port_num = nesvnic->logical_port + 1; 3944 event.event = nesdev->iw_status ? IB_EVENT_PORT_ACTIVE : IB_EVENT_PORT_ERR; 3945 ib_dispatch_event(&event); 3946} 3947 3948 3949/** 3950 * nes_destroy_ofa_device 3951 */ 3952void nes_destroy_ofa_device(struct nes_ib_device *nesibdev) 3953{ 3954 if (nesibdev == NULL) 3955 return; 3956 3957 nes_unregister_ofa_device(nesibdev); 3958 3959 kfree(nesibdev->ibdev.iwcm); 3960 ib_dealloc_device(&nesibdev->ibdev); 3961} 3962 3963 3964/** 3965 * nes_register_ofa_device 3966 */ 3967int nes_register_ofa_device(struct nes_ib_device *nesibdev) 3968{ 3969 struct nes_vnic *nesvnic = nesibdev->nesvnic; 3970 struct nes_device *nesdev = nesvnic->nesdev; 3971 struct nes_adapter *nesadapter = nesdev->nesadapter; 3972 int i, ret; 3973 3974 ret = ib_register_device(&nesvnic->nesibdev->ibdev, NULL); 3975 if (ret) { 3976 return ret; 3977 } 3978 3979 /* Get the resources allocated to this device */ 3980 nesibdev->max_cq = (nesadapter->max_cq-NES_FIRST_QPN) / nesadapter->port_count; 3981 nesibdev->max_mr = nesadapter->max_mr / nesadapter->port_count; 3982 nesibdev->max_qp = (nesadapter->max_qp-NES_FIRST_QPN) / nesadapter->port_count; 3983 nesibdev->max_pd = nesadapter->max_pd / nesadapter->port_count; 3984 3985 for (i = 0; i < ARRAY_SIZE(nes_dev_attributes); ++i) { 3986 ret = device_create_file(&nesibdev->ibdev.dev, nes_dev_attributes[i]); 3987 if (ret) { 3988 while (i > 0) { 3989 i--; 3990 device_remove_file(&nesibdev->ibdev.dev, 3991 nes_dev_attributes[i]); 3992 } 3993 ib_unregister_device(&nesibdev->ibdev); 3994 return ret; 3995 } 3996 } 3997 3998 nesvnic->of_device_registered = 1; 3999 4000 return 0; 4001} 4002 4003 4004/** 4005 * nes_unregister_ofa_device 4006 */ 4007static void nes_unregister_ofa_device(struct nes_ib_device *nesibdev) 4008{ 4009 struct nes_vnic *nesvnic = nesibdev->nesvnic; 4010 int i; 4011 4012 for (i = 0; i < ARRAY_SIZE(nes_dev_attributes); ++i) { 4013 device_remove_file(&nesibdev->ibdev.dev, nes_dev_attributes[i]); 4014 } 4015 4016 if (nesvnic->of_device_registered) { 4017 ib_unregister_device(&nesibdev->ibdev); 4018 } 4019 4020 nesvnic->of_device_registered = 0; 4021} 4022