qib_driver.c 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804
  1. /*
  2. * Copyright (c) 2021 Cornelis Networks. All rights reserved.
  3. * Copyright (c) 2013 Intel Corporation. All rights reserved.
  4. * Copyright (c) 2006, 2007, 2008, 2009 QLogic Corporation. All rights reserved.
  5. * Copyright (c) 2003, 2004, 2005, 2006 PathScale, Inc. All rights reserved.
  6. *
  7. * This software is available to you under a choice of one of two
  8. * licenses. You may choose to be licensed under the terms of the GNU
  9. * General Public License (GPL) Version 2, available from the file
  10. * COPYING in the main directory of this source tree, or the
  11. * OpenIB.org BSD license below:
  12. *
  13. * Redistribution and use in source and binary forms, with or
  14. * without modification, are permitted provided that the following
  15. * conditions are met:
  16. *
  17. * - Redistributions of source code must retain the above
  18. * copyright notice, this list of conditions and the following
  19. * disclaimer.
  20. *
  21. * - Redistributions in binary form must reproduce the above
  22. * copyright notice, this list of conditions and the following
  23. * disclaimer in the documentation and/or other materials
  24. * provided with the distribution.
  25. *
  26. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  27. * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  28. * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  29. * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
  30. * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
  31. * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  32. * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  33. * SOFTWARE.
  34. */
  35. #include <linux/spinlock.h>
  36. #include <linux/pci.h>
  37. #include <linux/io.h>
  38. #include <linux/delay.h>
  39. #include <linux/netdevice.h>
  40. #include <linux/vmalloc.h>
  41. #include <linux/module.h>
  42. #include <linux/prefetch.h>
  43. #include "qib.h"
  44. /*
  45. * The size has to be longer than this string, so we can append
  46. * board/chip information to it in the init code.
  47. */
  48. const char ib_qib_version[] = QIB_DRIVER_VERSION "\n";
  49. DEFINE_MUTEX(qib_mutex); /* general driver use */
  50. unsigned qib_ibmtu;
  51. module_param_named(ibmtu, qib_ibmtu, uint, S_IRUGO);
  52. MODULE_PARM_DESC(ibmtu, "Set max IB MTU (0=2KB, 1=256, 2=512, ... 5=4096");
  53. unsigned qib_compat_ddr_negotiate = 1;
  54. module_param_named(compat_ddr_negotiate, qib_compat_ddr_negotiate, uint,
  55. S_IWUSR | S_IRUGO);
  56. MODULE_PARM_DESC(compat_ddr_negotiate,
  57. "Attempt pre-IBTA 1.2 DDR speed negotiation");
  58. MODULE_LICENSE("Dual BSD/GPL");
  59. MODULE_AUTHOR("Cornelis <[email protected]>");
  60. MODULE_DESCRIPTION("Cornelis IB driver");
  61. /*
  62. * QIB_PIO_MAXIBHDR is the max IB header size allowed for in our
  63. * PIO send buffers. This is well beyond anything currently
  64. * defined in the InfiniBand spec.
  65. */
  66. #define QIB_PIO_MAXIBHDR 128
  67. /*
  68. * QIB_MAX_PKT_RCV is the max # if packets processed per receive interrupt.
  69. */
  70. #define QIB_MAX_PKT_RECV 64
  71. struct qlogic_ib_stats qib_stats;
  72. struct pci_dev *qib_get_pci_dev(struct rvt_dev_info *rdi)
  73. {
  74. struct qib_ibdev *ibdev = container_of(rdi, struct qib_ibdev, rdi);
  75. struct qib_devdata *dd = container_of(ibdev,
  76. struct qib_devdata, verbs_dev);
  77. return dd->pcidev;
  78. }
  79. /*
  80. * Return count of units with at least one port ACTIVE.
  81. */
  82. int qib_count_active_units(void)
  83. {
  84. struct qib_devdata *dd;
  85. struct qib_pportdata *ppd;
  86. unsigned long index, flags;
  87. int pidx, nunits_active = 0;
  88. xa_lock_irqsave(&qib_dev_table, flags);
  89. xa_for_each(&qib_dev_table, index, dd) {
  90. if (!(dd->flags & QIB_PRESENT) || !dd->kregbase)
  91. continue;
  92. for (pidx = 0; pidx < dd->num_pports; ++pidx) {
  93. ppd = dd->pport + pidx;
  94. if (ppd->lid && (ppd->lflags & (QIBL_LINKINIT |
  95. QIBL_LINKARMED | QIBL_LINKACTIVE))) {
  96. nunits_active++;
  97. break;
  98. }
  99. }
  100. }
  101. xa_unlock_irqrestore(&qib_dev_table, flags);
  102. return nunits_active;
  103. }
  104. /*
  105. * Return count of all units, optionally return in arguments
  106. * the number of usable (present) units, and the number of
  107. * ports that are up.
  108. */
  109. int qib_count_units(int *npresentp, int *nupp)
  110. {
  111. int nunits = 0, npresent = 0, nup = 0;
  112. struct qib_devdata *dd;
  113. unsigned long index, flags;
  114. int pidx;
  115. struct qib_pportdata *ppd;
  116. xa_lock_irqsave(&qib_dev_table, flags);
  117. xa_for_each(&qib_dev_table, index, dd) {
  118. nunits++;
  119. if ((dd->flags & QIB_PRESENT) && dd->kregbase)
  120. npresent++;
  121. for (pidx = 0; pidx < dd->num_pports; ++pidx) {
  122. ppd = dd->pport + pidx;
  123. if (ppd->lid && (ppd->lflags & (QIBL_LINKINIT |
  124. QIBL_LINKARMED | QIBL_LINKACTIVE)))
  125. nup++;
  126. }
  127. }
  128. xa_unlock_irqrestore(&qib_dev_table, flags);
  129. if (npresentp)
  130. *npresentp = npresent;
  131. if (nupp)
  132. *nupp = nup;
  133. return nunits;
  134. }
  135. /**
  136. * qib_wait_linkstate - wait for an IB link state change to occur
  137. * @ppd: the qlogic_ib device
  138. * @state: the state to wait for
  139. * @msecs: the number of milliseconds to wait
  140. *
  141. * wait up to msecs milliseconds for IB link state change to occur for
  142. * now, take the easy polling route. Currently used only by
  143. * qib_set_linkstate. Returns 0 if state reached, otherwise
  144. * -ETIMEDOUT state can have multiple states set, for any of several
  145. * transitions.
  146. */
  147. int qib_wait_linkstate(struct qib_pportdata *ppd, u32 state, int msecs)
  148. {
  149. int ret;
  150. unsigned long flags;
  151. spin_lock_irqsave(&ppd->lflags_lock, flags);
  152. if (ppd->state_wanted) {
  153. spin_unlock_irqrestore(&ppd->lflags_lock, flags);
  154. ret = -EBUSY;
  155. goto bail;
  156. }
  157. ppd->state_wanted = state;
  158. spin_unlock_irqrestore(&ppd->lflags_lock, flags);
  159. wait_event_interruptible_timeout(ppd->state_wait,
  160. (ppd->lflags & state),
  161. msecs_to_jiffies(msecs));
  162. spin_lock_irqsave(&ppd->lflags_lock, flags);
  163. ppd->state_wanted = 0;
  164. spin_unlock_irqrestore(&ppd->lflags_lock, flags);
  165. if (!(ppd->lflags & state))
  166. ret = -ETIMEDOUT;
  167. else
  168. ret = 0;
  169. bail:
  170. return ret;
  171. }
  172. int qib_set_linkstate(struct qib_pportdata *ppd, u8 newstate)
  173. {
  174. u32 lstate;
  175. int ret;
  176. struct qib_devdata *dd = ppd->dd;
  177. unsigned long flags;
  178. switch (newstate) {
  179. case QIB_IB_LINKDOWN_ONLY:
  180. dd->f_set_ib_cfg(ppd, QIB_IB_CFG_LSTATE,
  181. IB_LINKCMD_DOWN | IB_LINKINITCMD_NOP);
  182. /* don't wait */
  183. ret = 0;
  184. goto bail;
  185. case QIB_IB_LINKDOWN:
  186. dd->f_set_ib_cfg(ppd, QIB_IB_CFG_LSTATE,
  187. IB_LINKCMD_DOWN | IB_LINKINITCMD_POLL);
  188. /* don't wait */
  189. ret = 0;
  190. goto bail;
  191. case QIB_IB_LINKDOWN_SLEEP:
  192. dd->f_set_ib_cfg(ppd, QIB_IB_CFG_LSTATE,
  193. IB_LINKCMD_DOWN | IB_LINKINITCMD_SLEEP);
  194. /* don't wait */
  195. ret = 0;
  196. goto bail;
  197. case QIB_IB_LINKDOWN_DISABLE:
  198. dd->f_set_ib_cfg(ppd, QIB_IB_CFG_LSTATE,
  199. IB_LINKCMD_DOWN | IB_LINKINITCMD_DISABLE);
  200. /* don't wait */
  201. ret = 0;
  202. goto bail;
  203. case QIB_IB_LINKARM:
  204. if (ppd->lflags & QIBL_LINKARMED) {
  205. ret = 0;
  206. goto bail;
  207. }
  208. if (!(ppd->lflags & (QIBL_LINKINIT | QIBL_LINKACTIVE))) {
  209. ret = -EINVAL;
  210. goto bail;
  211. }
  212. /*
  213. * Since the port can be ACTIVE when we ask for ARMED,
  214. * clear QIBL_LINKV so we can wait for a transition.
  215. * If the link isn't ARMED, then something else happened
  216. * and there is no point waiting for ARMED.
  217. */
  218. spin_lock_irqsave(&ppd->lflags_lock, flags);
  219. ppd->lflags &= ~QIBL_LINKV;
  220. spin_unlock_irqrestore(&ppd->lflags_lock, flags);
  221. dd->f_set_ib_cfg(ppd, QIB_IB_CFG_LSTATE,
  222. IB_LINKCMD_ARMED | IB_LINKINITCMD_NOP);
  223. lstate = QIBL_LINKV;
  224. break;
  225. case QIB_IB_LINKACTIVE:
  226. if (ppd->lflags & QIBL_LINKACTIVE) {
  227. ret = 0;
  228. goto bail;
  229. }
  230. if (!(ppd->lflags & QIBL_LINKARMED)) {
  231. ret = -EINVAL;
  232. goto bail;
  233. }
  234. dd->f_set_ib_cfg(ppd, QIB_IB_CFG_LSTATE,
  235. IB_LINKCMD_ACTIVE | IB_LINKINITCMD_NOP);
  236. lstate = QIBL_LINKACTIVE;
  237. break;
  238. default:
  239. ret = -EINVAL;
  240. goto bail;
  241. }
  242. ret = qib_wait_linkstate(ppd, lstate, 10);
  243. bail:
  244. return ret;
  245. }
  246. /*
  247. * Get address of eager buffer from it's index (allocated in chunks, not
  248. * contiguous).
  249. */
  250. static inline void *qib_get_egrbuf(const struct qib_ctxtdata *rcd, u32 etail)
  251. {
  252. const u32 chunk = etail >> rcd->rcvegrbufs_perchunk_shift;
  253. const u32 idx = etail & ((u32)rcd->rcvegrbufs_perchunk - 1);
  254. return rcd->rcvegrbuf[chunk] + (idx << rcd->dd->rcvegrbufsize_shift);
  255. }
  256. /*
  257. * Returns 1 if error was a CRC, else 0.
  258. * Needed for some chip's synthesized error counters.
  259. */
  260. static u32 qib_rcv_hdrerr(struct qib_ctxtdata *rcd, struct qib_pportdata *ppd,
  261. u32 ctxt, u32 eflags, u32 l, u32 etail,
  262. __le32 *rhf_addr, struct qib_message_header *rhdr)
  263. {
  264. u32 ret = 0;
  265. if (eflags & (QLOGIC_IB_RHF_H_ICRCERR | QLOGIC_IB_RHF_H_VCRCERR))
  266. ret = 1;
  267. else if (eflags == QLOGIC_IB_RHF_H_TIDERR) {
  268. /* For TIDERR and RC QPs premptively schedule a NAK */
  269. struct ib_header *hdr = (struct ib_header *)rhdr;
  270. struct ib_other_headers *ohdr = NULL;
  271. struct qib_ibport *ibp = &ppd->ibport_data;
  272. struct qib_devdata *dd = ppd->dd;
  273. struct rvt_dev_info *rdi = &dd->verbs_dev.rdi;
  274. struct rvt_qp *qp = NULL;
  275. u32 tlen = qib_hdrget_length_in_bytes(rhf_addr);
  276. u16 lid = be16_to_cpu(hdr->lrh[1]);
  277. int lnh = be16_to_cpu(hdr->lrh[0]) & 3;
  278. u32 qp_num;
  279. u32 opcode;
  280. u32 psn;
  281. int diff;
  282. /* Sanity check packet */
  283. if (tlen < 24)
  284. goto drop;
  285. if (lid < be16_to_cpu(IB_MULTICAST_LID_BASE)) {
  286. lid &= ~((1 << ppd->lmc) - 1);
  287. if (unlikely(lid != ppd->lid))
  288. goto drop;
  289. }
  290. /* Check for GRH */
  291. if (lnh == QIB_LRH_BTH)
  292. ohdr = &hdr->u.oth;
  293. else if (lnh == QIB_LRH_GRH) {
  294. u32 vtf;
  295. ohdr = &hdr->u.l.oth;
  296. if (hdr->u.l.grh.next_hdr != IB_GRH_NEXT_HDR)
  297. goto drop;
  298. vtf = be32_to_cpu(hdr->u.l.grh.version_tclass_flow);
  299. if ((vtf >> IB_GRH_VERSION_SHIFT) != IB_GRH_VERSION)
  300. goto drop;
  301. } else
  302. goto drop;
  303. /* Get opcode and PSN from packet */
  304. opcode = be32_to_cpu(ohdr->bth[0]);
  305. opcode >>= 24;
  306. psn = be32_to_cpu(ohdr->bth[2]);
  307. /* Get the destination QP number. */
  308. qp_num = be32_to_cpu(ohdr->bth[1]) & RVT_QPN_MASK;
  309. if (qp_num != QIB_MULTICAST_QPN) {
  310. int ruc_res;
  311. rcu_read_lock();
  312. qp = rvt_lookup_qpn(rdi, &ibp->rvp, qp_num);
  313. if (!qp) {
  314. rcu_read_unlock();
  315. goto drop;
  316. }
  317. /*
  318. * Handle only RC QPs - for other QP types drop error
  319. * packet.
  320. */
  321. spin_lock(&qp->r_lock);
  322. /* Check for valid receive state. */
  323. if (!(ib_rvt_state_ops[qp->state] &
  324. RVT_PROCESS_RECV_OK)) {
  325. ibp->rvp.n_pkt_drops++;
  326. goto unlock;
  327. }
  328. switch (qp->ibqp.qp_type) {
  329. case IB_QPT_RC:
  330. ruc_res =
  331. qib_ruc_check_hdr(
  332. ibp, hdr,
  333. lnh == QIB_LRH_GRH,
  334. qp,
  335. be32_to_cpu(ohdr->bth[0]));
  336. if (ruc_res)
  337. goto unlock;
  338. /* Only deal with RDMA Writes for now */
  339. if (opcode <
  340. IB_OPCODE_RC_RDMA_READ_RESPONSE_FIRST) {
  341. diff = qib_cmp24(psn, qp->r_psn);
  342. if (!qp->r_nak_state && diff >= 0) {
  343. ibp->rvp.n_rc_seqnak++;
  344. qp->r_nak_state =
  345. IB_NAK_PSN_ERROR;
  346. /* Use the expected PSN. */
  347. qp->r_ack_psn = qp->r_psn;
  348. /*
  349. * Wait to send the sequence
  350. * NAK until all packets
  351. * in the receive queue have
  352. * been processed.
  353. * Otherwise, we end up
  354. * propagating congestion.
  355. */
  356. if (list_empty(&qp->rspwait)) {
  357. qp->r_flags |=
  358. RVT_R_RSP_NAK;
  359. rvt_get_qp(qp);
  360. list_add_tail(
  361. &qp->rspwait,
  362. &rcd->qp_wait_list);
  363. }
  364. } /* Out of sequence NAK */
  365. } /* QP Request NAKs */
  366. break;
  367. case IB_QPT_SMI:
  368. case IB_QPT_GSI:
  369. case IB_QPT_UD:
  370. case IB_QPT_UC:
  371. default:
  372. /* For now don't handle any other QP types */
  373. break;
  374. }
  375. unlock:
  376. spin_unlock(&qp->r_lock);
  377. rcu_read_unlock();
  378. } /* Unicast QP */
  379. } /* Valid packet with TIDErr */
  380. drop:
  381. return ret;
  382. }
  383. /*
  384. * qib_kreceive - receive a packet
  385. * @rcd: the qlogic_ib context
  386. * @llic: gets count of good packets needed to clear lli,
  387. * (used with chips that need need to track crcs for lli)
  388. *
  389. * called from interrupt handler for errors or receive interrupt
  390. * Returns number of CRC error packets, needed by some chips for
  391. * local link integrity tracking. crcs are adjusted down by following
  392. * good packets, if any, and count of good packets is also tracked.
  393. */
  394. u32 qib_kreceive(struct qib_ctxtdata *rcd, u32 *llic, u32 *npkts)
  395. {
  396. struct qib_devdata *dd = rcd->dd;
  397. struct qib_pportdata *ppd = rcd->ppd;
  398. __le32 *rhf_addr;
  399. void *ebuf;
  400. const u32 rsize = dd->rcvhdrentsize; /* words */
  401. const u32 maxcnt = dd->rcvhdrcnt * rsize; /* words */
  402. u32 etail = -1, l, hdrqtail;
  403. struct qib_message_header *hdr;
  404. u32 eflags, etype, tlen, i = 0, updegr = 0, crcs = 0;
  405. int last;
  406. u64 lval;
  407. struct rvt_qp *qp, *nqp;
  408. l = rcd->head;
  409. rhf_addr = (__le32 *) rcd->rcvhdrq + l + dd->rhf_offset;
  410. if (dd->flags & QIB_NODMA_RTAIL) {
  411. u32 seq = qib_hdrget_seq(rhf_addr);
  412. if (seq != rcd->seq_cnt)
  413. goto bail;
  414. hdrqtail = 0;
  415. } else {
  416. hdrqtail = qib_get_rcvhdrtail(rcd);
  417. if (l == hdrqtail)
  418. goto bail;
  419. smp_rmb(); /* prevent speculative reads of dma'ed hdrq */
  420. }
  421. for (last = 0, i = 1; !last; i += !last) {
  422. hdr = dd->f_get_msgheader(dd, rhf_addr);
  423. eflags = qib_hdrget_err_flags(rhf_addr);
  424. etype = qib_hdrget_rcv_type(rhf_addr);
  425. /* total length */
  426. tlen = qib_hdrget_length_in_bytes(rhf_addr);
  427. ebuf = NULL;
  428. if ((dd->flags & QIB_NODMA_RTAIL) ?
  429. qib_hdrget_use_egr_buf(rhf_addr) :
  430. (etype != RCVHQ_RCV_TYPE_EXPECTED)) {
  431. etail = qib_hdrget_index(rhf_addr);
  432. updegr = 1;
  433. if (tlen > sizeof(*hdr) ||
  434. etype >= RCVHQ_RCV_TYPE_NON_KD) {
  435. ebuf = qib_get_egrbuf(rcd, etail);
  436. prefetch_range(ebuf, tlen - sizeof(*hdr));
  437. }
  438. }
  439. if (!eflags) {
  440. u16 lrh_len = be16_to_cpu(hdr->lrh[2]) << 2;
  441. if (lrh_len != tlen) {
  442. qib_stats.sps_lenerrs++;
  443. goto move_along;
  444. }
  445. }
  446. if (etype == RCVHQ_RCV_TYPE_NON_KD && !eflags &&
  447. ebuf == NULL &&
  448. tlen > (dd->rcvhdrentsize - 2 + 1 -
  449. qib_hdrget_offset(rhf_addr)) << 2) {
  450. goto move_along;
  451. }
  452. /*
  453. * Both tiderr and qibhdrerr are set for all plain IB
  454. * packets; only qibhdrerr should be set.
  455. */
  456. if (unlikely(eflags))
  457. crcs += qib_rcv_hdrerr(rcd, ppd, rcd->ctxt, eflags, l,
  458. etail, rhf_addr, hdr);
  459. else if (etype == RCVHQ_RCV_TYPE_NON_KD) {
  460. qib_ib_rcv(rcd, hdr, ebuf, tlen);
  461. if (crcs)
  462. crcs--;
  463. else if (llic && *llic)
  464. --*llic;
  465. }
  466. move_along:
  467. l += rsize;
  468. if (l >= maxcnt)
  469. l = 0;
  470. if (i == QIB_MAX_PKT_RECV)
  471. last = 1;
  472. rhf_addr = (__le32 *) rcd->rcvhdrq + l + dd->rhf_offset;
  473. if (dd->flags & QIB_NODMA_RTAIL) {
  474. u32 seq = qib_hdrget_seq(rhf_addr);
  475. if (++rcd->seq_cnt > 13)
  476. rcd->seq_cnt = 1;
  477. if (seq != rcd->seq_cnt)
  478. last = 1;
  479. } else if (l == hdrqtail)
  480. last = 1;
  481. /*
  482. * Update head regs etc., every 16 packets, if not last pkt,
  483. * to help prevent rcvhdrq overflows, when many packets
  484. * are processed and queue is nearly full.
  485. * Don't request an interrupt for intermediate updates.
  486. */
  487. lval = l;
  488. if (!last && !(i & 0xf)) {
  489. dd->f_update_usrhead(rcd, lval, updegr, etail, i);
  490. updegr = 0;
  491. }
  492. }
  493. rcd->head = l;
  494. /*
  495. * Iterate over all QPs waiting to respond.
  496. * The list won't change since the IRQ is only run on one CPU.
  497. */
  498. list_for_each_entry_safe(qp, nqp, &rcd->qp_wait_list, rspwait) {
  499. list_del_init(&qp->rspwait);
  500. if (qp->r_flags & RVT_R_RSP_NAK) {
  501. qp->r_flags &= ~RVT_R_RSP_NAK;
  502. qib_send_rc_ack(qp);
  503. }
  504. if (qp->r_flags & RVT_R_RSP_SEND) {
  505. unsigned long flags;
  506. qp->r_flags &= ~RVT_R_RSP_SEND;
  507. spin_lock_irqsave(&qp->s_lock, flags);
  508. if (ib_rvt_state_ops[qp->state] &
  509. RVT_PROCESS_OR_FLUSH_SEND)
  510. qib_schedule_send(qp);
  511. spin_unlock_irqrestore(&qp->s_lock, flags);
  512. }
  513. rvt_put_qp(qp);
  514. }
  515. bail:
  516. /* Report number of packets consumed */
  517. if (npkts)
  518. *npkts = i;
  519. /*
  520. * Always write head at end, and setup rcv interrupt, even
  521. * if no packets were processed.
  522. */
  523. lval = (u64)rcd->head | dd->rhdrhead_intr_off;
  524. dd->f_update_usrhead(rcd, lval, updegr, etail, i);
  525. return crcs;
  526. }
  527. /**
  528. * qib_set_mtu - set the MTU
  529. * @ppd: the perport data
  530. * @arg: the new MTU
  531. *
  532. * We can handle "any" incoming size, the issue here is whether we
  533. * need to restrict our outgoing size. For now, we don't do any
  534. * sanity checking on this, and we don't deal with what happens to
  535. * programs that are already running when the size changes.
  536. * NOTE: changing the MTU will usually cause the IBC to go back to
  537. * link INIT state...
  538. */
  539. int qib_set_mtu(struct qib_pportdata *ppd, u16 arg)
  540. {
  541. u32 piosize;
  542. int ret, chk;
  543. if (arg != 256 && arg != 512 && arg != 1024 && arg != 2048 &&
  544. arg != 4096) {
  545. ret = -EINVAL;
  546. goto bail;
  547. }
  548. chk = ib_mtu_enum_to_int(qib_ibmtu);
  549. if (chk > 0 && arg > chk) {
  550. ret = -EINVAL;
  551. goto bail;
  552. }
  553. piosize = ppd->ibmaxlen;
  554. ppd->ibmtu = arg;
  555. if (arg >= (piosize - QIB_PIO_MAXIBHDR)) {
  556. /* Only if it's not the initial value (or reset to it) */
  557. if (piosize != ppd->init_ibmaxlen) {
  558. if (arg > piosize && arg <= ppd->init_ibmaxlen)
  559. piosize = ppd->init_ibmaxlen - 2 * sizeof(u32);
  560. ppd->ibmaxlen = piosize;
  561. }
  562. } else if ((arg + QIB_PIO_MAXIBHDR) != ppd->ibmaxlen) {
  563. piosize = arg + QIB_PIO_MAXIBHDR - 2 * sizeof(u32);
  564. ppd->ibmaxlen = piosize;
  565. }
  566. ppd->dd->f_set_ib_cfg(ppd, QIB_IB_CFG_MTU, 0);
  567. ret = 0;
  568. bail:
  569. return ret;
  570. }
  571. int qib_set_lid(struct qib_pportdata *ppd, u32 lid, u8 lmc)
  572. {
  573. struct qib_devdata *dd = ppd->dd;
  574. ppd->lid = lid;
  575. ppd->lmc = lmc;
  576. dd->f_set_ib_cfg(ppd, QIB_IB_CFG_LIDLMC,
  577. lid | (~((1U << lmc) - 1)) << 16);
  578. qib_devinfo(dd->pcidev, "IB%u:%u got a lid: 0x%x\n",
  579. dd->unit, ppd->port, lid);
  580. return 0;
  581. }
  582. /*
  583. * Following deal with the "obviously simple" task of overriding the state
  584. * of the LEDS, which normally indicate link physical and logical status.
  585. * The complications arise in dealing with different hardware mappings
  586. * and the board-dependent routine being called from interrupts.
  587. * and then there's the requirement to _flash_ them.
  588. */
  589. #define LED_OVER_FREQ_SHIFT 8
  590. #define LED_OVER_FREQ_MASK (0xFF<<LED_OVER_FREQ_SHIFT)
  591. /* Below is "non-zero" to force override, but both actual LEDs are off */
  592. #define LED_OVER_BOTH_OFF (8)
  593. static void qib_run_led_override(struct timer_list *t)
  594. {
  595. struct qib_pportdata *ppd = from_timer(ppd, t,
  596. led_override_timer);
  597. struct qib_devdata *dd = ppd->dd;
  598. int timeoff;
  599. int ph_idx;
  600. if (!(dd->flags & QIB_INITTED))
  601. return;
  602. ph_idx = ppd->led_override_phase++ & 1;
  603. ppd->led_override = ppd->led_override_vals[ph_idx];
  604. timeoff = ppd->led_override_timeoff;
  605. dd->f_setextled(ppd, 1);
  606. /*
  607. * don't re-fire the timer if user asked for it to be off; we let
  608. * it fire one more time after they turn it off to simplify
  609. */
  610. if (ppd->led_override_vals[0] || ppd->led_override_vals[1])
  611. mod_timer(&ppd->led_override_timer, jiffies + timeoff);
  612. }
  613. void qib_set_led_override(struct qib_pportdata *ppd, unsigned int val)
  614. {
  615. struct qib_devdata *dd = ppd->dd;
  616. int timeoff, freq;
  617. if (!(dd->flags & QIB_INITTED))
  618. return;
  619. /* First check if we are blinking. If not, use 1HZ polling */
  620. timeoff = HZ;
  621. freq = (val & LED_OVER_FREQ_MASK) >> LED_OVER_FREQ_SHIFT;
  622. if (freq) {
  623. /* For blink, set each phase from one nybble of val */
  624. ppd->led_override_vals[0] = val & 0xF;
  625. ppd->led_override_vals[1] = (val >> 4) & 0xF;
  626. timeoff = (HZ << 4)/freq;
  627. } else {
  628. /* Non-blink set both phases the same. */
  629. ppd->led_override_vals[0] = val & 0xF;
  630. ppd->led_override_vals[1] = val & 0xF;
  631. }
  632. ppd->led_override_timeoff = timeoff;
  633. /*
  634. * If the timer has not already been started, do so. Use a "quick"
  635. * timeout so the function will be called soon, to look at our request.
  636. */
  637. if (atomic_inc_return(&ppd->led_override_timer_active) == 1) {
  638. /* Need to start timer */
  639. timer_setup(&ppd->led_override_timer, qib_run_led_override, 0);
  640. ppd->led_override_timer.expires = jiffies + 1;
  641. add_timer(&ppd->led_override_timer);
  642. } else {
  643. if (ppd->led_override_vals[0] || ppd->led_override_vals[1])
  644. mod_timer(&ppd->led_override_timer, jiffies + 1);
  645. atomic_dec(&ppd->led_override_timer_active);
  646. }
  647. }
  648. /**
  649. * qib_reset_device - reset the chip if possible
  650. * @unit: the device to reset
  651. *
  652. * Whether or not reset is successful, we attempt to re-initialize the chip
  653. * (that is, much like a driver unload/reload). We clear the INITTED flag
  654. * so that the various entry points will fail until we reinitialize. For
  655. * now, we only allow this if no user contexts are open that use chip resources
  656. */
  657. int qib_reset_device(int unit)
  658. {
  659. int ret, i;
  660. struct qib_devdata *dd = qib_lookup(unit);
  661. struct qib_pportdata *ppd;
  662. unsigned long flags;
  663. int pidx;
  664. if (!dd) {
  665. ret = -ENODEV;
  666. goto bail;
  667. }
  668. qib_devinfo(dd->pcidev, "Reset on unit %u requested\n", unit);
  669. if (!dd->kregbase || !(dd->flags & QIB_PRESENT)) {
  670. qib_devinfo(dd->pcidev,
  671. "Invalid unit number %u or not initialized or not present\n",
  672. unit);
  673. ret = -ENXIO;
  674. goto bail;
  675. }
  676. spin_lock_irqsave(&dd->uctxt_lock, flags);
  677. if (dd->rcd)
  678. for (i = dd->first_user_ctxt; i < dd->cfgctxts; i++) {
  679. if (!dd->rcd[i] || !dd->rcd[i]->cnt)
  680. continue;
  681. spin_unlock_irqrestore(&dd->uctxt_lock, flags);
  682. ret = -EBUSY;
  683. goto bail;
  684. }
  685. spin_unlock_irqrestore(&dd->uctxt_lock, flags);
  686. for (pidx = 0; pidx < dd->num_pports; ++pidx) {
  687. ppd = dd->pport + pidx;
  688. if (atomic_read(&ppd->led_override_timer_active)) {
  689. /* Need to stop LED timer, _then_ shut off LEDs */
  690. del_timer_sync(&ppd->led_override_timer);
  691. atomic_set(&ppd->led_override_timer_active, 0);
  692. }
  693. /* Shut off LEDs after we are sure timer is not running */
  694. ppd->led_override = LED_OVER_BOTH_OFF;
  695. dd->f_setextled(ppd, 0);
  696. if (dd->flags & QIB_HAS_SEND_DMA)
  697. qib_teardown_sdma(ppd);
  698. }
  699. ret = dd->f_reset(dd);
  700. if (ret == 1)
  701. ret = qib_init(dd, 1);
  702. else
  703. ret = -EAGAIN;
  704. if (ret)
  705. qib_dev_err(dd,
  706. "Reinitialize unit %u after reset failed with %d\n",
  707. unit, ret);
  708. else
  709. qib_devinfo(dd->pcidev,
  710. "Reinitialized unit %u after resetting\n",
  711. unit);
  712. bail:
  713. return ret;
  714. }