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. NLA_PUT(d->skb, type, size, buf);
  28. return 0;
  29. nla_put_failure:
  30. spin_unlock_bh(d->lock);
  31. return -1;
  32. }
  33. /**
  34. * gnet_stats_start_copy_compat - start dumping procedure in compatibility mode
  35. * @skb: socket buffer to put statistics TLVs into
  36. * @type: TLV type for top level statistic TLV
  37. * @tc_stats_type: TLV type for backward compatibility struct tc_stats TLV
  38. * @xstats_type: TLV type for backward compatibility xstats TLV
  39. * @lock: statistics lock
  40. * @d: dumping handle
  41. *
  42. * Initializes the dumping handle, grabs the statistic lock and appends
  43. * an empty TLV header to the socket buffer for use a container for all
  44. * other statistic TLVS.
  45. *
  46. * The dumping handle is marked to be in backward compatibility mode telling
  47. * all gnet_stats_copy_XXX() functions to fill a local copy of struct tc_stats.
  48. *
  49. * Returns 0 on success or -1 if the room in the socket buffer was not sufficient.
  50. */
  51. int
  52. gnet_stats_start_copy_compat(struct sk_buff *skb, int type, int tc_stats_type,
  53. int xstats_type, spinlock_t *lock, struct gnet_dump *d)
  54. __acquires(lock)
  55. {
  56. memset(d, 0, sizeof(*d));
  57. spin_lock_bh(lock);
  58. d->lock = lock;
  59. if (type)
  60. d->tail = (struct nlattr *)skb_tail_pointer(skb);
  61. d->skb = skb;
  62. d->compat_tc_stats = tc_stats_type;
  63. d->compat_xstats = xstats_type;
  64. if (d->tail)
  65. return gnet_stats_copy(d, type, NULL, 0);
  66. return 0;
  67. }
  68. EXPORT_SYMBOL(gnet_stats_start_copy_compat);
  69. /**
  70. * gnet_stats_start_copy_compat - start dumping procedure in compatibility mode
  71. * @skb: socket buffer to put statistics TLVs into
  72. * @type: TLV type for top level statistic TLV
  73. * @lock: statistics lock
  74. * @d: dumping handle
  75. *
  76. * Initializes the dumping handle, grabs the statistic lock and appends
  77. * an empty TLV header to the socket buffer for use a container for all
  78. * other statistic TLVS.
  79. *
  80. * Returns 0 on success or -1 if the room in the socket buffer was not sufficient.
  81. */
  82. int
  83. gnet_stats_start_copy(struct sk_buff *skb, int type, spinlock_t *lock,
  84. struct gnet_dump *d)
  85. {
  86. return gnet_stats_start_copy_compat(skb, type, 0, 0, lock, d);
  87. }
  88. EXPORT_SYMBOL(gnet_stats_start_copy);
  89. /**
  90. * gnet_stats_copy_basic - copy basic statistics into statistic TLV
  91. * @d: dumping handle
  92. * @b: basic statistics
  93. *
  94. * Appends the basic statistics to the top level TLV created by
  95. * gnet_stats_start_copy().
  96. *
  97. * Returns 0 on success or -1 with the statistic lock released
  98. * if the room in the socket buffer was not sufficient.
  99. */
  100. int
  101. gnet_stats_copy_basic(struct gnet_dump *d, struct gnet_stats_basic_packed *b)
  102. {
  103. if (d->compat_tc_stats) {
  104. d->tc_stats.bytes = b->bytes;
  105. d->tc_stats.packets = b->packets;
  106. }
  107. if (d->tail) {
  108. struct gnet_stats_basic sb;
  109. memset(&sb, 0, sizeof(sb));
  110. sb.bytes = b->bytes;
  111. sb.packets = b->packets;
  112. return gnet_stats_copy(d, TCA_STATS_BASIC, &sb, sizeof(sb));
  113. }
  114. return 0;
  115. }
  116. EXPORT_SYMBOL(gnet_stats_copy_basic);
  117. /**
  118. * gnet_stats_copy_rate_est - copy rate estimator statistics into statistics TLV
  119. * @d: dumping handle
  120. * @b: basic statistics
  121. * @r: rate estimator statistics
  122. *
  123. * Appends the rate estimator statistics to the top level TLV created by
  124. * gnet_stats_start_copy().
  125. *
  126. * Returns 0 on success or -1 with the statistic lock released
  127. * if the room in the socket buffer was not sufficient.
  128. */
  129. int
  130. gnet_stats_copy_rate_est(struct gnet_dump *d,
  131. const struct gnet_stats_basic_packed *b,
  132. struct gnet_stats_rate_est *r)
  133. {
  134. if (b && !gen_estimator_active(b, r))
  135. return 0;
  136. if (d->compat_tc_stats) {
  137. d->tc_stats.bps = r->bps;
  138. d->tc_stats.pps = r->pps;
  139. }
  140. if (d->tail)
  141. return gnet_stats_copy(d, TCA_STATS_RATE_EST, r, sizeof(*r));
  142. return 0;
  143. }
  144. EXPORT_SYMBOL(gnet_stats_copy_rate_est);
  145. /**
  146. * gnet_stats_copy_queue - copy queue statistics into statistics TLV
  147. * @d: dumping handle
  148. * @q: queue statistics
  149. *
  150. * Appends the queue statistics to the top level TLV created by
  151. * gnet_stats_start_copy().
  152. *
  153. * Returns 0 on success or -1 with the statistic lock released
  154. * if the room in the socket buffer was not sufficient.
  155. */
  156. int
  157. gnet_stats_copy_queue(struct gnet_dump *d, struct gnet_stats_queue *q)
  158. {
  159. if (d->compat_tc_stats) {
  160. d->tc_stats.drops = q->drops;
  161. d->tc_stats.qlen = q->qlen;
  162. d->tc_stats.backlog = q->backlog;
  163. d->tc_stats.overlimits = q->overlimits;
  164. }
  165. if (d->tail)
  166. return gnet_stats_copy(d, TCA_STATS_QUEUE, q, sizeof(*q));
  167. return 0;
  168. }
  169. EXPORT_SYMBOL(gnet_stats_copy_queue);
  170. /**
  171. * gnet_stats_copy_app - copy application specific statistics into statistics TLV
  172. * @d: dumping handle
  173. * @st: application specific statistics data
  174. * @len: length of data
  175. *
  176. * Appends the application sepecific statistics to the top level TLV created by
  177. * gnet_stats_start_copy() and remembers the data for XSTATS if the dumping
  178. * handle is in backward compatibility mode.
  179. *
  180. * Returns 0 on success or -1 with the statistic lock released
  181. * if the room in the socket buffer was not sufficient.
  182. */
  183. int
  184. gnet_stats_copy_app(struct gnet_dump *d, void *st, int len)
  185. {
  186. if (d->compat_xstats) {
  187. d->xstats = st;
  188. d->xstats_len = len;
  189. }
  190. if (d->tail)
  191. return gnet_stats_copy(d, TCA_STATS_APP, st, len);
  192. return 0;
  193. }
  194. EXPORT_SYMBOL(gnet_stats_copy_app);
  195. /**
  196. * gnet_stats_finish_copy - finish dumping procedure
  197. * @d: dumping handle
  198. *
  199. * Corrects the length of the top level TLV to include all TLVs added
  200. * by gnet_stats_copy_XXX() calls. Adds the backward compatibility TLVs
  201. * if gnet_stats_start_copy_compat() was used and releases the statistics
  202. * lock.
  203. *
  204. * Returns 0 on success or -1 with the statistic lock released
  205. * if the room in the socket buffer was not sufficient.
  206. */
  207. int
  208. gnet_stats_finish_copy(struct gnet_dump *d)
  209. {
  210. if (d->tail)
  211. d->tail->nla_len = skb_tail_pointer(d->skb) - (u8 *)d->tail;
  212. if (d->compat_tc_stats)
  213. if (gnet_stats_copy(d, d->compat_tc_stats, &d->tc_stats,
  214. sizeof(d->tc_stats)) < 0)
  215. return -1;
  216. if (d->compat_xstats && d->xstats) {
  217. if (gnet_stats_copy(d, d->compat_xstats, d->xstats,
  218. d->xstats_len) < 0)
  219. return -1;
  220. }
  221. spin_unlock_bh(d->lock);
  222. return 0;
  223. }
  224. EXPORT_SYMBOL(gnet_stats_finish_copy);