linkstate.c 5.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227
  1. // SPDX-License-Identifier: GPL-2.0-only
  2. #include "netlink.h"
  3. #include "common.h"
  4. #include <linux/phy.h>
  5. #include <linux/phylib_stubs.h>
  6. struct linkstate_req_info {
  7. struct ethnl_req_info base;
  8. };
  9. struct linkstate_reply_data {
  10. struct ethnl_reply_data base;
  11. int link;
  12. int sqi;
  13. int sqi_max;
  14. struct ethtool_link_ext_stats link_stats;
  15. bool link_ext_state_provided;
  16. struct ethtool_link_ext_state_info ethtool_link_ext_state_info;
  17. };
  18. #define LINKSTATE_REPDATA(__reply_base) \
  19. container_of(__reply_base, struct linkstate_reply_data, base)
  20. const struct nla_policy ethnl_linkstate_get_policy[] = {
  21. [ETHTOOL_A_LINKSTATE_HEADER] =
  22. NLA_POLICY_NESTED(ethnl_header_policy_stats),
  23. };
  24. static int linkstate_get_sqi(struct phy_device *phydev)
  25. {
  26. int ret;
  27. if (!phydev)
  28. return -EOPNOTSUPP;
  29. mutex_lock(&phydev->lock);
  30. if (!phydev->drv || !phydev->drv->get_sqi)
  31. ret = -EOPNOTSUPP;
  32. else if (!phydev->link)
  33. ret = -ENETDOWN;
  34. else
  35. ret = phydev->drv->get_sqi(phydev);
  36. mutex_unlock(&phydev->lock);
  37. return ret;
  38. }
  39. static int linkstate_get_sqi_max(struct phy_device *phydev)
  40. {
  41. int ret;
  42. if (!phydev)
  43. return -EOPNOTSUPP;
  44. mutex_lock(&phydev->lock);
  45. if (!phydev->drv || !phydev->drv->get_sqi_max)
  46. ret = -EOPNOTSUPP;
  47. else if (!phydev->link)
  48. ret = -ENETDOWN;
  49. else
  50. ret = phydev->drv->get_sqi_max(phydev);
  51. mutex_unlock(&phydev->lock);
  52. return ret;
  53. };
  54. static bool linkstate_sqi_critical_error(int sqi)
  55. {
  56. return sqi < 0 && sqi != -EOPNOTSUPP && sqi != -ENETDOWN;
  57. }
  58. static bool linkstate_sqi_valid(struct linkstate_reply_data *data)
  59. {
  60. return data->sqi >= 0 && data->sqi_max >= 0 &&
  61. data->sqi <= data->sqi_max;
  62. }
  63. static int linkstate_get_link_ext_state(struct net_device *dev,
  64. struct linkstate_reply_data *data)
  65. {
  66. int err;
  67. if (!dev->ethtool_ops->get_link_ext_state)
  68. return -EOPNOTSUPP;
  69. err = dev->ethtool_ops->get_link_ext_state(dev, &data->ethtool_link_ext_state_info);
  70. if (err)
  71. return err;
  72. data->link_ext_state_provided = true;
  73. return 0;
  74. }
  75. static int linkstate_prepare_data(const struct ethnl_req_info *req_base,
  76. struct ethnl_reply_data *reply_base,
  77. const struct genl_info *info)
  78. {
  79. struct linkstate_reply_data *data = LINKSTATE_REPDATA(reply_base);
  80. struct net_device *dev = reply_base->dev;
  81. struct nlattr **tb = info->attrs;
  82. struct phy_device *phydev;
  83. int ret;
  84. phydev = ethnl_req_get_phydev(req_base, tb, ETHTOOL_A_LINKSTATE_HEADER,
  85. info->extack);
  86. if (IS_ERR(phydev)) {
  87. ret = PTR_ERR(phydev);
  88. goto out;
  89. }
  90. ret = ethnl_ops_begin(dev);
  91. if (ret < 0)
  92. return ret;
  93. data->link = __ethtool_get_link(dev);
  94. ret = linkstate_get_sqi(phydev);
  95. if (linkstate_sqi_critical_error(ret))
  96. goto out;
  97. data->sqi = ret;
  98. ret = linkstate_get_sqi_max(phydev);
  99. if (linkstate_sqi_critical_error(ret))
  100. goto out;
  101. data->sqi_max = ret;
  102. if (dev->flags & IFF_UP) {
  103. ret = linkstate_get_link_ext_state(dev, data);
  104. if (ret < 0 && ret != -EOPNOTSUPP && ret != -ENODATA)
  105. goto out;
  106. }
  107. ethtool_stats_init((u64 *)&data->link_stats,
  108. sizeof(data->link_stats) / 8);
  109. if (req_base->flags & ETHTOOL_FLAG_STATS) {
  110. if (phydev)
  111. phy_ethtool_get_link_ext_stats(phydev,
  112. &data->link_stats);
  113. if (dev->ethtool_ops->get_link_ext_stats)
  114. dev->ethtool_ops->get_link_ext_stats(dev,
  115. &data->link_stats);
  116. }
  117. ret = 0;
  118. out:
  119. ethnl_ops_complete(dev);
  120. return ret;
  121. }
  122. static int linkstate_reply_size(const struct ethnl_req_info *req_base,
  123. const struct ethnl_reply_data *reply_base)
  124. {
  125. struct linkstate_reply_data *data = LINKSTATE_REPDATA(reply_base);
  126. int len;
  127. len = nla_total_size(sizeof(u8)) /* LINKSTATE_LINK */
  128. + 0;
  129. if (linkstate_sqi_valid(data)) {
  130. len += nla_total_size(sizeof(u32)); /* LINKSTATE_SQI */
  131. len += nla_total_size(sizeof(u32)); /* LINKSTATE_SQI_MAX */
  132. }
  133. if (data->link_ext_state_provided)
  134. len += nla_total_size(sizeof(u8)); /* LINKSTATE_EXT_STATE */
  135. if (data->ethtool_link_ext_state_info.__link_ext_substate)
  136. len += nla_total_size(sizeof(u8)); /* LINKSTATE_EXT_SUBSTATE */
  137. if (data->link_stats.link_down_events != ETHTOOL_STAT_NOT_SET)
  138. len += nla_total_size(sizeof(u32));
  139. return len;
  140. }
  141. static int linkstate_fill_reply(struct sk_buff *skb,
  142. const struct ethnl_req_info *req_base,
  143. const struct ethnl_reply_data *reply_base)
  144. {
  145. struct linkstate_reply_data *data = LINKSTATE_REPDATA(reply_base);
  146. if (data->link >= 0 &&
  147. nla_put_u8(skb, ETHTOOL_A_LINKSTATE_LINK, !!data->link))
  148. return -EMSGSIZE;
  149. if (linkstate_sqi_valid(data)) {
  150. if (nla_put_u32(skb, ETHTOOL_A_LINKSTATE_SQI, data->sqi))
  151. return -EMSGSIZE;
  152. if (nla_put_u32(skb, ETHTOOL_A_LINKSTATE_SQI_MAX,
  153. data->sqi_max))
  154. return -EMSGSIZE;
  155. }
  156. if (data->link_ext_state_provided) {
  157. if (nla_put_u8(skb, ETHTOOL_A_LINKSTATE_EXT_STATE,
  158. data->ethtool_link_ext_state_info.link_ext_state))
  159. return -EMSGSIZE;
  160. if (data->ethtool_link_ext_state_info.__link_ext_substate &&
  161. nla_put_u8(skb, ETHTOOL_A_LINKSTATE_EXT_SUBSTATE,
  162. data->ethtool_link_ext_state_info.__link_ext_substate))
  163. return -EMSGSIZE;
  164. }
  165. if (data->link_stats.link_down_events != ETHTOOL_STAT_NOT_SET)
  166. if (nla_put_u32(skb, ETHTOOL_A_LINKSTATE_EXT_DOWN_CNT,
  167. data->link_stats.link_down_events))
  168. return -EMSGSIZE;
  169. return 0;
  170. }
  171. const struct ethnl_request_ops ethnl_linkstate_request_ops = {
  172. .request_cmd = ETHTOOL_MSG_LINKSTATE_GET,
  173. .reply_cmd = ETHTOOL_MSG_LINKSTATE_GET_REPLY,
  174. .hdr_attr = ETHTOOL_A_LINKSTATE_HEADER,
  175. .req_info_size = sizeof(struct linkstate_req_info),
  176. .reply_data_size = sizeof(struct linkstate_reply_data),
  177. .prepare_data = linkstate_prepare_data,
  178. .reply_size = linkstate_reply_size,
  179. .fill_reply = linkstate_fill_reply,
  180. };