verbs.c 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923
  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. atomic_inc(&pd->usecnt);
  217. atomic_set(&srq->usecnt, 0);
  218. }
  219. return srq;
  220. }
  221. EXPORT_SYMBOL(ib_create_srq);
  222. int ib_modify_srq(struct ib_srq *srq,
  223. struct ib_srq_attr *srq_attr,
  224. enum ib_srq_attr_mask srq_attr_mask)
  225. {
  226. return srq->device->modify_srq ?
  227. srq->device->modify_srq(srq, srq_attr, srq_attr_mask, NULL) :
  228. -ENOSYS;
  229. }
  230. EXPORT_SYMBOL(ib_modify_srq);
  231. int ib_query_srq(struct ib_srq *srq,
  232. struct ib_srq_attr *srq_attr)
  233. {
  234. return srq->device->query_srq ?
  235. srq->device->query_srq(srq, srq_attr) : -ENOSYS;
  236. }
  237. EXPORT_SYMBOL(ib_query_srq);
  238. int ib_destroy_srq(struct ib_srq *srq)
  239. {
  240. struct ib_pd *pd;
  241. int ret;
  242. if (atomic_read(&srq->usecnt))
  243. return -EBUSY;
  244. pd = srq->pd;
  245. ret = srq->device->destroy_srq(srq);
  246. if (!ret)
  247. atomic_dec(&pd->usecnt);
  248. return ret;
  249. }
  250. EXPORT_SYMBOL(ib_destroy_srq);
  251. /* Queue pairs */
  252. struct ib_qp *ib_create_qp(struct ib_pd *pd,
  253. struct ib_qp_init_attr *qp_init_attr)
  254. {
  255. struct ib_qp *qp;
  256. qp = pd->device->create_qp(pd, qp_init_attr, NULL);
  257. if (!IS_ERR(qp)) {
  258. qp->device = pd->device;
  259. qp->pd = pd;
  260. qp->send_cq = qp_init_attr->send_cq;
  261. qp->recv_cq = qp_init_attr->recv_cq;
  262. qp->srq = qp_init_attr->srq;
  263. qp->uobject = NULL;
  264. qp->event_handler = qp_init_attr->event_handler;
  265. qp->qp_context = qp_init_attr->qp_context;
  266. qp->qp_type = qp_init_attr->qp_type;
  267. atomic_inc(&pd->usecnt);
  268. atomic_inc(&qp_init_attr->send_cq->usecnt);
  269. atomic_inc(&qp_init_attr->recv_cq->usecnt);
  270. if (qp_init_attr->srq)
  271. atomic_inc(&qp_init_attr->srq->usecnt);
  272. }
  273. return qp;
  274. }
  275. EXPORT_SYMBOL(ib_create_qp);
  276. static const struct {
  277. int valid;
  278. enum ib_qp_attr_mask req_param[IB_QPT_RAW_ETHERTYPE + 1];
  279. enum ib_qp_attr_mask opt_param[IB_QPT_RAW_ETHERTYPE + 1];
  280. } qp_state_table[IB_QPS_ERR + 1][IB_QPS_ERR + 1] = {
  281. [IB_QPS_RESET] = {
  282. [IB_QPS_RESET] = { .valid = 1 },
  283. [IB_QPS_INIT] = {
  284. .valid = 1,
  285. .req_param = {
  286. [IB_QPT_UD] = (IB_QP_PKEY_INDEX |
  287. IB_QP_PORT |
  288. IB_QP_QKEY),
  289. [IB_QPT_UC] = (IB_QP_PKEY_INDEX |
  290. IB_QP_PORT |
  291. IB_QP_ACCESS_FLAGS),
  292. [IB_QPT_RC] = (IB_QP_PKEY_INDEX |
  293. IB_QP_PORT |
  294. IB_QP_ACCESS_FLAGS),
  295. [IB_QPT_SMI] = (IB_QP_PKEY_INDEX |
  296. IB_QP_QKEY),
  297. [IB_QPT_GSI] = (IB_QP_PKEY_INDEX |
  298. IB_QP_QKEY),
  299. }
  300. },
  301. },
  302. [IB_QPS_INIT] = {
  303. [IB_QPS_RESET] = { .valid = 1 },
  304. [IB_QPS_ERR] = { .valid = 1 },
  305. [IB_QPS_INIT] = {
  306. .valid = 1,
  307. .opt_param = {
  308. [IB_QPT_UD] = (IB_QP_PKEY_INDEX |
  309. IB_QP_PORT |
  310. IB_QP_QKEY),
  311. [IB_QPT_UC] = (IB_QP_PKEY_INDEX |
  312. IB_QP_PORT |
  313. IB_QP_ACCESS_FLAGS),
  314. [IB_QPT_RC] = (IB_QP_PKEY_INDEX |
  315. IB_QP_PORT |
  316. IB_QP_ACCESS_FLAGS),
  317. [IB_QPT_SMI] = (IB_QP_PKEY_INDEX |
  318. IB_QP_QKEY),
  319. [IB_QPT_GSI] = (IB_QP_PKEY_INDEX |
  320. IB_QP_QKEY),
  321. }
  322. },
  323. [IB_QPS_RTR] = {
  324. .valid = 1,
  325. .req_param = {
  326. [IB_QPT_UC] = (IB_QP_AV |
  327. IB_QP_PATH_MTU |
  328. IB_QP_DEST_QPN |
  329. IB_QP_RQ_PSN),
  330. [IB_QPT_RC] = (IB_QP_AV |
  331. IB_QP_PATH_MTU |
  332. IB_QP_DEST_QPN |
  333. IB_QP_RQ_PSN |
  334. IB_QP_MAX_DEST_RD_ATOMIC |
  335. IB_QP_MIN_RNR_TIMER),
  336. },
  337. .opt_param = {
  338. [IB_QPT_UD] = (IB_QP_PKEY_INDEX |
  339. IB_QP_QKEY),
  340. [IB_QPT_UC] = (IB_QP_ALT_PATH |
  341. IB_QP_ACCESS_FLAGS |
  342. IB_QP_PKEY_INDEX),
  343. [IB_QPT_RC] = (IB_QP_ALT_PATH |
  344. IB_QP_ACCESS_FLAGS |
  345. IB_QP_PKEY_INDEX),
  346. [IB_QPT_SMI] = (IB_QP_PKEY_INDEX |
  347. IB_QP_QKEY),
  348. [IB_QPT_GSI] = (IB_QP_PKEY_INDEX |
  349. IB_QP_QKEY),
  350. }
  351. }
  352. },
  353. [IB_QPS_RTR] = {
  354. [IB_QPS_RESET] = { .valid = 1 },
  355. [IB_QPS_ERR] = { .valid = 1 },
  356. [IB_QPS_RTS] = {
  357. .valid = 1,
  358. .req_param = {
  359. [IB_QPT_UD] = IB_QP_SQ_PSN,
  360. [IB_QPT_UC] = IB_QP_SQ_PSN,
  361. [IB_QPT_RC] = (IB_QP_TIMEOUT |
  362. IB_QP_RETRY_CNT |
  363. IB_QP_RNR_RETRY |
  364. IB_QP_SQ_PSN |
  365. IB_QP_MAX_QP_RD_ATOMIC),
  366. [IB_QPT_SMI] = IB_QP_SQ_PSN,
  367. [IB_QPT_GSI] = IB_QP_SQ_PSN,
  368. },
  369. .opt_param = {
  370. [IB_QPT_UD] = (IB_QP_CUR_STATE |
  371. IB_QP_QKEY),
  372. [IB_QPT_UC] = (IB_QP_CUR_STATE |
  373. IB_QP_ALT_PATH |
  374. IB_QP_ACCESS_FLAGS |
  375. IB_QP_PATH_MIG_STATE),
  376. [IB_QPT_RC] = (IB_QP_CUR_STATE |
  377. IB_QP_ALT_PATH |
  378. IB_QP_ACCESS_FLAGS |
  379. IB_QP_MIN_RNR_TIMER |
  380. IB_QP_PATH_MIG_STATE),
  381. [IB_QPT_SMI] = (IB_QP_CUR_STATE |
  382. IB_QP_QKEY),
  383. [IB_QPT_GSI] = (IB_QP_CUR_STATE |
  384. IB_QP_QKEY),
  385. }
  386. }
  387. },
  388. [IB_QPS_RTS] = {
  389. [IB_QPS_RESET] = { .valid = 1 },
  390. [IB_QPS_ERR] = { .valid = 1 },
  391. [IB_QPS_RTS] = {
  392. .valid = 1,
  393. .opt_param = {
  394. [IB_QPT_UD] = (IB_QP_CUR_STATE |
  395. IB_QP_QKEY),
  396. [IB_QPT_UC] = (IB_QP_CUR_STATE |
  397. IB_QP_ACCESS_FLAGS |
  398. IB_QP_ALT_PATH |
  399. IB_QP_PATH_MIG_STATE),
  400. [IB_QPT_RC] = (IB_QP_CUR_STATE |
  401. IB_QP_ACCESS_FLAGS |
  402. IB_QP_ALT_PATH |
  403. IB_QP_PATH_MIG_STATE |
  404. IB_QP_MIN_RNR_TIMER),
  405. [IB_QPT_SMI] = (IB_QP_CUR_STATE |
  406. IB_QP_QKEY),
  407. [IB_QPT_GSI] = (IB_QP_CUR_STATE |
  408. IB_QP_QKEY),
  409. }
  410. },
  411. [IB_QPS_SQD] = {
  412. .valid = 1,
  413. .opt_param = {
  414. [IB_QPT_UD] = IB_QP_EN_SQD_ASYNC_NOTIFY,
  415. [IB_QPT_UC] = IB_QP_EN_SQD_ASYNC_NOTIFY,
  416. [IB_QPT_RC] = IB_QP_EN_SQD_ASYNC_NOTIFY,
  417. [IB_QPT_SMI] = IB_QP_EN_SQD_ASYNC_NOTIFY,
  418. [IB_QPT_GSI] = IB_QP_EN_SQD_ASYNC_NOTIFY
  419. }
  420. },
  421. },
  422. [IB_QPS_SQD] = {
  423. [IB_QPS_RESET] = { .valid = 1 },
  424. [IB_QPS_ERR] = { .valid = 1 },
  425. [IB_QPS_RTS] = {
  426. .valid = 1,
  427. .opt_param = {
  428. [IB_QPT_UD] = (IB_QP_CUR_STATE |
  429. IB_QP_QKEY),
  430. [IB_QPT_UC] = (IB_QP_CUR_STATE |
  431. IB_QP_ALT_PATH |
  432. IB_QP_ACCESS_FLAGS |
  433. IB_QP_PATH_MIG_STATE),
  434. [IB_QPT_RC] = (IB_QP_CUR_STATE |
  435. IB_QP_ALT_PATH |
  436. IB_QP_ACCESS_FLAGS |
  437. IB_QP_MIN_RNR_TIMER |
  438. IB_QP_PATH_MIG_STATE),
  439. [IB_QPT_SMI] = (IB_QP_CUR_STATE |
  440. IB_QP_QKEY),
  441. [IB_QPT_GSI] = (IB_QP_CUR_STATE |
  442. IB_QP_QKEY),
  443. }
  444. },
  445. [IB_QPS_SQD] = {
  446. .valid = 1,
  447. .opt_param = {
  448. [IB_QPT_UD] = (IB_QP_PKEY_INDEX |
  449. IB_QP_QKEY),
  450. [IB_QPT_UC] = (IB_QP_AV |
  451. IB_QP_ALT_PATH |
  452. IB_QP_ACCESS_FLAGS |
  453. IB_QP_PKEY_INDEX |
  454. IB_QP_PATH_MIG_STATE),
  455. [IB_QPT_RC] = (IB_QP_PORT |
  456. IB_QP_AV |
  457. IB_QP_TIMEOUT |
  458. IB_QP_RETRY_CNT |
  459. IB_QP_RNR_RETRY |
  460. IB_QP_MAX_QP_RD_ATOMIC |
  461. IB_QP_MAX_DEST_RD_ATOMIC |
  462. IB_QP_ALT_PATH |
  463. IB_QP_ACCESS_FLAGS |
  464. IB_QP_PKEY_INDEX |
  465. IB_QP_MIN_RNR_TIMER |
  466. IB_QP_PATH_MIG_STATE),
  467. [IB_QPT_SMI] = (IB_QP_PKEY_INDEX |
  468. IB_QP_QKEY),
  469. [IB_QPT_GSI] = (IB_QP_PKEY_INDEX |
  470. IB_QP_QKEY),
  471. }
  472. }
  473. },
  474. [IB_QPS_SQE] = {
  475. [IB_QPS_RESET] = { .valid = 1 },
  476. [IB_QPS_ERR] = { .valid = 1 },
  477. [IB_QPS_RTS] = {
  478. .valid = 1,
  479. .opt_param = {
  480. [IB_QPT_UD] = (IB_QP_CUR_STATE |
  481. IB_QP_QKEY),
  482. [IB_QPT_UC] = (IB_QP_CUR_STATE |
  483. IB_QP_ACCESS_FLAGS),
  484. [IB_QPT_SMI] = (IB_QP_CUR_STATE |
  485. IB_QP_QKEY),
  486. [IB_QPT_GSI] = (IB_QP_CUR_STATE |
  487. IB_QP_QKEY),
  488. }
  489. }
  490. },
  491. [IB_QPS_ERR] = {
  492. [IB_QPS_RESET] = { .valid = 1 },
  493. [IB_QPS_ERR] = { .valid = 1 }
  494. }
  495. };
  496. int ib_modify_qp_is_ok(enum ib_qp_state cur_state, enum ib_qp_state next_state,
  497. enum ib_qp_type type, enum ib_qp_attr_mask mask)
  498. {
  499. enum ib_qp_attr_mask req_param, opt_param;
  500. if (cur_state < 0 || cur_state > IB_QPS_ERR ||
  501. next_state < 0 || next_state > IB_QPS_ERR)
  502. return 0;
  503. if (mask & IB_QP_CUR_STATE &&
  504. cur_state != IB_QPS_RTR && cur_state != IB_QPS_RTS &&
  505. cur_state != IB_QPS_SQD && cur_state != IB_QPS_SQE)
  506. return 0;
  507. if (!qp_state_table[cur_state][next_state].valid)
  508. return 0;
  509. req_param = qp_state_table[cur_state][next_state].req_param[type];
  510. opt_param = qp_state_table[cur_state][next_state].opt_param[type];
  511. if ((mask & req_param) != req_param)
  512. return 0;
  513. if (mask & ~(req_param | opt_param | IB_QP_STATE))
  514. return 0;
  515. return 1;
  516. }
  517. EXPORT_SYMBOL(ib_modify_qp_is_ok);
  518. int ib_modify_qp(struct ib_qp *qp,
  519. struct ib_qp_attr *qp_attr,
  520. int qp_attr_mask)
  521. {
  522. return qp->device->modify_qp(qp, qp_attr, qp_attr_mask, NULL);
  523. }
  524. EXPORT_SYMBOL(ib_modify_qp);
  525. int ib_query_qp(struct ib_qp *qp,
  526. struct ib_qp_attr *qp_attr,
  527. int qp_attr_mask,
  528. struct ib_qp_init_attr *qp_init_attr)
  529. {
  530. return qp->device->query_qp ?
  531. qp->device->query_qp(qp, qp_attr, qp_attr_mask, qp_init_attr) :
  532. -ENOSYS;
  533. }
  534. EXPORT_SYMBOL(ib_query_qp);
  535. int ib_destroy_qp(struct ib_qp *qp)
  536. {
  537. struct ib_pd *pd;
  538. struct ib_cq *scq, *rcq;
  539. struct ib_srq *srq;
  540. int ret;
  541. pd = qp->pd;
  542. scq = qp->send_cq;
  543. rcq = qp->recv_cq;
  544. srq = qp->srq;
  545. ret = qp->device->destroy_qp(qp);
  546. if (!ret) {
  547. atomic_dec(&pd->usecnt);
  548. atomic_dec(&scq->usecnt);
  549. atomic_dec(&rcq->usecnt);
  550. if (srq)
  551. atomic_dec(&srq->usecnt);
  552. }
  553. return ret;
  554. }
  555. EXPORT_SYMBOL(ib_destroy_qp);
  556. /* Completion queues */
  557. struct ib_cq *ib_create_cq(struct ib_device *device,
  558. ib_comp_handler comp_handler,
  559. void (*event_handler)(struct ib_event *, void *),
  560. void *cq_context, int cqe, int comp_vector)
  561. {
  562. struct ib_cq *cq;
  563. cq = device->create_cq(device, cqe, comp_vector, NULL, NULL);
  564. if (!IS_ERR(cq)) {
  565. cq->device = device;
  566. cq->uobject = NULL;
  567. cq->comp_handler = comp_handler;
  568. cq->event_handler = event_handler;
  569. cq->cq_context = cq_context;
  570. atomic_set(&cq->usecnt, 0);
  571. }
  572. return cq;
  573. }
  574. EXPORT_SYMBOL(ib_create_cq);
  575. int ib_modify_cq(struct ib_cq *cq, u16 cq_count, u16 cq_period)
  576. {
  577. return cq->device->modify_cq ?
  578. cq->device->modify_cq(cq, cq_count, cq_period) : -ENOSYS;
  579. }
  580. EXPORT_SYMBOL(ib_modify_cq);
  581. int ib_destroy_cq(struct ib_cq *cq)
  582. {
  583. if (atomic_read(&cq->usecnt))
  584. return -EBUSY;
  585. return cq->device->destroy_cq(cq);
  586. }
  587. EXPORT_SYMBOL(ib_destroy_cq);
  588. int ib_resize_cq(struct ib_cq *cq, int cqe)
  589. {
  590. return cq->device->resize_cq ?
  591. cq->device->resize_cq(cq, cqe, NULL) : -ENOSYS;
  592. }
  593. EXPORT_SYMBOL(ib_resize_cq);
  594. /* Memory regions */
  595. struct ib_mr *ib_get_dma_mr(struct ib_pd *pd, int mr_access_flags)
  596. {
  597. struct ib_mr *mr;
  598. mr = pd->device->get_dma_mr(pd, mr_access_flags);
  599. if (!IS_ERR(mr)) {
  600. mr->device = pd->device;
  601. mr->pd = pd;
  602. mr->uobject = NULL;
  603. atomic_inc(&pd->usecnt);
  604. atomic_set(&mr->usecnt, 0);
  605. }
  606. return mr;
  607. }
  608. EXPORT_SYMBOL(ib_get_dma_mr);
  609. struct ib_mr *ib_reg_phys_mr(struct ib_pd *pd,
  610. struct ib_phys_buf *phys_buf_array,
  611. int num_phys_buf,
  612. int mr_access_flags,
  613. u64 *iova_start)
  614. {
  615. struct ib_mr *mr;
  616. if (!pd->device->reg_phys_mr)
  617. return ERR_PTR(-ENOSYS);
  618. mr = pd->device->reg_phys_mr(pd, phys_buf_array, num_phys_buf,
  619. mr_access_flags, iova_start);
  620. if (!IS_ERR(mr)) {
  621. mr->device = pd->device;
  622. mr->pd = pd;
  623. mr->uobject = NULL;
  624. atomic_inc(&pd->usecnt);
  625. atomic_set(&mr->usecnt, 0);
  626. }
  627. return mr;
  628. }
  629. EXPORT_SYMBOL(ib_reg_phys_mr);
  630. int ib_rereg_phys_mr(struct ib_mr *mr,
  631. int mr_rereg_mask,
  632. struct ib_pd *pd,
  633. struct ib_phys_buf *phys_buf_array,
  634. int num_phys_buf,
  635. int mr_access_flags,
  636. u64 *iova_start)
  637. {
  638. struct ib_pd *old_pd;
  639. int ret;
  640. if (!mr->device->rereg_phys_mr)
  641. return -ENOSYS;
  642. if (atomic_read(&mr->usecnt))
  643. return -EBUSY;
  644. old_pd = mr->pd;
  645. ret = mr->device->rereg_phys_mr(mr, mr_rereg_mask, pd,
  646. phys_buf_array, num_phys_buf,
  647. mr_access_flags, iova_start);
  648. if (!ret && (mr_rereg_mask & IB_MR_REREG_PD)) {
  649. atomic_dec(&old_pd->usecnt);
  650. atomic_inc(&pd->usecnt);
  651. }
  652. return ret;
  653. }
  654. EXPORT_SYMBOL(ib_rereg_phys_mr);
  655. int ib_query_mr(struct ib_mr *mr, struct ib_mr_attr *mr_attr)
  656. {
  657. return mr->device->query_mr ?
  658. mr->device->query_mr(mr, mr_attr) : -ENOSYS;
  659. }
  660. EXPORT_SYMBOL(ib_query_mr);
  661. int ib_dereg_mr(struct ib_mr *mr)
  662. {
  663. struct ib_pd *pd;
  664. int ret;
  665. if (atomic_read(&mr->usecnt))
  666. return -EBUSY;
  667. pd = mr->pd;
  668. ret = mr->device->dereg_mr(mr);
  669. if (!ret)
  670. atomic_dec(&pd->usecnt);
  671. return ret;
  672. }
  673. EXPORT_SYMBOL(ib_dereg_mr);
  674. struct ib_mr *ib_alloc_fast_reg_mr(struct ib_pd *pd, int max_page_list_len)
  675. {
  676. struct ib_mr *mr;
  677. if (!pd->device->alloc_fast_reg_mr)
  678. return ERR_PTR(-ENOSYS);
  679. mr = pd->device->alloc_fast_reg_mr(pd, max_page_list_len);
  680. if (!IS_ERR(mr)) {
  681. mr->device = pd->device;
  682. mr->pd = pd;
  683. mr->uobject = NULL;
  684. atomic_inc(&pd->usecnt);
  685. atomic_set(&mr->usecnt, 0);
  686. }
  687. return mr;
  688. }
  689. EXPORT_SYMBOL(ib_alloc_fast_reg_mr);
  690. struct ib_fast_reg_page_list *ib_alloc_fast_reg_page_list(struct ib_device *device,
  691. int max_page_list_len)
  692. {
  693. struct ib_fast_reg_page_list *page_list;
  694. if (!device->alloc_fast_reg_page_list)
  695. return ERR_PTR(-ENOSYS);
  696. page_list = device->alloc_fast_reg_page_list(device, max_page_list_len);
  697. if (!IS_ERR(page_list)) {
  698. page_list->device = device;
  699. page_list->max_page_list_len = max_page_list_len;
  700. }
  701. return page_list;
  702. }
  703. EXPORT_SYMBOL(ib_alloc_fast_reg_page_list);
  704. void ib_free_fast_reg_page_list(struct ib_fast_reg_page_list *page_list)
  705. {
  706. page_list->device->free_fast_reg_page_list(page_list);
  707. }
  708. EXPORT_SYMBOL(ib_free_fast_reg_page_list);
  709. /* Memory windows */
  710. struct ib_mw *ib_alloc_mw(struct ib_pd *pd)
  711. {
  712. struct ib_mw *mw;
  713. if (!pd->device->alloc_mw)
  714. return ERR_PTR(-ENOSYS);
  715. mw = pd->device->alloc_mw(pd);
  716. if (!IS_ERR(mw)) {
  717. mw->device = pd->device;
  718. mw->pd = pd;
  719. mw->uobject = NULL;
  720. atomic_inc(&pd->usecnt);
  721. }
  722. return mw;
  723. }
  724. EXPORT_SYMBOL(ib_alloc_mw);
  725. int ib_dealloc_mw(struct ib_mw *mw)
  726. {
  727. struct ib_pd *pd;
  728. int ret;
  729. pd = mw->pd;
  730. ret = mw->device->dealloc_mw(mw);
  731. if (!ret)
  732. atomic_dec(&pd->usecnt);
  733. return ret;
  734. }
  735. EXPORT_SYMBOL(ib_dealloc_mw);
  736. /* "Fast" memory regions */
  737. struct ib_fmr *ib_alloc_fmr(struct ib_pd *pd,
  738. int mr_access_flags,
  739. struct ib_fmr_attr *fmr_attr)
  740. {
  741. struct ib_fmr *fmr;
  742. if (!pd->device->alloc_fmr)
  743. return ERR_PTR(-ENOSYS);
  744. fmr = pd->device->alloc_fmr(pd, mr_access_flags, fmr_attr);
  745. if (!IS_ERR(fmr)) {
  746. fmr->device = pd->device;
  747. fmr->pd = pd;
  748. atomic_inc(&pd->usecnt);
  749. }
  750. return fmr;
  751. }
  752. EXPORT_SYMBOL(ib_alloc_fmr);
  753. int ib_unmap_fmr(struct list_head *fmr_list)
  754. {
  755. struct ib_fmr *fmr;
  756. if (list_empty(fmr_list))
  757. return 0;
  758. fmr = list_entry(fmr_list->next, struct ib_fmr, list);
  759. return fmr->device->unmap_fmr(fmr_list);
  760. }
  761. EXPORT_SYMBOL(ib_unmap_fmr);
  762. int ib_dealloc_fmr(struct ib_fmr *fmr)
  763. {
  764. struct ib_pd *pd;
  765. int ret;
  766. pd = fmr->pd;
  767. ret = fmr->device->dealloc_fmr(fmr);
  768. if (!ret)
  769. atomic_dec(&pd->usecnt);
  770. return ret;
  771. }
  772. EXPORT_SYMBOL(ib_dealloc_fmr);
  773. /* Multicast groups */
  774. int ib_attach_mcast(struct ib_qp *qp, union ib_gid *gid, u16 lid)
  775. {
  776. if (!qp->device->attach_mcast)
  777. return -ENOSYS;
  778. if (gid->raw[0] != 0xff || qp->qp_type != IB_QPT_UD)
  779. return -EINVAL;
  780. return qp->device->attach_mcast(qp, gid, lid);
  781. }
  782. EXPORT_SYMBOL(ib_attach_mcast);
  783. int ib_detach_mcast(struct ib_qp *qp, union ib_gid *gid, u16 lid)
  784. {
  785. if (!qp->device->detach_mcast)
  786. return -ENOSYS;
  787. if (gid->raw[0] != 0xff || qp->qp_type != IB_QPT_UD)
  788. return -EINVAL;
  789. return qp->device->detach_mcast(qp, gid, lid);
  790. }
  791. EXPORT_SYMBOL(ib_detach_mcast);