gen_stats.c 6.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251
  1. /*
  2. * net/core/gen_stats.c
  3. *
  4. * This program is free software; you can redistribute it and/or
  5. * modify it under the terms of the GNU General Public License
  6. * as published by the Free Software Foundation; either version
  7. * 2 of the License, or (at your option) any later version.
  8. *
  9. * Authors: Thomas Graf <tgraf@suug.ch>
  10. * Jamal Hadi Salim
  11. * Alexey Kuznetsov, <kuznet@ms2.inr.ac.ru>
  12. *
  13. * See Documentation/networking/gen_stats.txt
  14. */
  15. #include <linux/types.h>
  16. #include <linux/kernel.h>
  17. #include <linux/module.h>
  18. #include <linux/interrupt.h>
  19. #include <linux/socket.h>
  20. #include <linux/rtnetlink.h>
  21. #include <linux/gen_stats.h>
  22. #include <net/netlink.h>
  23. #include <net/gen_stats.h>
  24. static inline int
  25. gnet_stats_copy(struct gnet_dump *d, int type, void *buf, int size)
  26. {
  27. if (nla_put(d->skb, type, size, buf))
  28. goto nla_put_failure;
  29. return 0;
  30. nla_put_failure:
  31. spin_unlock_bh(d->lock);
  32. return -1;
  33. }
  34. /**
  35. * gnet_stats_start_copy_compat - start dumping procedure in compatibility mode
  36. * @skb: socket buffer to put statistics TLVs into
  37. * @type: TLV type for top level statistic TLV
  38. * @tc_stats_type: TLV type for backward compatibility struct tc_stats TLV
  39. * @xstats_type: TLV type for backward compatibility xstats TLV
  40. * @lock: statistics lock
  41. * @d: dumping handle
  42. *
  43. * Initializes the dumping handle, grabs the statistic lock and appends
  44. * an empty TLV header to the socket buffer for use a container for all
  45. * other statistic TLVS.
  46. *
  47. * The dumping handle is marked to be in backward compatibility mode telling
  48. * all gnet_stats_copy_XXX() functions to fill a local copy of struct tc_stats.
  49. *
  50. * Returns 0 on success or -1 if the room in the socket buffer was not sufficient.
  51. */
  52. int
  53. gnet_stats_start_copy_compat(struct sk_buff *skb, int type, int tc_stats_type,
  54. int xstats_type, spinlock_t *lock, struct gnet_dump *d)
  55. __acquires(lock)
  56. {
  57. memset(d, 0, sizeof(*d));
  58. spin_lock_bh(lock);
  59. d->lock = lock;
  60. if (type)
  61. d->tail = (struct nlattr *)skb_tail_pointer(skb);
  62. d->skb = skb;
  63. d->compat_tc_stats = tc_stats_type;
  64. d->compat_xstats = xstats_type;
  65. if (d->tail)
  66. return gnet_stats_copy(d, type, NULL, 0);
  67. return 0;
  68. }
  69. EXPORT_SYMBOL(gnet_stats_start_copy_compat);
  70. /**
  71. * gnet_stats_start_copy_compat - start dumping procedure in compatibility mode
  72. * @skb: socket buffer to put statistics TLVs into
  73. * @type: TLV type for top level statistic TLV
  74. * @lock: statistics lock
  75. * @d: dumping handle
  76. *
  77. * Initializes the dumping handle, grabs the statistic lock and appends
  78. * an empty TLV header to the socket buffer for use a container for all
  79. * other statistic TLVS.
  80. *
  81. * Returns 0 on success or -1 if the room in the socket buffer was not sufficient.
  82. */
  83. int
  84. gnet_stats_start_copy(struct sk_buff *skb, int type, spinlock_t *lock,
  85. struct gnet_dump *d)
  86. {
  87. return gnet_stats_start_copy_compat(skb, type, 0, 0, lock, d);
  88. }
  89. EXPORT_SYMBOL(gnet_stats_start_copy);
  90. /**
  91. * gnet_stats_copy_basic - copy basic statistics into statistic TLV
  92. * @d: dumping handle
  93. * @b: basic statistics
  94. *
  95. * Appends the basic statistics to the top level TLV created by
  96. * gnet_stats_start_copy().
  97. *
  98. * Returns 0 on success or -1 with the statistic lock released
  99. * if the room in the socket buffer was not sufficient.
  100. */
  101. int
  102. gnet_stats_copy_basic(struct gnet_dump *d, struct gnet_stats_basic_packed *b)
  103. {
  104. if (d->compat_tc_stats) {
  105. d->tc_stats.bytes = b->bytes;
  106. d->tc_stats.packets = b->packets;
  107. }
  108. if (d->tail) {
  109. struct gnet_stats_basic sb;
  110. memset(&sb, 0, sizeof(sb));
  111. sb.bytes = b->bytes;
  112. sb.packets = b->packets;
  113. return gnet_stats_copy(d, TCA_STATS_BASIC, &sb, sizeof(sb));
  114. }
  115. return 0;
  116. }
  117. EXPORT_SYMBOL(gnet_stats_copy_basic);
  118. /**
  119. * gnet_stats_copy_rate_est - copy rate estimator statistics into statistics TLV
  120. * @d: dumping handle
  121. * @b: basic statistics
  122. * @r: rate estimator statistics
  123. *
  124. * Appends the rate estimator statistics to the top level TLV created by
  125. * gnet_stats_start_copy().
  126. *
  127. * Returns 0 on success or -1 with the statistic lock released
  128. * if the room in the socket buffer was not sufficient.
  129. */
  130. int
  131. gnet_stats_copy_rate_est(struct gnet_dump *d,
  132. const struct gnet_stats_basic_packed *b,
  133. struct gnet_stats_rate_est *r)
  134. {
  135. if (b && !gen_estimator_active(b, r))
  136. return 0;
  137. if (d->compat_tc_stats) {
  138. d->tc_stats.bps = r->bps;
  139. d->tc_stats.pps = r->pps;
  140. }
  141. if (d->tail)
  142. return gnet_stats_copy(d, TCA_STATS_RATE_EST, r, sizeof(*r));
  143. return 0;
  144. }
  145. EXPORT_SYMBOL(gnet_stats_copy_rate_est);
  146. /**
  147. * gnet_stats_copy_queue - copy queue statistics into statistics TLV
  148. * @d: dumping handle
  149. * @q: queue statistics
  150. *
  151. * Appends the queue statistics to the top level TLV created by
  152. * gnet_stats_start_copy().
  153. *
  154. * Returns 0 on success or -1 with the statistic lock released
  155. * if the room in the socket buffer was not sufficient.
  156. */
  157. int
  158. gnet_stats_copy_queue(struct gnet_dump *d, struct gnet_stats_queue *q)
  159. {
  160. if (d->compat_tc_stats) {
  161. d->tc_stats.drops = q->drops;
  162. d->tc_stats.qlen = q->qlen;
  163. d->tc_stats.backlog = q->backlog;
  164. d->tc_stats.overlimits = q->overlimits;
  165. }
  166. if (d->tail)
  167. return gnet_stats_copy(d, TCA_STATS_QUEUE, q, sizeof(*q));
  168. return 0;
  169. }
  170. EXPORT_SYMBOL(gnet_stats_copy_queue);
  171. /**
  172. * gnet_stats_copy_app - copy application specific statistics into statistics TLV
  173. * @d: dumping handle
  174. * @st: application specific statistics data
  175. * @len: length of data
  176. *
  177. * Appends the application sepecific statistics to the top level TLV created by
  178. * gnet_stats_start_copy() and remembers the data for XSTATS if the dumping
  179. * handle is in backward compatibility mode.
  180. *
  181. * Returns 0 on success or -1 with the statistic lock released
  182. * if the room in the socket buffer was not sufficient.
  183. */
  184. int
  185. gnet_stats_copy_app(struct gnet_dump *d, void *st, int len)
  186. {
  187. if (d->compat_xstats) {
  188. d->xstats = st;
  189. d->xstats_len = len;
  190. }
  191. if (d->tail)
  192. return gnet_stats_copy(d, TCA_STATS_APP, st, len);
  193. return 0;
  194. }
  195. EXPORT_SYMBOL(gnet_stats_copy_app);
  196. /**
  197. * gnet_stats_finish_copy - finish dumping procedure
  198. * @d: dumping handle
  199. *
  200. * Corrects the length of the top level TLV to include all TLVs added
  201. * by gnet_stats_copy_XXX() calls. Adds the backward compatibility TLVs
  202. * if gnet_stats_start_copy_compat() was used and releases the statistics
  203. * lock.
  204. *
  205. * Returns 0 on success or -1 with the statistic lock released
  206. * if the room in the socket buffer was not sufficient.
  207. */
  208. int
  209. gnet_stats_finish_copy(struct gnet_dump *d)
  210. {
  211. if (d->tail)
  212. d->tail->nla_len = skb_tail_pointer(d->skb) - (u8 *)d->tail;
  213. if (d->compat_tc_stats)
  214. if (gnet_stats_copy(d, d->compat_tc_stats, &d->tc_stats,
  215. sizeof(d->tc_stats)) < 0)
  216. return -1;
  217. if (d->compat_xstats && d->xstats) {
  218. if (gnet_stats_copy(d, d->compat_xstats, d->xstats,
  219. d->xstats_len) < 0)
  220. return -1;
  221. }
  222. spin_unlock_bh(d->lock);
  223. return 0;
  224. }
  225. EXPORT_SYMBOL(gnet_stats_finish_copy);