appldata_net_sum.c 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167
  1. // SPDX-License-Identifier: GPL-2.0
  2. /*
  3. * Data gathering module for Linux-VM Monitor Stream, Stage 1.
  4. * Collects accumulated network statistics (Packets received/transmitted,
  5. * dropped, errors, ...).
  6. *
  7. * Copyright IBM Corp. 2003, 2006
  8. *
  9. * Author: Gerald Schaefer <gerald.schaefer@de.ibm.com>
  10. */
  11. #include <linux/module.h>
  12. #include <linux/init.h>
  13. #include <linux/errno.h>
  14. #include <linux/kernel_stat.h>
  15. #include <linux/netdevice.h>
  16. #include <net/net_namespace.h>
  17. #include "appldata.h"
  18. /*
  19. * Network data
  20. *
  21. * This is accessed as binary data by z/VM. If changes to it can't be avoided,
  22. * the structure version (product ID, see appldata_base.c) needs to be changed
  23. * as well and all documentation and z/VM applications using it must be updated.
  24. *
  25. * The record layout is documented in the Linux for zSeries Device Drivers
  26. * book:
  27. * http://oss.software.ibm.com/developerworks/opensource/linux390/index.shtml
  28. */
  29. struct appldata_net_sum_data {
  30. u64 timestamp;
  31. u32 sync_count_1; /* after VM collected the record data, */
  32. u32 sync_count_2; /* sync_count_1 and sync_count_2 should be the
  33. same. If not, the record has been updated on
  34. the Linux side while VM was collecting the
  35. (possibly corrupt) data */
  36. u32 nr_interfaces; /* nr. of network interfaces being monitored */
  37. u32 padding; /* next value is 64-bit aligned, so these */
  38. /* 4 byte would be padded out by compiler */
  39. u64 rx_packets; /* total packets received */
  40. u64 tx_packets; /* total packets transmitted */
  41. u64 rx_bytes; /* total bytes received */
  42. u64 tx_bytes; /* total bytes transmitted */
  43. u64 rx_errors; /* bad packets received */
  44. u64 tx_errors; /* packet transmit problems */
  45. u64 rx_dropped; /* no space in linux buffers */
  46. u64 tx_dropped; /* no space available in linux */
  47. u64 collisions; /* collisions while transmitting */
  48. } __packed;
  49. /*
  50. * appldata_get_net_sum_data()
  51. *
  52. * gather accumulated network statistics
  53. */
  54. static void appldata_get_net_sum_data(void *data)
  55. {
  56. int i;
  57. struct appldata_net_sum_data *net_data;
  58. struct net_device *dev;
  59. unsigned long rx_packets, tx_packets, rx_bytes, tx_bytes, rx_errors,
  60. tx_errors, rx_dropped, tx_dropped, collisions;
  61. net_data = data;
  62. net_data->sync_count_1++;
  63. i = 0;
  64. rx_packets = 0;
  65. tx_packets = 0;
  66. rx_bytes = 0;
  67. tx_bytes = 0;
  68. rx_errors = 0;
  69. tx_errors = 0;
  70. rx_dropped = 0;
  71. tx_dropped = 0;
  72. collisions = 0;
  73. rcu_read_lock();
  74. for_each_netdev_rcu(&init_net, dev) {
  75. const struct rtnl_link_stats64 *stats;
  76. struct rtnl_link_stats64 temp;
  77. stats = dev_get_stats(dev, &temp);
  78. rx_packets += stats->rx_packets;
  79. tx_packets += stats->tx_packets;
  80. rx_bytes += stats->rx_bytes;
  81. tx_bytes += stats->tx_bytes;
  82. rx_errors += stats->rx_errors;
  83. tx_errors += stats->tx_errors;
  84. rx_dropped += stats->rx_dropped;
  85. tx_dropped += stats->tx_dropped;
  86. collisions += stats->collisions;
  87. i++;
  88. }
  89. rcu_read_unlock();
  90. net_data->nr_interfaces = i;
  91. net_data->rx_packets = rx_packets;
  92. net_data->tx_packets = tx_packets;
  93. net_data->rx_bytes = rx_bytes;
  94. net_data->tx_bytes = tx_bytes;
  95. net_data->rx_errors = rx_errors;
  96. net_data->tx_errors = tx_errors;
  97. net_data->rx_dropped = rx_dropped;
  98. net_data->tx_dropped = tx_dropped;
  99. net_data->collisions = collisions;
  100. net_data->timestamp = get_tod_clock();
  101. net_data->sync_count_2++;
  102. }
  103. static struct appldata_ops ops = {
  104. .name = "net_sum",
  105. .record_nr = APPLDATA_RECORD_NET_SUM_ID,
  106. .size = sizeof(struct appldata_net_sum_data),
  107. .callback = &appldata_get_net_sum_data,
  108. .owner = THIS_MODULE,
  109. .mod_lvl = {0xF0, 0xF0}, /* EBCDIC "00" */
  110. };
  111. /*
  112. * appldata_net_init()
  113. *
  114. * init data, register ops
  115. */
  116. static int __init appldata_net_init(void)
  117. {
  118. int ret;
  119. ops.data = kzalloc(sizeof(struct appldata_net_sum_data), GFP_KERNEL);
  120. if (!ops.data)
  121. return -ENOMEM;
  122. ret = appldata_register_ops(&ops);
  123. if (ret)
  124. kfree(ops.data);
  125. return ret;
  126. }
  127. /*
  128. * appldata_net_exit()
  129. *
  130. * unregister ops
  131. */
  132. static void __exit appldata_net_exit(void)
  133. {
  134. appldata_unregister_ops(&ops);
  135. kfree(ops.data);
  136. }
  137. module_init(appldata_net_init);
  138. module_exit(appldata_net_exit);
  139. MODULE_LICENSE("GPL");
  140. MODULE_AUTHOR("Gerald Schaefer");
  141. MODULE_DESCRIPTION("Linux-VM Monitor Stream, accumulated network statistics");