verbs.c 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949
  1. /*
  2. * Copyright (c) 2004 Mellanox Technologies Ltd. All rights reserved.
  3. * Copyright (c) 2004 Infinicon Corporation. All rights reserved.
  4. * Copyright (c) 2004 Intel Corporation. All rights reserved.
  5. * Copyright (c) 2004 Topspin Corporation. All rights reserved.
  6. * Copyright (c) 2004 Voltaire Corporation. All rights reserved.
  7. * Copyright (c) 2005 Sun Microsystems, Inc. All rights reserved.
  8. * Copyright (c) 2005, 2006 Cisco Systems. All rights reserved.
  9. *
  10. * This software is available to you under a choice of one of two
  11. * licenses. You may choose to be licensed under the terms of the GNU
  12. * General Public License (GPL) Version 2, available from the file
  13. * COPYING in the main directory of this source tree, or the
  14. * OpenIB.org BSD license below:
  15. *
  16. * Redistribution and use in source and binary forms, with or
  17. * without modification, are permitted provided that the following
  18. * conditions are met:
  19. *
  20. * - Redistributions of source code must retain the above
  21. * copyright notice, this list of conditions and the following
  22. * disclaimer.
  23. *
  24. * - Redistributions in binary form must reproduce the above
  25. * copyright notice, this list of conditions and the following
  26. * disclaimer in the documentation and/or other materials
  27. * provided with the distribution.
  28. *
  29. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  30. * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  31. * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  32. * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
  33. * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
  34. * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  35. * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  36. * SOFTWARE.
  37. */
  38. #include <linux/errno.h>
  39. #include <linux/err.h>
  40. #include <linux/string.h>
  41. #include <rdma/ib_verbs.h>
  42. #include <rdma/ib_cache.h>
  43. int ib_rate_to_mult(enum ib_rate rate)
  44. {
  45. switch (rate) {
  46. case IB_RATE_2_5_GBPS: return 1;
  47. case IB_RATE_5_GBPS: return 2;
  48. case IB_RATE_10_GBPS: return 4;
  49. case IB_RATE_20_GBPS: return 8;
  50. case IB_RATE_30_GBPS: return 12;
  51. case IB_RATE_40_GBPS: return 16;
  52. case IB_RATE_60_GBPS: return 24;
  53. case IB_RATE_80_GBPS: return 32;
  54. case IB_RATE_120_GBPS: return 48;
  55. default: return -1;
  56. }
  57. }
  58. EXPORT_SYMBOL(ib_rate_to_mult);
  59. enum ib_rate mult_to_ib_rate(int mult)
  60. {
  61. switch (mult) {
  62. case 1: return IB_RATE_2_5_GBPS;
  63. case 2: return IB_RATE_5_GBPS;
  64. case 4: return IB_RATE_10_GBPS;
  65. case 8: return IB_RATE_20_GBPS;
  66. case 12: return IB_RATE_30_GBPS;
  67. case 16: return IB_RATE_40_GBPS;
  68. case 24: return IB_RATE_60_GBPS;
  69. case 32: return IB_RATE_80_GBPS;
  70. case 48: return IB_RATE_120_GBPS;
  71. default: return IB_RATE_PORT_CURRENT;
  72. }
  73. }
  74. EXPORT_SYMBOL(mult_to_ib_rate);
  75. enum rdma_transport_type
  76. rdma_node_get_transport(enum rdma_node_type node_type)
  77. {
  78. switch (node_type) {
  79. case RDMA_NODE_IB_CA:
  80. case RDMA_NODE_IB_SWITCH:
  81. case RDMA_NODE_IB_ROUTER:
  82. return RDMA_TRANSPORT_IB;
  83. case RDMA_NODE_RNIC:
  84. return RDMA_TRANSPORT_IWARP;
  85. default:
  86. BUG();
  87. return 0;
  88. }
  89. }
  90. EXPORT_SYMBOL(rdma_node_get_transport);
  91. enum rdma_link_layer rdma_port_get_link_layer(struct ib_device *device, u8 port_num)
  92. {
  93. if (device->get_link_layer)
  94. return device->get_link_layer(device, port_num);
  95. switch (rdma_node_get_transport(device->node_type)) {
  96. case RDMA_TRANSPORT_IB:
  97. return IB_LINK_LAYER_INFINIBAND;
  98. case RDMA_TRANSPORT_IWARP:
  99. return IB_LINK_LAYER_ETHERNET;
  100. default:
  101. return IB_LINK_LAYER_UNSPECIFIED;
  102. }
  103. }
  104. EXPORT_SYMBOL(rdma_port_get_link_layer);
  105. /* Protection domains */
  106. struct ib_pd *ib_alloc_pd(struct ib_device *device)
  107. {
  108. struct ib_pd *pd;
  109. pd = device->alloc_pd(device, NULL, NULL);
  110. if (!IS_ERR(pd)) {
  111. pd->device = device;
  112. pd->uobject = NULL;
  113. atomic_set(&pd->usecnt, 0);
  114. }
  115. return pd;
  116. }
  117. EXPORT_SYMBOL(ib_alloc_pd);
  118. int ib_dealloc_pd(struct ib_pd *pd)
  119. {
  120. if (atomic_read(&pd->usecnt))
  121. return -EBUSY;
  122. return pd->device->dealloc_pd(pd);
  123. }
  124. EXPORT_SYMBOL(ib_dealloc_pd);
  125. /* Address handles */
  126. struct ib_ah *ib_create_ah(struct ib_pd *pd, struct ib_ah_attr *ah_attr)
  127. {
  128. struct ib_ah *ah;
  129. ah = pd->device->create_ah(pd, ah_attr);
  130. if (!IS_ERR(ah)) {
  131. ah->device = pd->device;
  132. ah->pd = pd;
  133. ah->uobject = NULL;
  134. atomic_inc(&pd->usecnt);
  135. }
  136. return ah;
  137. }
  138. EXPORT_SYMBOL(ib_create_ah);
  139. int ib_init_ah_from_wc(struct ib_device *device, u8 port_num, struct ib_wc *wc,
  140. struct ib_grh *grh, struct ib_ah_attr *ah_attr)
  141. {
  142. u32 flow_class;
  143. u16 gid_index;
  144. int ret;
  145. memset(ah_attr, 0, sizeof *ah_attr);
  146. ah_attr->dlid = wc->slid;
  147. ah_attr->sl = wc->sl;
  148. ah_attr->src_path_bits = wc->dlid_path_bits;
  149. ah_attr->port_num = port_num;
  150. if (wc->wc_flags & IB_WC_GRH) {
  151. ah_attr->ah_flags = IB_AH_GRH;
  152. ah_attr->grh.dgid = grh->sgid;
  153. ret = ib_find_cached_gid(device, &grh->dgid, &port_num,
  154. &gid_index);
  155. if (ret)
  156. return ret;
  157. ah_attr->grh.sgid_index = (u8) gid_index;
  158. flow_class = be32_to_cpu(grh->version_tclass_flow);
  159. ah_attr->grh.flow_label = flow_class & 0xFFFFF;
  160. ah_attr->grh.hop_limit = 0xFF;
  161. ah_attr->grh.traffic_class = (flow_class >> 20) & 0xFF;
  162. }
  163. return 0;
  164. }
  165. EXPORT_SYMBOL(ib_init_ah_from_wc);
  166. struct ib_ah *ib_create_ah_from_wc(struct ib_pd *pd, struct ib_wc *wc,
  167. struct ib_grh *grh, u8 port_num)
  168. {
  169. struct ib_ah_attr ah_attr;
  170. int ret;
  171. ret = ib_init_ah_from_wc(pd->device, port_num, wc, grh, &ah_attr);
  172. if (ret)
  173. return ERR_PTR(ret);
  174. return ib_create_ah(pd, &ah_attr);
  175. }
  176. EXPORT_SYMBOL(ib_create_ah_from_wc);
  177. int ib_modify_ah(struct ib_ah *ah, struct ib_ah_attr *ah_attr)
  178. {
  179. return ah->device->modify_ah ?
  180. ah->device->modify_ah(ah, ah_attr) :
  181. -ENOSYS;
  182. }
  183. EXPORT_SYMBOL(ib_modify_ah);
  184. int ib_query_ah(struct ib_ah *ah, struct ib_ah_attr *ah_attr)
  185. {
  186. return ah->device->query_ah ?
  187. ah->device->query_ah(ah, ah_attr) :
  188. -ENOSYS;
  189. }
  190. EXPORT_SYMBOL(ib_query_ah);
  191. int ib_destroy_ah(struct ib_ah *ah)
  192. {
  193. struct ib_pd *pd;
  194. int ret;
  195. pd = ah->pd;
  196. ret = ah->device->destroy_ah(ah);
  197. if (!ret)
  198. atomic_dec(&pd->usecnt);
  199. return ret;
  200. }
  201. EXPORT_SYMBOL(ib_destroy_ah);
  202. /* Shared receive queues */
  203. struct ib_srq *ib_create_srq(struct ib_pd *pd,
  204. struct ib_srq_init_attr *srq_init_attr)
  205. {
  206. struct ib_srq *srq;
  207. if (!pd->device->create_srq)
  208. return ERR_PTR(-ENOSYS);
  209. srq = pd->device->create_srq(pd, srq_init_attr, NULL);
  210. if (!IS_ERR(srq)) {
  211. srq->device = pd->device;
  212. srq->pd = pd;
  213. srq->uobject = NULL;
  214. srq->event_handler = srq_init_attr->event_handler;
  215. srq->srq_context = srq_init_attr->srq_context;
  216. srq->srq_type = srq_init_attr->srq_type;
  217. atomic_inc(&pd->usecnt);
  218. atomic_set(&srq->usecnt, 0);
  219. }
  220. return srq;
  221. }
  222. EXPORT_SYMBOL(ib_create_srq);
  223. int ib_modify_srq(struct ib_srq *srq,
  224. struct ib_srq_attr *srq_attr,
  225. enum ib_srq_attr_mask srq_attr_mask)
  226. {
  227. return srq->device->modify_srq ?
  228. srq->device->modify_srq(srq, srq_attr, srq_attr_mask, NULL) :
  229. -ENOSYS;
  230. }
  231. EXPORT_SYMBOL(ib_modify_srq);
  232. int ib_query_srq(struct ib_srq *srq,
  233. struct ib_srq_attr *srq_attr)
  234. {
  235. return srq->device->query_srq ?
  236. srq->device->query_srq(srq, srq_attr) : -ENOSYS;
  237. }
  238. EXPORT_SYMBOL(ib_query_srq);
  239. int ib_destroy_srq(struct ib_srq *srq)
  240. {
  241. struct ib_pd *pd;
  242. int ret;
  243. if (atomic_read(&srq->usecnt))
  244. return -EBUSY;
  245. pd = srq->pd;
  246. ret = srq->device->destroy_srq(srq);
  247. if (!ret)
  248. atomic_dec(&pd->usecnt);
  249. return ret;
  250. }
  251. EXPORT_SYMBOL(ib_destroy_srq);
  252. /* Queue pairs */
  253. struct ib_qp *ib_create_qp(struct ib_pd *pd,
  254. struct ib_qp_init_attr *qp_init_attr)
  255. {
  256. struct ib_qp *qp;
  257. qp = pd->device->create_qp(pd, qp_init_attr, NULL);
  258. if (!IS_ERR(qp)) {
  259. qp->device = pd->device;
  260. qp->pd = pd;
  261. qp->send_cq = qp_init_attr->send_cq;
  262. qp->recv_cq = qp_init_attr->recv_cq;
  263. qp->srq = qp_init_attr->srq;
  264. qp->uobject = NULL;
  265. qp->event_handler = qp_init_attr->event_handler;
  266. qp->qp_context = qp_init_attr->qp_context;
  267. qp->qp_type = qp_init_attr->qp_type;
  268. atomic_inc(&pd->usecnt);
  269. atomic_inc(&qp_init_attr->send_cq->usecnt);
  270. atomic_inc(&qp_init_attr->recv_cq->usecnt);
  271. if (qp_init_attr->srq)
  272. atomic_inc(&qp_init_attr->srq->usecnt);
  273. }
  274. return qp;
  275. }
  276. EXPORT_SYMBOL(ib_create_qp);
  277. static const struct {
  278. int valid;
  279. enum ib_qp_attr_mask req_param[IB_QPT_RAW_ETHERTYPE + 1];
  280. enum ib_qp_attr_mask opt_param[IB_QPT_RAW_ETHERTYPE + 1];
  281. } qp_state_table[IB_QPS_ERR + 1][IB_QPS_ERR + 1] = {
  282. [IB_QPS_RESET] = {
  283. [IB_QPS_RESET] = { .valid = 1 },
  284. [IB_QPS_INIT] = {
  285. .valid = 1,
  286. .req_param = {
  287. [IB_QPT_UD] = (IB_QP_PKEY_INDEX |
  288. IB_QP_PORT |
  289. IB_QP_QKEY),
  290. [IB_QPT_UC] = (IB_QP_PKEY_INDEX |
  291. IB_QP_PORT |
  292. IB_QP_ACCESS_FLAGS),
  293. [IB_QPT_RC] = (IB_QP_PKEY_INDEX |
  294. IB_QP_PORT |
  295. IB_QP_ACCESS_FLAGS),
  296. [IB_QPT_SMI] = (IB_QP_PKEY_INDEX |
  297. IB_QP_QKEY),
  298. [IB_QPT_GSI] = (IB_QP_PKEY_INDEX |
  299. IB_QP_QKEY),
  300. }
  301. },
  302. },
  303. [IB_QPS_INIT] = {
  304. [IB_QPS_RESET] = { .valid = 1 },
  305. [IB_QPS_ERR] = { .valid = 1 },
  306. [IB_QPS_INIT] = {
  307. .valid = 1,
  308. .opt_param = {
  309. [IB_QPT_UD] = (IB_QP_PKEY_INDEX |
  310. IB_QP_PORT |
  311. IB_QP_QKEY),
  312. [IB_QPT_UC] = (IB_QP_PKEY_INDEX |
  313. IB_QP_PORT |
  314. IB_QP_ACCESS_FLAGS),
  315. [IB_QPT_RC] = (IB_QP_PKEY_INDEX |
  316. IB_QP_PORT |
  317. IB_QP_ACCESS_FLAGS),
  318. [IB_QPT_SMI] = (IB_QP_PKEY_INDEX |
  319. IB_QP_QKEY),
  320. [IB_QPT_GSI] = (IB_QP_PKEY_INDEX |
  321. IB_QP_QKEY),
  322. }
  323. },
  324. [IB_QPS_RTR] = {
  325. .valid = 1,
  326. .req_param = {
  327. [IB_QPT_UC] = (IB_QP_AV |
  328. IB_QP_PATH_MTU |
  329. IB_QP_DEST_QPN |
  330. IB_QP_RQ_PSN),
  331. [IB_QPT_RC] = (IB_QP_AV |
  332. IB_QP_PATH_MTU |
  333. IB_QP_DEST_QPN |
  334. IB_QP_RQ_PSN |
  335. IB_QP_MAX_DEST_RD_ATOMIC |
  336. IB_QP_MIN_RNR_TIMER),
  337. },
  338. .opt_param = {
  339. [IB_QPT_UD] = (IB_QP_PKEY_INDEX |
  340. IB_QP_QKEY),
  341. [IB_QPT_UC] = (IB_QP_ALT_PATH |
  342. IB_QP_ACCESS_FLAGS |
  343. IB_QP_PKEY_INDEX),
  344. [IB_QPT_RC] = (IB_QP_ALT_PATH |
  345. IB_QP_ACCESS_FLAGS |
  346. IB_QP_PKEY_INDEX),
  347. [IB_QPT_SMI] = (IB_QP_PKEY_INDEX |
  348. IB_QP_QKEY),
  349. [IB_QPT_GSI] = (IB_QP_PKEY_INDEX |
  350. IB_QP_QKEY),
  351. }
  352. }
  353. },
  354. [IB_QPS_RTR] = {
  355. [IB_QPS_RESET] = { .valid = 1 },
  356. [IB_QPS_ERR] = { .valid = 1 },
  357. [IB_QPS_RTS] = {
  358. .valid = 1,
  359. .req_param = {
  360. [IB_QPT_UD] = IB_QP_SQ_PSN,
  361. [IB_QPT_UC] = IB_QP_SQ_PSN,
  362. [IB_QPT_RC] = (IB_QP_TIMEOUT |
  363. IB_QP_RETRY_CNT |
  364. IB_QP_RNR_RETRY |
  365. IB_QP_SQ_PSN |
  366. IB_QP_MAX_QP_RD_ATOMIC),
  367. [IB_QPT_SMI] = IB_QP_SQ_PSN,
  368. [IB_QPT_GSI] = IB_QP_SQ_PSN,
  369. },
  370. .opt_param = {
  371. [IB_QPT_UD] = (IB_QP_CUR_STATE |
  372. IB_QP_QKEY),
  373. [IB_QPT_UC] = (IB_QP_CUR_STATE |
  374. IB_QP_ALT_PATH |
  375. IB_QP_ACCESS_FLAGS |
  376. IB_QP_PATH_MIG_STATE),
  377. [IB_QPT_RC] = (IB_QP_CUR_STATE |
  378. IB_QP_ALT_PATH |
  379. IB_QP_ACCESS_FLAGS |
  380. IB_QP_MIN_RNR_TIMER |
  381. IB_QP_PATH_MIG_STATE),
  382. [IB_QPT_SMI] = (IB_QP_CUR_STATE |
  383. IB_QP_QKEY),
  384. [IB_QPT_GSI] = (IB_QP_CUR_STATE |
  385. IB_QP_QKEY),
  386. }
  387. }
  388. },
  389. [IB_QPS_RTS] = {
  390. [IB_QPS_RESET] = { .valid = 1 },
  391. [IB_QPS_ERR] = { .valid = 1 },
  392. [IB_QPS_RTS] = {
  393. .valid = 1,
  394. .opt_param = {
  395. [IB_QPT_UD] = (IB_QP_CUR_STATE |
  396. IB_QP_QKEY),
  397. [IB_QPT_UC] = (IB_QP_CUR_STATE |
  398. IB_QP_ACCESS_FLAGS |
  399. IB_QP_ALT_PATH |
  400. IB_QP_PATH_MIG_STATE),
  401. [IB_QPT_RC] = (IB_QP_CUR_STATE |
  402. IB_QP_ACCESS_FLAGS |
  403. IB_QP_ALT_PATH |
  404. IB_QP_PATH_MIG_STATE |
  405. IB_QP_MIN_RNR_TIMER),
  406. [IB_QPT_SMI] = (IB_QP_CUR_STATE |
  407. IB_QP_QKEY),
  408. [IB_QPT_GSI] = (IB_QP_CUR_STATE |
  409. IB_QP_QKEY),
  410. }
  411. },
  412. [IB_QPS_SQD] = {
  413. .valid = 1,
  414. .opt_param = {
  415. [IB_QPT_UD] = IB_QP_EN_SQD_ASYNC_NOTIFY,
  416. [IB_QPT_UC] = IB_QP_EN_SQD_ASYNC_NOTIFY,
  417. [IB_QPT_RC] = IB_QP_EN_SQD_ASYNC_NOTIFY,
  418. [IB_QPT_SMI] = IB_QP_EN_SQD_ASYNC_NOTIFY,
  419. [IB_QPT_GSI] = IB_QP_EN_SQD_ASYNC_NOTIFY
  420. }
  421. },
  422. },
  423. [IB_QPS_SQD] = {
  424. [IB_QPS_RESET] = { .valid = 1 },
  425. [IB_QPS_ERR] = { .valid = 1 },
  426. [IB_QPS_RTS] = {
  427. .valid = 1,
  428. .opt_param = {
  429. [IB_QPT_UD] = (IB_QP_CUR_STATE |
  430. IB_QP_QKEY),
  431. [IB_QPT_UC] = (IB_QP_CUR_STATE |
  432. IB_QP_ALT_PATH |
  433. IB_QP_ACCESS_FLAGS |
  434. IB_QP_PATH_MIG_STATE),
  435. [IB_QPT_RC] = (IB_QP_CUR_STATE |
  436. IB_QP_ALT_PATH |
  437. IB_QP_ACCESS_FLAGS |
  438. IB_QP_MIN_RNR_TIMER |
  439. IB_QP_PATH_MIG_STATE),
  440. [IB_QPT_SMI] = (IB_QP_CUR_STATE |
  441. IB_QP_QKEY),
  442. [IB_QPT_GSI] = (IB_QP_CUR_STATE |
  443. IB_QP_QKEY),
  444. }
  445. },
  446. [IB_QPS_SQD] = {
  447. .valid = 1,
  448. .opt_param = {
  449. [IB_QPT_UD] = (IB_QP_PKEY_INDEX |
  450. IB_QP_QKEY),
  451. [IB_QPT_UC] = (IB_QP_AV |
  452. IB_QP_ALT_PATH |
  453. IB_QP_ACCESS_FLAGS |
  454. IB_QP_PKEY_INDEX |
  455. IB_QP_PATH_MIG_STATE),
  456. [IB_QPT_RC] = (IB_QP_PORT |
  457. IB_QP_AV |
  458. IB_QP_TIMEOUT |
  459. IB_QP_RETRY_CNT |
  460. IB_QP_RNR_RETRY |
  461. IB_QP_MAX_QP_RD_ATOMIC |
  462. IB_QP_MAX_DEST_RD_ATOMIC |
  463. IB_QP_ALT_PATH |
  464. IB_QP_ACCESS_FLAGS |
  465. IB_QP_PKEY_INDEX |
  466. IB_QP_MIN_RNR_TIMER |
  467. IB_QP_PATH_MIG_STATE),
  468. [IB_QPT_SMI] = (IB_QP_PKEY_INDEX |
  469. IB_QP_QKEY),
  470. [IB_QPT_GSI] = (IB_QP_PKEY_INDEX |
  471. IB_QP_QKEY),
  472. }
  473. }
  474. },
  475. [IB_QPS_SQE] = {
  476. [IB_QPS_RESET] = { .valid = 1 },
  477. [IB_QPS_ERR] = { .valid = 1 },
  478. [IB_QPS_RTS] = {
  479. .valid = 1,
  480. .opt_param = {
  481. [IB_QPT_UD] = (IB_QP_CUR_STATE |
  482. IB_QP_QKEY),
  483. [IB_QPT_UC] = (IB_QP_CUR_STATE |
  484. IB_QP_ACCESS_FLAGS),
  485. [IB_QPT_SMI] = (IB_QP_CUR_STATE |
  486. IB_QP_QKEY),
  487. [IB_QPT_GSI] = (IB_QP_CUR_STATE |
  488. IB_QP_QKEY),
  489. }
  490. }
  491. },
  492. [IB_QPS_ERR] = {
  493. [IB_QPS_RESET] = { .valid = 1 },
  494. [IB_QPS_ERR] = { .valid = 1 }
  495. }
  496. };
  497. int ib_modify_qp_is_ok(enum ib_qp_state cur_state, enum ib_qp_state next_state,
  498. enum ib_qp_type type, enum ib_qp_attr_mask mask)
  499. {
  500. enum ib_qp_attr_mask req_param, opt_param;
  501. if (cur_state < 0 || cur_state > IB_QPS_ERR ||
  502. next_state < 0 || next_state > IB_QPS_ERR)
  503. return 0;
  504. if (mask & IB_QP_CUR_STATE &&
  505. cur_state != IB_QPS_RTR && cur_state != IB_QPS_RTS &&
  506. cur_state != IB_QPS_SQD && cur_state != IB_QPS_SQE)
  507. return 0;
  508. if (!qp_state_table[cur_state][next_state].valid)
  509. return 0;
  510. req_param = qp_state_table[cur_state][next_state].req_param[type];
  511. opt_param = qp_state_table[cur_state][next_state].opt_param[type];
  512. if ((mask & req_param) != req_param)
  513. return 0;
  514. if (mask & ~(req_param | opt_param | IB_QP_STATE))
  515. return 0;
  516. return 1;
  517. }
  518. EXPORT_SYMBOL(ib_modify_qp_is_ok);
  519. int ib_modify_qp(struct ib_qp *qp,
  520. struct ib_qp_attr *qp_attr,
  521. int qp_attr_mask)
  522. {
  523. return qp->device->modify_qp(qp, qp_attr, qp_attr_mask, NULL);
  524. }
  525. EXPORT_SYMBOL(ib_modify_qp);
  526. int ib_query_qp(struct ib_qp *qp,
  527. struct ib_qp_attr *qp_attr,
  528. int qp_attr_mask,
  529. struct ib_qp_init_attr *qp_init_attr)
  530. {
  531. return qp->device->query_qp ?
  532. qp->device->query_qp(qp, qp_attr, qp_attr_mask, qp_init_attr) :
  533. -ENOSYS;
  534. }
  535. EXPORT_SYMBOL(ib_query_qp);
  536. int ib_destroy_qp(struct ib_qp *qp)
  537. {
  538. struct ib_pd *pd;
  539. struct ib_cq *scq, *rcq;
  540. struct ib_srq *srq;
  541. int ret;
  542. pd = qp->pd;
  543. scq = qp->send_cq;
  544. rcq = qp->recv_cq;
  545. srq = qp->srq;
  546. ret = qp->device->destroy_qp(qp);
  547. if (!ret) {
  548. atomic_dec(&pd->usecnt);
  549. atomic_dec(&scq->usecnt);
  550. atomic_dec(&rcq->usecnt);
  551. if (srq)
  552. atomic_dec(&srq->usecnt);
  553. }
  554. return ret;
  555. }
  556. EXPORT_SYMBOL(ib_destroy_qp);
  557. /* Completion queues */
  558. struct ib_cq *ib_create_cq(struct ib_device *device,
  559. ib_comp_handler comp_handler,
  560. void (*event_handler)(struct ib_event *, void *),
  561. void *cq_context, int cqe, int comp_vector)
  562. {
  563. struct ib_cq *cq;
  564. cq = device->create_cq(device, cqe, comp_vector, NULL, NULL);
  565. if (!IS_ERR(cq)) {
  566. cq->device = device;
  567. cq->uobject = NULL;
  568. cq->comp_handler = comp_handler;
  569. cq->event_handler = event_handler;
  570. cq->cq_context = cq_context;
  571. atomic_set(&cq->usecnt, 0);
  572. }
  573. return cq;
  574. }
  575. EXPORT_SYMBOL(ib_create_cq);
  576. int ib_modify_cq(struct ib_cq *cq, u16 cq_count, u16 cq_period)
  577. {
  578. return cq->device->modify_cq ?
  579. cq->device->modify_cq(cq, cq_count, cq_period) : -ENOSYS;
  580. }
  581. EXPORT_SYMBOL(ib_modify_cq);
  582. int ib_destroy_cq(struct ib_cq *cq)
  583. {
  584. if (atomic_read(&cq->usecnt))
  585. return -EBUSY;
  586. return cq->device->destroy_cq(cq);
  587. }
  588. EXPORT_SYMBOL(ib_destroy_cq);
  589. int ib_resize_cq(struct ib_cq *cq, int cqe)
  590. {
  591. return cq->device->resize_cq ?
  592. cq->device->resize_cq(cq, cqe, NULL) : -ENOSYS;
  593. }
  594. EXPORT_SYMBOL(ib_resize_cq);
  595. /* Memory regions */
  596. struct ib_mr *ib_get_dma_mr(struct ib_pd *pd, int mr_access_flags)
  597. {
  598. struct ib_mr *mr;
  599. mr = pd->device->get_dma_mr(pd, mr_access_flags);
  600. if (!IS_ERR(mr)) {
  601. mr->device = pd->device;
  602. mr->pd = pd;
  603. mr->uobject = NULL;
  604. atomic_inc(&pd->usecnt);
  605. atomic_set(&mr->usecnt, 0);
  606. }
  607. return mr;
  608. }
  609. EXPORT_SYMBOL(ib_get_dma_mr);
  610. struct ib_mr *ib_reg_phys_mr(struct ib_pd *pd,
  611. struct ib_phys_buf *phys_buf_array,
  612. int num_phys_buf,
  613. int mr_access_flags,
  614. u64 *iova_start)
  615. {
  616. struct ib_mr *mr;
  617. if (!pd->device->reg_phys_mr)
  618. return ERR_PTR(-ENOSYS);
  619. mr = pd->device->reg_phys_mr(pd, phys_buf_array, num_phys_buf,
  620. mr_access_flags, iova_start);
  621. if (!IS_ERR(mr)) {
  622. mr->device = pd->device;
  623. mr->pd = pd;
  624. mr->uobject = NULL;
  625. atomic_inc(&pd->usecnt);
  626. atomic_set(&mr->usecnt, 0);
  627. }
  628. return mr;
  629. }
  630. EXPORT_SYMBOL(ib_reg_phys_mr);
  631. int ib_rereg_phys_mr(struct ib_mr *mr,
  632. int mr_rereg_mask,
  633. struct ib_pd *pd,
  634. struct ib_phys_buf *phys_buf_array,
  635. int num_phys_buf,
  636. int mr_access_flags,
  637. u64 *iova_start)
  638. {
  639. struct ib_pd *old_pd;
  640. int ret;
  641. if (!mr->device->rereg_phys_mr)
  642. return -ENOSYS;
  643. if (atomic_read(&mr->usecnt))
  644. return -EBUSY;
  645. old_pd = mr->pd;
  646. ret = mr->device->rereg_phys_mr(mr, mr_rereg_mask, pd,
  647. phys_buf_array, num_phys_buf,
  648. mr_access_flags, iova_start);
  649. if (!ret && (mr_rereg_mask & IB_MR_REREG_PD)) {
  650. atomic_dec(&old_pd->usecnt);
  651. atomic_inc(&pd->usecnt);
  652. }
  653. return ret;
  654. }
  655. EXPORT_SYMBOL(ib_rereg_phys_mr);
  656. int ib_query_mr(struct ib_mr *mr, struct ib_mr_attr *mr_attr)
  657. {
  658. return mr->device->query_mr ?
  659. mr->device->query_mr(mr, mr_attr) : -ENOSYS;
  660. }
  661. EXPORT_SYMBOL(ib_query_mr);
  662. int ib_dereg_mr(struct ib_mr *mr)
  663. {
  664. struct ib_pd *pd;
  665. int ret;
  666. if (atomic_read(&mr->usecnt))
  667. return -EBUSY;
  668. pd = mr->pd;
  669. ret = mr->device->dereg_mr(mr);
  670. if (!ret)
  671. atomic_dec(&pd->usecnt);
  672. return ret;
  673. }
  674. EXPORT_SYMBOL(ib_dereg_mr);
  675. struct ib_mr *ib_alloc_fast_reg_mr(struct ib_pd *pd, int max_page_list_len)
  676. {
  677. struct ib_mr *mr;
  678. if (!pd->device->alloc_fast_reg_mr)
  679. return ERR_PTR(-ENOSYS);
  680. mr = pd->device->alloc_fast_reg_mr(pd, max_page_list_len);
  681. if (!IS_ERR(mr)) {
  682. mr->device = pd->device;
  683. mr->pd = pd;
  684. mr->uobject = NULL;
  685. atomic_inc(&pd->usecnt);
  686. atomic_set(&mr->usecnt, 0);
  687. }
  688. return mr;
  689. }
  690. EXPORT_SYMBOL(ib_alloc_fast_reg_mr);
  691. struct ib_fast_reg_page_list *ib_alloc_fast_reg_page_list(struct ib_device *device,
  692. int max_page_list_len)
  693. {
  694. struct ib_fast_reg_page_list *page_list;
  695. if (!device->alloc_fast_reg_page_list)
  696. return ERR_PTR(-ENOSYS);
  697. page_list = device->alloc_fast_reg_page_list(device, max_page_list_len);
  698. if (!IS_ERR(page_list)) {
  699. page_list->device = device;
  700. page_list->max_page_list_len = max_page_list_len;
  701. }
  702. return page_list;
  703. }
  704. EXPORT_SYMBOL(ib_alloc_fast_reg_page_list);
  705. void ib_free_fast_reg_page_list(struct ib_fast_reg_page_list *page_list)
  706. {
  707. page_list->device->free_fast_reg_page_list(page_list);
  708. }
  709. EXPORT_SYMBOL(ib_free_fast_reg_page_list);
  710. /* Memory windows */
  711. struct ib_mw *ib_alloc_mw(struct ib_pd *pd)
  712. {
  713. struct ib_mw *mw;
  714. if (!pd->device->alloc_mw)
  715. return ERR_PTR(-ENOSYS);
  716. mw = pd->device->alloc_mw(pd);
  717. if (!IS_ERR(mw)) {
  718. mw->device = pd->device;
  719. mw->pd = pd;
  720. mw->uobject = NULL;
  721. atomic_inc(&pd->usecnt);
  722. }
  723. return mw;
  724. }
  725. EXPORT_SYMBOL(ib_alloc_mw);
  726. int ib_dealloc_mw(struct ib_mw *mw)
  727. {
  728. struct ib_pd *pd;
  729. int ret;
  730. pd = mw->pd;
  731. ret = mw->device->dealloc_mw(mw);
  732. if (!ret)
  733. atomic_dec(&pd->usecnt);
  734. return ret;
  735. }
  736. EXPORT_SYMBOL(ib_dealloc_mw);
  737. /* "Fast" memory regions */
  738. struct ib_fmr *ib_alloc_fmr(struct ib_pd *pd,
  739. int mr_access_flags,
  740. struct ib_fmr_attr *fmr_attr)
  741. {
  742. struct ib_fmr *fmr;
  743. if (!pd->device->alloc_fmr)
  744. return ERR_PTR(-ENOSYS);
  745. fmr = pd->device->alloc_fmr(pd, mr_access_flags, fmr_attr);
  746. if (!IS_ERR(fmr)) {
  747. fmr->device = pd->device;
  748. fmr->pd = pd;
  749. atomic_inc(&pd->usecnt);
  750. }
  751. return fmr;
  752. }
  753. EXPORT_SYMBOL(ib_alloc_fmr);
  754. int ib_unmap_fmr(struct list_head *fmr_list)
  755. {
  756. struct ib_fmr *fmr;
  757. if (list_empty(fmr_list))
  758. return 0;
  759. fmr = list_entry(fmr_list->next, struct ib_fmr, list);
  760. return fmr->device->unmap_fmr(fmr_list);
  761. }
  762. EXPORT_SYMBOL(ib_unmap_fmr);
  763. int ib_dealloc_fmr(struct ib_fmr *fmr)
  764. {
  765. struct ib_pd *pd;
  766. int ret;
  767. pd = fmr->pd;
  768. ret = fmr->device->dealloc_fmr(fmr);
  769. if (!ret)
  770. atomic_dec(&pd->usecnt);
  771. return ret;
  772. }
  773. EXPORT_SYMBOL(ib_dealloc_fmr);
  774. /* Multicast groups */
  775. int ib_attach_mcast(struct ib_qp *qp, union ib_gid *gid, u16 lid)
  776. {
  777. if (!qp->device->attach_mcast)
  778. return -ENOSYS;
  779. if (gid->raw[0] != 0xff || qp->qp_type != IB_QPT_UD)
  780. return -EINVAL;
  781. return qp->device->attach_mcast(qp, gid, lid);
  782. }
  783. EXPORT_SYMBOL(ib_attach_mcast);
  784. int ib_detach_mcast(struct ib_qp *qp, union ib_gid *gid, u16 lid)
  785. {
  786. if (!qp->device->detach_mcast)
  787. return -ENOSYS;
  788. if (gid->raw[0] != 0xff || qp->qp_type != IB_QPT_UD)
  789. return -EINVAL;
  790. return qp->device->detach_mcast(qp, gid, lid);
  791. }
  792. EXPORT_SYMBOL(ib_detach_mcast);
  793. struct ib_xrcd *ib_alloc_xrcd(struct ib_device *device)
  794. {
  795. struct ib_xrcd *xrcd;
  796. if (!device->alloc_xrcd)
  797. return ERR_PTR(-ENOSYS);
  798. xrcd = device->alloc_xrcd(device, NULL, NULL);
  799. if (!IS_ERR(xrcd)) {
  800. xrcd->device = device;
  801. atomic_set(&xrcd->usecnt, 0);
  802. }
  803. return xrcd;
  804. }
  805. EXPORT_SYMBOL(ib_alloc_xrcd);
  806. int ib_dealloc_xrcd(struct ib_xrcd *xrcd)
  807. {
  808. if (atomic_read(&xrcd->usecnt))
  809. return -EBUSY;
  810. return xrcd->device->dealloc_xrcd(xrcd);
  811. }
  812. EXPORT_SYMBOL(ib_dealloc_xrcd);