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