cxgb3i_ddp.c 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734
  1. /*
  2. * cxgb3i_ddp.c: Chelsio S3xx iSCSI DDP Manager.
  3. *
  4. * Copyright (c) 2008 Chelsio Communications, Inc.
  5. *
  6. * This program is free software; you can redistribute it and/or modify
  7. * it under the terms of the GNU General Public License as published by
  8. * the Free Software Foundation.
  9. *
  10. * Written by: Karen Xie (kxie@chelsio.com)
  11. */
  12. #include <linux/skbuff.h>
  13. #include <linux/scatterlist.h>
  14. /* from cxgb3 LLD */
  15. #include "common.h"
  16. #include "t3_cpl.h"
  17. #include "t3cdev.h"
  18. #include "cxgb3_ctl_defs.h"
  19. #include "cxgb3_offload.h"
  20. #include "firmware_exports.h"
  21. #include "cxgb3i_ddp.h"
  22. #define ddp_log_error(fmt...) printk(KERN_ERR "cxgb3i_ddp: ERR! " fmt)
  23. #define ddp_log_warn(fmt...) printk(KERN_WARNING "cxgb3i_ddp: WARN! " fmt)
  24. #define ddp_log_info(fmt...) printk(KERN_INFO "cxgb3i_ddp: " fmt)
  25. #ifdef __DEBUG_CXGB3I_DDP__
  26. #define ddp_log_debug(fmt, args...) \
  27. printk(KERN_INFO "cxgb3i_ddp: %s - " fmt, __func__ , ## args)
  28. #else
  29. #define ddp_log_debug(fmt...)
  30. #endif
  31. /*
  32. * iSCSI Direct Data Placement
  33. *
  34. * T3 h/w can directly place the iSCSI Data-In or Data-Out PDU's payload into
  35. * pre-posted final destination host-memory buffers based on the Initiator
  36. * Task Tag (ITT) in Data-In or Target Task Tag (TTT) in Data-Out PDUs.
  37. *
  38. * The host memory address is programmed into h/w in the format of pagepod
  39. * entries.
  40. * The location of the pagepod entry is encoded into ddp tag which is used or
  41. * is the base for ITT/TTT.
  42. */
  43. #define DDP_PGIDX_MAX 4
  44. #define DDP_THRESHOLD 2048
  45. static unsigned char ddp_page_order[DDP_PGIDX_MAX] = {0, 1, 2, 4};
  46. static unsigned char ddp_page_shift[DDP_PGIDX_MAX] = {12, 13, 14, 16};
  47. static unsigned char page_idx = DDP_PGIDX_MAX;
  48. /*
  49. * functions to program the pagepod in h/w
  50. */
  51. static inline void ulp_mem_io_set_hdr(struct sk_buff *skb, unsigned int addr)
  52. {
  53. struct ulp_mem_io *req = (struct ulp_mem_io *)skb->head;
  54. req->wr.wr_lo = 0;
  55. req->wr.wr_hi = htonl(V_WR_OP(FW_WROPCODE_BYPASS));
  56. req->cmd_lock_addr = htonl(V_ULP_MEMIO_ADDR(addr >> 5) |
  57. V_ULPTX_CMD(ULP_MEM_WRITE));
  58. req->len = htonl(V_ULP_MEMIO_DATA_LEN(PPOD_SIZE >> 5) |
  59. V_ULPTX_NFLITS((PPOD_SIZE >> 3) + 1));
  60. }
  61. static int set_ddp_map(struct cxgb3i_ddp_info *ddp, struct pagepod_hdr *hdr,
  62. unsigned int idx, unsigned int npods,
  63. struct cxgb3i_gather_list *gl)
  64. {
  65. unsigned int pm_addr = (idx << PPOD_SIZE_SHIFT) + ddp->llimit;
  66. int i;
  67. for (i = 0; i < npods; i++, idx++, pm_addr += PPOD_SIZE) {
  68. struct sk_buff *skb = ddp->gl_skb[idx];
  69. struct pagepod *ppod;
  70. int j, pidx;
  71. /* hold on to the skb until we clear the ddp mapping */
  72. skb_get(skb);
  73. ulp_mem_io_set_hdr(skb, pm_addr);
  74. ppod = (struct pagepod *)
  75. (skb->head + sizeof(struct ulp_mem_io));
  76. memcpy(&(ppod->hdr), hdr, sizeof(struct pagepod));
  77. for (pidx = 4 * i, j = 0; j < 5; ++j, ++pidx)
  78. ppod->addr[j] = pidx < gl->nelem ?
  79. cpu_to_be64(gl->phys_addr[pidx]) : 0UL;
  80. skb->priority = CPL_PRIORITY_CONTROL;
  81. cxgb3_ofld_send(ddp->tdev, skb);
  82. }
  83. return 0;
  84. }
  85. static void clear_ddp_map(struct cxgb3i_ddp_info *ddp, unsigned int tag,
  86. unsigned int idx, unsigned int npods)
  87. {
  88. unsigned int pm_addr = (idx << PPOD_SIZE_SHIFT) + ddp->llimit;
  89. int i;
  90. for (i = 0; i < npods; i++, idx++, pm_addr += PPOD_SIZE) {
  91. struct sk_buff *skb = ddp->gl_skb[idx];
  92. if (!skb) {
  93. ddp_log_error("ddp tag 0x%x, 0x%x, %d/%u, skb NULL.\n",
  94. tag, idx, i, npods);
  95. continue;
  96. }
  97. ddp->gl_skb[idx] = NULL;
  98. memset((skb->head + sizeof(struct ulp_mem_io)), 0, PPOD_SIZE);
  99. ulp_mem_io_set_hdr(skb, pm_addr);
  100. skb->priority = CPL_PRIORITY_CONTROL;
  101. cxgb3_ofld_send(ddp->tdev, skb);
  102. }
  103. }
  104. static inline int ddp_find_unused_entries(struct cxgb3i_ddp_info *ddp,
  105. unsigned int start, unsigned int max,
  106. unsigned int count,
  107. struct cxgb3i_gather_list *gl)
  108. {
  109. unsigned int i, j, k;
  110. /* not enough entries */
  111. if ((max - start) < count)
  112. return -EBUSY;
  113. max -= count;
  114. spin_lock(&ddp->map_lock);
  115. for (i = start; i < max;) {
  116. for (j = 0, k = i; j < count; j++, k++) {
  117. if (ddp->gl_map[k])
  118. break;
  119. }
  120. if (j == count) {
  121. for (j = 0, k = i; j < count; j++, k++)
  122. ddp->gl_map[k] = gl;
  123. spin_unlock(&ddp->map_lock);
  124. return i;
  125. }
  126. i += j + 1;
  127. }
  128. spin_unlock(&ddp->map_lock);
  129. return -EBUSY;
  130. }
  131. static inline void ddp_unmark_entries(struct cxgb3i_ddp_info *ddp,
  132. int start, int count)
  133. {
  134. spin_lock(&ddp->map_lock);
  135. memset(&ddp->gl_map[start], 0,
  136. count * sizeof(struct cxgb3i_gather_list *));
  137. spin_unlock(&ddp->map_lock);
  138. }
  139. static inline void ddp_free_gl_skb(struct cxgb3i_ddp_info *ddp,
  140. int idx, int count)
  141. {
  142. int i;
  143. for (i = 0; i < count; i++, idx++)
  144. if (ddp->gl_skb[idx]) {
  145. kfree_skb(ddp->gl_skb[idx]);
  146. ddp->gl_skb[idx] = NULL;
  147. }
  148. }
  149. static inline int ddp_alloc_gl_skb(struct cxgb3i_ddp_info *ddp, int idx,
  150. int count, gfp_t gfp)
  151. {
  152. int i;
  153. for (i = 0; i < count; i++) {
  154. struct sk_buff *skb = alloc_skb(sizeof(struct ulp_mem_io) +
  155. PPOD_SIZE, gfp);
  156. if (skb) {
  157. ddp->gl_skb[idx + i] = skb;
  158. skb_put(skb, sizeof(struct ulp_mem_io) + PPOD_SIZE);
  159. } else {
  160. ddp_free_gl_skb(ddp, idx, i);
  161. return -ENOMEM;
  162. }
  163. }
  164. return 0;
  165. }
  166. /**
  167. * cxgb3i_ddp_find_page_index - return ddp page index for a given page size
  168. * @pgsz: page size
  169. * return the ddp page index, if no match is found return DDP_PGIDX_MAX.
  170. */
  171. int cxgb3i_ddp_find_page_index(unsigned long pgsz)
  172. {
  173. int i;
  174. for (i = 0; i < DDP_PGIDX_MAX; i++) {
  175. if (pgsz == (1UL << ddp_page_shift[i]))
  176. return i;
  177. }
  178. ddp_log_debug("ddp page size 0x%lx not supported.\n", pgsz);
  179. return DDP_PGIDX_MAX;
  180. }
  181. static inline void ddp_gl_unmap(struct pci_dev *pdev,
  182. struct cxgb3i_gather_list *gl)
  183. {
  184. int i;
  185. for (i = 0; i < gl->nelem; i++)
  186. pci_unmap_page(pdev, gl->phys_addr[i], PAGE_SIZE,
  187. PCI_DMA_FROMDEVICE);
  188. }
  189. static inline int ddp_gl_map(struct pci_dev *pdev,
  190. struct cxgb3i_gather_list *gl)
  191. {
  192. int i;
  193. for (i = 0; i < gl->nelem; i++) {
  194. gl->phys_addr[i] = pci_map_page(pdev, gl->pages[i], 0,
  195. PAGE_SIZE,
  196. PCI_DMA_FROMDEVICE);
  197. if (unlikely(pci_dma_mapping_error(pdev, gl->phys_addr[i])))
  198. goto unmap;
  199. }
  200. return i;
  201. unmap:
  202. if (i) {
  203. unsigned int nelem = gl->nelem;
  204. gl->nelem = i;
  205. ddp_gl_unmap(pdev, gl);
  206. gl->nelem = nelem;
  207. }
  208. return -ENOMEM;
  209. }
  210. /**
  211. * cxgb3i_ddp_make_gl - build ddp page buffer list
  212. * @xferlen: total buffer length
  213. * @sgl: page buffer scatter-gather list
  214. * @sgcnt: # of page buffers
  215. * @pdev: pci_dev, used for pci map
  216. * @gfp: allocation mode
  217. *
  218. * construct a ddp page buffer list from the scsi scattergather list.
  219. * coalesce buffers as much as possible, and obtain dma addresses for
  220. * each page.
  221. *
  222. * Return the cxgb3i_gather_list constructed from the page buffers if the
  223. * memory can be used for ddp. Return NULL otherwise.
  224. */
  225. struct cxgb3i_gather_list *cxgb3i_ddp_make_gl(unsigned int xferlen,
  226. struct scatterlist *sgl,
  227. unsigned int sgcnt,
  228. struct pci_dev *pdev,
  229. gfp_t gfp)
  230. {
  231. struct cxgb3i_gather_list *gl;
  232. struct scatterlist *sg = sgl;
  233. struct page *sgpage = sg_page(sg);
  234. unsigned int sglen = sg->length;
  235. unsigned int sgoffset = sg->offset;
  236. unsigned int npages = (xferlen + sgoffset + PAGE_SIZE - 1) >>
  237. PAGE_SHIFT;
  238. int i = 1, j = 0;
  239. if (xferlen < DDP_THRESHOLD) {
  240. ddp_log_debug("xfer %u < threshold %u, no ddp.\n",
  241. xferlen, DDP_THRESHOLD);
  242. return NULL;
  243. }
  244. gl = kzalloc(sizeof(struct cxgb3i_gather_list) +
  245. npages * (sizeof(dma_addr_t) + sizeof(struct page *)),
  246. gfp);
  247. if (!gl)
  248. return NULL;
  249. gl->pages = (struct page **)&gl->phys_addr[npages];
  250. gl->length = xferlen;
  251. gl->offset = sgoffset;
  252. gl->pages[0] = sgpage;
  253. sg = sg_next(sg);
  254. while (sg) {
  255. struct page *page = sg_page(sg);
  256. if (sgpage == page && sg->offset == sgoffset + sglen)
  257. sglen += sg->length;
  258. else {
  259. /* make sure the sgl is fit for ddp:
  260. * each has the same page size, and
  261. * all of the middle pages are used completely
  262. */
  263. if ((j && sgoffset) ||
  264. ((i != sgcnt - 1) &&
  265. ((sglen + sgoffset) & ~PAGE_MASK)))
  266. goto error_out;
  267. j++;
  268. if (j == gl->nelem || sg->offset)
  269. goto error_out;
  270. gl->pages[j] = page;
  271. sglen = sg->length;
  272. sgoffset = sg->offset;
  273. sgpage = page;
  274. }
  275. i++;
  276. sg = sg_next(sg);
  277. }
  278. gl->nelem = ++j;
  279. if (ddp_gl_map(pdev, gl) < 0)
  280. goto error_out;
  281. return gl;
  282. error_out:
  283. kfree(gl);
  284. return NULL;
  285. }
  286. /**
  287. * cxgb3i_ddp_release_gl - release a page buffer list
  288. * @gl: a ddp page buffer list
  289. * @pdev: pci_dev used for pci_unmap
  290. * free a ddp page buffer list resulted from cxgb3i_ddp_make_gl().
  291. */
  292. void cxgb3i_ddp_release_gl(struct cxgb3i_gather_list *gl,
  293. struct pci_dev *pdev)
  294. {
  295. ddp_gl_unmap(pdev, gl);
  296. kfree(gl);
  297. }
  298. /**
  299. * cxgb3i_ddp_tag_reserve - set up ddp for a data transfer
  300. * @tdev: t3cdev adapter
  301. * @tid: connection id
  302. * @tformat: tag format
  303. * @tagp: contains s/w tag initially, will be updated with ddp/hw tag
  304. * @gl: the page momory list
  305. * @gfp: allocation mode
  306. *
  307. * ddp setup for a given page buffer list and construct the ddp tag.
  308. * return 0 if success, < 0 otherwise.
  309. */
  310. int cxgb3i_ddp_tag_reserve(struct t3cdev *tdev, unsigned int tid,
  311. struct cxgb3i_tag_format *tformat, u32 *tagp,
  312. struct cxgb3i_gather_list *gl, gfp_t gfp)
  313. {
  314. struct cxgb3i_ddp_info *ddp = tdev->ulp_iscsi;
  315. struct pagepod_hdr hdr;
  316. unsigned int npods;
  317. int idx = -1;
  318. int err = -ENOMEM;
  319. u32 sw_tag = *tagp;
  320. u32 tag;
  321. if (page_idx >= DDP_PGIDX_MAX || !ddp || !gl || !gl->nelem ||
  322. gl->length < DDP_THRESHOLD) {
  323. ddp_log_debug("pgidx %u, xfer %u/%u, NO ddp.\n",
  324. page_idx, gl->length, DDP_THRESHOLD);
  325. return -EINVAL;
  326. }
  327. npods = (gl->nelem + PPOD_PAGES_MAX - 1) >> PPOD_PAGES_SHIFT;
  328. if (ddp->idx_last == ddp->nppods)
  329. idx = ddp_find_unused_entries(ddp, 0, ddp->nppods, npods, gl);
  330. else {
  331. idx = ddp_find_unused_entries(ddp, ddp->idx_last + 1,
  332. ddp->nppods, npods, gl);
  333. if (idx < 0 && ddp->idx_last >= npods) {
  334. idx = ddp_find_unused_entries(ddp, 0,
  335. min(ddp->idx_last + npods, ddp->nppods),
  336. npods, gl);
  337. }
  338. }
  339. if (idx < 0) {
  340. ddp_log_debug("xferlen %u, gl %u, npods %u NO DDP.\n",
  341. gl->length, gl->nelem, npods);
  342. return idx;
  343. }
  344. err = ddp_alloc_gl_skb(ddp, idx, npods, gfp);
  345. if (err < 0)
  346. goto unmark_entries;
  347. tag = cxgb3i_ddp_tag_base(tformat, sw_tag);
  348. tag |= idx << PPOD_IDX_SHIFT;
  349. hdr.rsvd = 0;
  350. hdr.vld_tid = htonl(F_PPOD_VALID | V_PPOD_TID(tid));
  351. hdr.pgsz_tag_clr = htonl(tag & ddp->rsvd_tag_mask);
  352. hdr.maxoffset = htonl(gl->length);
  353. hdr.pgoffset = htonl(gl->offset);
  354. err = set_ddp_map(ddp, &hdr, idx, npods, gl);
  355. if (err < 0)
  356. goto free_gl_skb;
  357. ddp->idx_last = idx;
  358. ddp_log_debug("xfer %u, gl %u,%u, tid 0x%x, 0x%x -> 0x%x(%u,%u).\n",
  359. gl->length, gl->nelem, gl->offset, tid, sw_tag, tag,
  360. idx, npods);
  361. *tagp = tag;
  362. return 0;
  363. free_gl_skb:
  364. ddp_free_gl_skb(ddp, idx, npods);
  365. unmark_entries:
  366. ddp_unmark_entries(ddp, idx, npods);
  367. return err;
  368. }
  369. /**
  370. * cxgb3i_ddp_tag_release - release a ddp tag
  371. * @tdev: t3cdev adapter
  372. * @tag: ddp tag
  373. * ddp cleanup for a given ddp tag and release all the resources held
  374. */
  375. void cxgb3i_ddp_tag_release(struct t3cdev *tdev, u32 tag)
  376. {
  377. struct cxgb3i_ddp_info *ddp = tdev->ulp_iscsi;
  378. u32 idx;
  379. if (!ddp) {
  380. ddp_log_error("release ddp tag 0x%x, ddp NULL.\n", tag);
  381. return;
  382. }
  383. idx = (tag >> PPOD_IDX_SHIFT) & ddp->idx_mask;
  384. if (idx < ddp->nppods) {
  385. struct cxgb3i_gather_list *gl = ddp->gl_map[idx];
  386. unsigned int npods;
  387. if (!gl || !gl->nelem) {
  388. ddp_log_error("release 0x%x, idx 0x%x, gl 0x%p, %u.\n",
  389. tag, idx, gl, gl ? gl->nelem : 0);
  390. return;
  391. }
  392. npods = (gl->nelem + PPOD_PAGES_MAX - 1) >> PPOD_PAGES_SHIFT;
  393. ddp_log_debug("ddp tag 0x%x, release idx 0x%x, npods %u.\n",
  394. tag, idx, npods);
  395. clear_ddp_map(ddp, tag, idx, npods);
  396. ddp_unmark_entries(ddp, idx, npods);
  397. cxgb3i_ddp_release_gl(gl, ddp->pdev);
  398. } else
  399. ddp_log_error("ddp tag 0x%x, idx 0x%x > max 0x%x.\n",
  400. tag, idx, ddp->nppods);
  401. }
  402. static int setup_conn_pgidx(struct t3cdev *tdev, unsigned int tid, int pg_idx,
  403. int reply)
  404. {
  405. struct sk_buff *skb = alloc_skb(sizeof(struct cpl_set_tcb_field),
  406. GFP_KERNEL);
  407. struct cpl_set_tcb_field *req;
  408. u64 val = pg_idx < DDP_PGIDX_MAX ? pg_idx : 0;
  409. if (!skb)
  410. return -ENOMEM;
  411. /* set up ulp submode and page size */
  412. req = (struct cpl_set_tcb_field *)skb_put(skb, sizeof(*req));
  413. req->wr.wr_hi = htonl(V_WR_OP(FW_WROPCODE_FORWARD));
  414. OPCODE_TID(req) = htonl(MK_OPCODE_TID(CPL_SET_TCB_FIELD, tid));
  415. req->reply = V_NO_REPLY(reply ? 0 : 1);
  416. req->cpu_idx = 0;
  417. req->word = htons(31);
  418. req->mask = cpu_to_be64(0xF0000000);
  419. req->val = cpu_to_be64(val << 28);
  420. skb->priority = CPL_PRIORITY_CONTROL;
  421. cxgb3_ofld_send(tdev, skb);
  422. return 0;
  423. }
  424. /**
  425. * cxgb3i_setup_conn_host_pagesize - setup the conn.'s ddp page size
  426. * @tdev: t3cdev adapter
  427. * @tid: connection id
  428. * @reply: request reply from h/w
  429. * set up the ddp page size based on the host PAGE_SIZE for a connection
  430. * identified by tid
  431. */
  432. int cxgb3i_setup_conn_host_pagesize(struct t3cdev *tdev, unsigned int tid,
  433. int reply)
  434. {
  435. return setup_conn_pgidx(tdev, tid, page_idx, reply);
  436. }
  437. /**
  438. * cxgb3i_setup_conn_pagesize - setup the conn.'s ddp page size
  439. * @tdev: t3cdev adapter
  440. * @tid: connection id
  441. * @reply: request reply from h/w
  442. * @pgsz: ddp page size
  443. * set up the ddp page size for a connection identified by tid
  444. */
  445. int cxgb3i_setup_conn_pagesize(struct t3cdev *tdev, unsigned int tid,
  446. int reply, unsigned long pgsz)
  447. {
  448. int pgidx = cxgb3i_ddp_find_page_index(pgsz);
  449. return setup_conn_pgidx(tdev, tid, pgidx, reply);
  450. }
  451. /**
  452. * cxgb3i_setup_conn_digest - setup conn. digest setting
  453. * @tdev: t3cdev adapter
  454. * @tid: connection id
  455. * @hcrc: header digest enabled
  456. * @dcrc: data digest enabled
  457. * @reply: request reply from h/w
  458. * set up the iscsi digest settings for a connection identified by tid
  459. */
  460. int cxgb3i_setup_conn_digest(struct t3cdev *tdev, unsigned int tid,
  461. int hcrc, int dcrc, int reply)
  462. {
  463. struct sk_buff *skb = alloc_skb(sizeof(struct cpl_set_tcb_field),
  464. GFP_KERNEL);
  465. struct cpl_set_tcb_field *req;
  466. u64 val = (hcrc ? 1 : 0) | (dcrc ? 2 : 0);
  467. if (!skb)
  468. return -ENOMEM;
  469. /* set up ulp submode and page size */
  470. req = (struct cpl_set_tcb_field *)skb_put(skb, sizeof(*req));
  471. req->wr.wr_hi = htonl(V_WR_OP(FW_WROPCODE_FORWARD));
  472. OPCODE_TID(req) = htonl(MK_OPCODE_TID(CPL_SET_TCB_FIELD, tid));
  473. req->reply = V_NO_REPLY(reply ? 0 : 1);
  474. req->cpu_idx = 0;
  475. req->word = htons(31);
  476. req->mask = cpu_to_be64(0x0F000000);
  477. req->val = cpu_to_be64(val << 24);
  478. skb->priority = CPL_PRIORITY_CONTROL;
  479. cxgb3_ofld_send(tdev, skb);
  480. return 0;
  481. }
  482. /**
  483. * cxgb3i_adapter_ddp_info - read the adapter's ddp information
  484. * @tdev: t3cdev adapter
  485. * @tformat: tag format
  486. * @txsz: max tx pdu payload size, filled in by this func.
  487. * @rxsz: max rx pdu payload size, filled in by this func.
  488. * setup the tag format for a given iscsi entity
  489. */
  490. int cxgb3i_adapter_ddp_info(struct t3cdev *tdev,
  491. struct cxgb3i_tag_format *tformat,
  492. unsigned int *txsz, unsigned int *rxsz)
  493. {
  494. struct cxgb3i_ddp_info *ddp;
  495. unsigned char idx_bits;
  496. if (!tformat)
  497. return -EINVAL;
  498. if (!tdev->ulp_iscsi)
  499. return -EINVAL;
  500. ddp = (struct cxgb3i_ddp_info *)tdev->ulp_iscsi;
  501. idx_bits = 32 - tformat->sw_bits;
  502. tformat->rsvd_bits = ddp->idx_bits;
  503. tformat->rsvd_shift = PPOD_IDX_SHIFT;
  504. tformat->rsvd_mask = (1 << tformat->rsvd_bits) - 1;
  505. ddp_log_info("tag format: sw %u, rsvd %u,%u, mask 0x%x.\n",
  506. tformat->sw_bits, tformat->rsvd_bits,
  507. tformat->rsvd_shift, tformat->rsvd_mask);
  508. *txsz = min_t(unsigned int, ULP2_MAX_PDU_PAYLOAD,
  509. ddp->max_txsz - ISCSI_PDU_NONPAYLOAD_LEN);
  510. *rxsz = min_t(unsigned int, ULP2_MAX_PDU_PAYLOAD,
  511. ddp->max_rxsz - ISCSI_PDU_NONPAYLOAD_LEN);
  512. ddp_log_info("max payload size: %u/%u, %u/%u.\n",
  513. *txsz, ddp->max_txsz, *rxsz, ddp->max_rxsz);
  514. return 0;
  515. }
  516. /**
  517. * cxgb3i_ddp_cleanup - release the cxgb3 adapter's ddp resource
  518. * @tdev: t3cdev adapter
  519. * release all the resource held by the ddp pagepod manager for a given
  520. * adapter if needed
  521. */
  522. static void ddp_cleanup(struct kref *kref)
  523. {
  524. struct cxgb3i_ddp_info *ddp = container_of(kref,
  525. struct cxgb3i_ddp_info,
  526. refcnt);
  527. int i = 0;
  528. ddp_log_info("kref release ddp 0x%p, t3dev 0x%p.\n", ddp, ddp->tdev);
  529. ddp->tdev->ulp_iscsi = NULL;
  530. while (i < ddp->nppods) {
  531. struct cxgb3i_gather_list *gl = ddp->gl_map[i];
  532. if (gl) {
  533. int npods = (gl->nelem + PPOD_PAGES_MAX - 1)
  534. >> PPOD_PAGES_SHIFT;
  535. ddp_log_info("t3dev 0x%p, ddp %d + %d.\n",
  536. ddp->tdev, i, npods);
  537. kfree(gl);
  538. ddp_free_gl_skb(ddp, i, npods);
  539. i += npods;
  540. } else
  541. i++;
  542. }
  543. cxgb3i_free_big_mem(ddp);
  544. }
  545. void cxgb3i_ddp_cleanup(struct t3cdev *tdev)
  546. {
  547. struct cxgb3i_ddp_info *ddp = (struct cxgb3i_ddp_info *)tdev->ulp_iscsi;
  548. ddp_log_info("t3dev 0x%p, release ddp 0x%p.\n", tdev, ddp);
  549. if (ddp)
  550. kref_put(&ddp->refcnt, ddp_cleanup);
  551. }
  552. /**
  553. * ddp_init - initialize the cxgb3 adapter's ddp resource
  554. * @tdev: t3cdev adapter
  555. * initialize the ddp pagepod manager for a given adapter
  556. */
  557. static void ddp_init(struct t3cdev *tdev)
  558. {
  559. struct cxgb3i_ddp_info *ddp = tdev->ulp_iscsi;
  560. struct ulp_iscsi_info uinfo;
  561. unsigned int ppmax, bits;
  562. int i, err;
  563. if (ddp) {
  564. kref_get(&ddp->refcnt);
  565. ddp_log_warn("t3dev 0x%p, ddp 0x%p already set up.\n",
  566. tdev, tdev->ulp_iscsi);
  567. return;
  568. }
  569. err = tdev->ctl(tdev, ULP_ISCSI_GET_PARAMS, &uinfo);
  570. if (err < 0) {
  571. ddp_log_error("%s, failed to get iscsi param err=%d.\n",
  572. tdev->name, err);
  573. return;
  574. }
  575. ppmax = (uinfo.ulimit - uinfo.llimit + 1) >> PPOD_SIZE_SHIFT;
  576. bits = __ilog2_u32(ppmax) + 1;
  577. if (bits > PPOD_IDX_MAX_SIZE)
  578. bits = PPOD_IDX_MAX_SIZE;
  579. ppmax = (1 << (bits - 1)) - 1;
  580. ddp = cxgb3i_alloc_big_mem(sizeof(struct cxgb3i_ddp_info) +
  581. ppmax *
  582. (sizeof(struct cxgb3i_gather_list *) +
  583. sizeof(struct sk_buff *)),
  584. GFP_KERNEL);
  585. if (!ddp) {
  586. ddp_log_warn("%s unable to alloc ddp 0x%d, ddp disabled.\n",
  587. tdev->name, ppmax);
  588. return;
  589. }
  590. ddp->gl_map = (struct cxgb3i_gather_list **)(ddp + 1);
  591. ddp->gl_skb = (struct sk_buff **)(((char *)ddp->gl_map) +
  592. ppmax *
  593. sizeof(struct cxgb3i_gather_list *));
  594. spin_lock_init(&ddp->map_lock);
  595. kref_init(&ddp->refcnt);
  596. ddp->tdev = tdev;
  597. ddp->pdev = uinfo.pdev;
  598. ddp->max_txsz = min_t(unsigned int, uinfo.max_txsz, ULP2_MAX_PKT_SIZE);
  599. ddp->max_rxsz = min_t(unsigned int, uinfo.max_rxsz, ULP2_MAX_PKT_SIZE);
  600. ddp->llimit = uinfo.llimit;
  601. ddp->ulimit = uinfo.ulimit;
  602. ddp->nppods = ppmax;
  603. ddp->idx_last = ppmax;
  604. ddp->idx_bits = bits;
  605. ddp->idx_mask = (1 << bits) - 1;
  606. ddp->rsvd_tag_mask = (1 << (bits + PPOD_IDX_SHIFT)) - 1;
  607. uinfo.tagmask = ddp->idx_mask << PPOD_IDX_SHIFT;
  608. for (i = 0; i < DDP_PGIDX_MAX; i++)
  609. uinfo.pgsz_factor[i] = ddp_page_order[i];
  610. uinfo.ulimit = uinfo.llimit + (ppmax << PPOD_SIZE_SHIFT);
  611. err = tdev->ctl(tdev, ULP_ISCSI_SET_PARAMS, &uinfo);
  612. if (err < 0) {
  613. ddp_log_warn("%s unable to set iscsi param err=%d, "
  614. "ddp disabled.\n", tdev->name, err);
  615. goto free_ddp_map;
  616. }
  617. tdev->ulp_iscsi = ddp;
  618. ddp_log_info("tdev 0x%p, nppods %u, bits %u, mask 0x%x,0x%x pkt %u/%u,"
  619. " %u/%u.\n",
  620. tdev, ppmax, ddp->idx_bits, ddp->idx_mask,
  621. ddp->rsvd_tag_mask, ddp->max_txsz, uinfo.max_txsz,
  622. ddp->max_rxsz, uinfo.max_rxsz);
  623. return;
  624. free_ddp_map:
  625. cxgb3i_free_big_mem(ddp);
  626. }
  627. /**
  628. * cxgb3i_ddp_init - initialize ddp functions
  629. */
  630. void cxgb3i_ddp_init(struct t3cdev *tdev)
  631. {
  632. if (page_idx == DDP_PGIDX_MAX) {
  633. page_idx = cxgb3i_ddp_find_page_index(PAGE_SIZE);
  634. ddp_log_info("system PAGE_SIZE %lu, ddp idx %u.\n",
  635. PAGE_SIZE, page_idx);
  636. }
  637. ddp_init(tdev);
  638. }