ipath_stats.c 9.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280
  1. /*
  2. * Copyright (c) 2006 QLogic, Inc. All rights reserved.
  3. * Copyright (c) 2003, 2004, 2005, 2006 PathScale, Inc. All rights reserved.
  4. *
  5. * This software is available to you under a choice of one of two
  6. * licenses. You may choose to be licensed under the terms of the GNU
  7. * General Public License (GPL) Version 2, available from the file
  8. * COPYING in the main directory of this source tree, or the
  9. * OpenIB.org BSD license below:
  10. *
  11. * Redistribution and use in source and binary forms, with or
  12. * without modification, are permitted provided that the following
  13. * conditions are met:
  14. *
  15. * - Redistributions of source code must retain the above
  16. * copyright notice, this list of conditions and the following
  17. * disclaimer.
  18. *
  19. * - Redistributions in binary form must reproduce the above
  20. * copyright notice, this list of conditions and the following
  21. * disclaimer in the documentation and/or other materials
  22. * provided with the distribution.
  23. *
  24. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  25. * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  26. * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  27. * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
  28. * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
  29. * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  30. * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  31. * SOFTWARE.
  32. */
  33. #include "ipath_kernel.h"
  34. struct infinipath_stats ipath_stats;
  35. /**
  36. * ipath_snap_cntr - snapshot a chip counter
  37. * @dd: the infinipath device
  38. * @creg: the counter to snapshot
  39. *
  40. * called from add_timer and user counter read calls, to deal with
  41. * counters that wrap in "human time". The words sent and received, and
  42. * the packets sent and received are all that we worry about. For now,
  43. * at least, we don't worry about error counters, because if they wrap
  44. * that quickly, we probably don't care. We may eventually just make this
  45. * handle all the counters. word counters can wrap in about 20 seconds
  46. * of full bandwidth traffic, packet counters in a few hours.
  47. */
  48. u64 ipath_snap_cntr(struct ipath_devdata *dd, ipath_creg creg)
  49. {
  50. u32 val, reg64 = 0;
  51. u64 val64;
  52. unsigned long t0, t1;
  53. u64 ret;
  54. t0 = jiffies;
  55. /* If fast increment counters are only 32 bits, snapshot them,
  56. * and maintain them as 64bit values in the driver */
  57. if (!(dd->ipath_flags & IPATH_32BITCOUNTERS) &&
  58. (creg == dd->ipath_cregs->cr_wordsendcnt ||
  59. creg == dd->ipath_cregs->cr_wordrcvcnt ||
  60. creg == dd->ipath_cregs->cr_pktsendcnt ||
  61. creg == dd->ipath_cregs->cr_pktrcvcnt)) {
  62. val64 = ipath_read_creg(dd, creg);
  63. val = val64 == ~0ULL ? ~0U : 0;
  64. reg64 = 1;
  65. } else /* val64 just to keep gcc quiet... */
  66. val64 = val = ipath_read_creg32(dd, creg);
  67. /*
  68. * See if a second has passed. This is just a way to detect things
  69. * that are quite broken. Normally this should take just a few
  70. * cycles (the check is for long enough that we don't care if we get
  71. * pre-empted.) An Opteron HT O read timeout is 4 seconds with
  72. * normal NB values
  73. */
  74. t1 = jiffies;
  75. if (time_before(t0 + HZ, t1) && val == -1) {
  76. ipath_dev_err(dd, "Error! Read counter 0x%x timed out\n",
  77. creg);
  78. ret = 0ULL;
  79. goto bail;
  80. }
  81. if (reg64) {
  82. ret = val64;
  83. goto bail;
  84. }
  85. if (creg == dd->ipath_cregs->cr_wordsendcnt) {
  86. if (val != dd->ipath_lastsword) {
  87. dd->ipath_sword += val - dd->ipath_lastsword;
  88. dd->ipath_lastsword = val;
  89. }
  90. val64 = dd->ipath_sword;
  91. } else if (creg == dd->ipath_cregs->cr_wordrcvcnt) {
  92. if (val != dd->ipath_lastrword) {
  93. dd->ipath_rword += val - dd->ipath_lastrword;
  94. dd->ipath_lastrword = val;
  95. }
  96. val64 = dd->ipath_rword;
  97. } else if (creg == dd->ipath_cregs->cr_pktsendcnt) {
  98. if (val != dd->ipath_lastspkts) {
  99. dd->ipath_spkts += val - dd->ipath_lastspkts;
  100. dd->ipath_lastspkts = val;
  101. }
  102. val64 = dd->ipath_spkts;
  103. } else if (creg == dd->ipath_cregs->cr_pktrcvcnt) {
  104. if (val != dd->ipath_lastrpkts) {
  105. dd->ipath_rpkts += val - dd->ipath_lastrpkts;
  106. dd->ipath_lastrpkts = val;
  107. }
  108. val64 = dd->ipath_rpkts;
  109. } else
  110. val64 = (u64) val;
  111. ret = val64;
  112. bail:
  113. return ret;
  114. }
  115. /**
  116. * ipath_qcheck - print delta of egrfull/hdrqfull errors for kernel ports
  117. * @dd: the infinipath device
  118. *
  119. * print the delta of egrfull/hdrqfull errors for kernel ports no more than
  120. * every 5 seconds. User processes are printed at close, but kernel doesn't
  121. * close, so... Separate routine so may call from other places someday, and
  122. * so function name when printed by _IPATH_INFO is meaningfull
  123. */
  124. static void ipath_qcheck(struct ipath_devdata *dd)
  125. {
  126. static u64 last_tot_hdrqfull;
  127. size_t blen = 0;
  128. char buf[128];
  129. *buf = 0;
  130. if (dd->ipath_pd[0]->port_hdrqfull != dd->ipath_p0_hdrqfull) {
  131. blen = snprintf(buf, sizeof buf, "port 0 hdrqfull %u",
  132. dd->ipath_pd[0]->port_hdrqfull -
  133. dd->ipath_p0_hdrqfull);
  134. dd->ipath_p0_hdrqfull = dd->ipath_pd[0]->port_hdrqfull;
  135. }
  136. if (ipath_stats.sps_etidfull != dd->ipath_last_tidfull) {
  137. blen += snprintf(buf + blen, sizeof buf - blen,
  138. "%srcvegrfull %llu",
  139. blen ? ", " : "",
  140. (unsigned long long)
  141. (ipath_stats.sps_etidfull -
  142. dd->ipath_last_tidfull));
  143. dd->ipath_last_tidfull = ipath_stats.sps_etidfull;
  144. }
  145. /*
  146. * this is actually the number of hdrq full interrupts, not actual
  147. * events, but at the moment that's mostly what I'm interested in.
  148. * Actual count, etc. is in the counters, if needed. For production
  149. * users this won't ordinarily be printed.
  150. */
  151. if ((ipath_debug & (__IPATH_PKTDBG | __IPATH_DBG)) &&
  152. ipath_stats.sps_hdrqfull != last_tot_hdrqfull) {
  153. blen += snprintf(buf + blen, sizeof buf - blen,
  154. "%shdrqfull %llu (all ports)",
  155. blen ? ", " : "",
  156. (unsigned long long)
  157. (ipath_stats.sps_hdrqfull -
  158. last_tot_hdrqfull));
  159. last_tot_hdrqfull = ipath_stats.sps_hdrqfull;
  160. }
  161. if (blen)
  162. ipath_dbg("%s\n", buf);
  163. if (dd->ipath_port0head != (u32)
  164. le64_to_cpu(*dd->ipath_hdrqtailptr)) {
  165. if (dd->ipath_lastport0rcv_cnt ==
  166. ipath_stats.sps_port0pkts) {
  167. ipath_cdbg(PKT, "missing rcv interrupts? "
  168. "port0 hd=%llx tl=%x; port0pkts %llx\n",
  169. (unsigned long long)
  170. le64_to_cpu(*dd->ipath_hdrqtailptr),
  171. dd->ipath_port0head,
  172. (unsigned long long)
  173. ipath_stats.sps_port0pkts);
  174. }
  175. dd->ipath_lastport0rcv_cnt = ipath_stats.sps_port0pkts;
  176. }
  177. }
  178. /**
  179. * ipath_get_faststats - get word counters from chip before they overflow
  180. * @opaque - contains a pointer to the infinipath device ipath_devdata
  181. *
  182. * called from add_timer
  183. */
  184. void ipath_get_faststats(unsigned long opaque)
  185. {
  186. struct ipath_devdata *dd = (struct ipath_devdata *) opaque;
  187. u32 val;
  188. static unsigned cnt;
  189. /*
  190. * don't access the chip while running diags, or memory diags can
  191. * fail
  192. */
  193. if (!dd->ipath_kregbase || !(dd->ipath_flags & IPATH_INITTED) ||
  194. ipath_diag_inuse)
  195. /* but re-arm the timer, for diags case; won't hurt other */
  196. goto done;
  197. if (dd->ipath_flags & IPATH_32BITCOUNTERS) {
  198. ipath_snap_cntr(dd, dd->ipath_cregs->cr_wordsendcnt);
  199. ipath_snap_cntr(dd, dd->ipath_cregs->cr_wordrcvcnt);
  200. ipath_snap_cntr(dd, dd->ipath_cregs->cr_pktsendcnt);
  201. ipath_snap_cntr(dd, dd->ipath_cregs->cr_pktrcvcnt);
  202. }
  203. ipath_qcheck(dd);
  204. /*
  205. * deal with repeat error suppression. Doesn't really matter if
  206. * last error was almost a full interval ago, or just a few usecs
  207. * ago; still won't get more than 2 per interval. We may want
  208. * longer intervals for this eventually, could do with mod, counter
  209. * or separate timer. Also see code in ipath_handle_errors() and
  210. * ipath_handle_hwerrors().
  211. */
  212. if (dd->ipath_lasterror)
  213. dd->ipath_lasterror = 0;
  214. if (dd->ipath_lasthwerror)
  215. dd->ipath_lasthwerror = 0;
  216. if ((dd->ipath_maskederrs & ~dd->ipath_ignorederrs)
  217. && time_after(jiffies, dd->ipath_unmasktime)) {
  218. char ebuf[256];
  219. int iserr;
  220. iserr = ipath_decode_err(ebuf, sizeof ebuf,
  221. (dd->ipath_maskederrs & ~dd->
  222. ipath_ignorederrs));
  223. if ((dd->ipath_maskederrs & ~dd->ipath_ignorederrs) &
  224. ~(INFINIPATH_E_RRCVEGRFULL | INFINIPATH_E_RRCVHDRFULL |
  225. INFINIPATH_E_PKTERRS ))
  226. ipath_dev_err(dd, "Re-enabling masked errors "
  227. "(%s)\n", ebuf);
  228. else {
  229. /*
  230. * rcvegrfull and rcvhdrqfull are "normal", for some
  231. * types of processes (mostly benchmarks) that send
  232. * huge numbers of messages, while not processing
  233. * them. So only complain about these at debug
  234. * level.
  235. */
  236. if (iserr)
  237. ipath_dbg("Re-enabling queue full errors (%s)\n",
  238. ebuf);
  239. else
  240. ipath_cdbg(ERRPKT, "Re-enabling packet"
  241. " problem interrupt (%s)\n", ebuf);
  242. }
  243. dd->ipath_maskederrs = dd->ipath_ignorederrs;
  244. ipath_write_kreg(dd, dd->ipath_kregs->kr_errormask,
  245. ~dd->ipath_maskederrs);
  246. }
  247. /* limit qfull messages to ~one per minute per port */
  248. if ((++cnt & 0x10)) {
  249. for (val = dd->ipath_cfgports - 1; ((int)val) >= 0;
  250. val--) {
  251. if (dd->ipath_lastegrheads[val] != -1)
  252. dd->ipath_lastegrheads[val] = -1;
  253. if (dd->ipath_lastrcvhdrqtails[val] != -1)
  254. dd->ipath_lastrcvhdrqtails[val] = -1;
  255. }
  256. }
  257. done:
  258. mod_timer(&dd->ipath_stats_timer, jiffies + HZ * 5);
  259. }