rmnet_map_command.c 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102
  1. // SPDX-License-Identifier: GPL-2.0-only
  2. /* Copyright (c) 2013-2018, The Linux Foundation. All rights reserved.
  3. */
  4. #include <linux/netdevice.h>
  5. #include "rmnet_config.h"
  6. #include "rmnet_map.h"
  7. #include "rmnet_private.h"
  8. #include "rmnet_vnd.h"
  9. static u8 rmnet_map_do_flow_control(struct sk_buff *skb,
  10. struct rmnet_port *port,
  11. int enable)
  12. {
  13. struct rmnet_map_header *map_header = (void *)skb->data;
  14. struct rmnet_endpoint *ep;
  15. struct net_device *vnd;
  16. u8 mux_id;
  17. int r;
  18. mux_id = map_header->mux_id;
  19. if (mux_id >= RMNET_MAX_LOGICAL_EP) {
  20. kfree_skb(skb);
  21. return RX_HANDLER_CONSUMED;
  22. }
  23. ep = rmnet_get_endpoint(port, mux_id);
  24. if (!ep) {
  25. kfree_skb(skb);
  26. return RX_HANDLER_CONSUMED;
  27. }
  28. vnd = ep->egress_dev;
  29. /* Ignore the ip family and pass the sequence number for both v4 and v6
  30. * sequence. User space does not support creating dedicated flows for
  31. * the 2 protocols
  32. */
  33. r = rmnet_vnd_do_flow_control(vnd, enable);
  34. if (r) {
  35. kfree_skb(skb);
  36. return RMNET_MAP_COMMAND_UNSUPPORTED;
  37. } else {
  38. return RMNET_MAP_COMMAND_ACK;
  39. }
  40. }
  41. static void rmnet_map_send_ack(struct sk_buff *skb,
  42. unsigned char type,
  43. struct rmnet_port *port)
  44. {
  45. struct rmnet_map_header *map_header = (void *)skb->data;
  46. struct rmnet_map_control_command *cmd;
  47. struct net_device *dev = skb->dev;
  48. if (port->data_format & RMNET_FLAGS_INGRESS_MAP_CKSUMV4)
  49. skb_trim(skb,
  50. skb->len - sizeof(struct rmnet_map_dl_csum_trailer));
  51. skb->protocol = htons(ETH_P_MAP);
  52. /* Command data immediately follows the MAP header */
  53. cmd = (struct rmnet_map_control_command *)(map_header + 1);
  54. cmd->cmd_type = type & 0x03;
  55. netif_tx_lock(dev);
  56. dev->netdev_ops->ndo_start_xmit(skb, dev);
  57. netif_tx_unlock(dev);
  58. }
  59. /* Process MAP command frame and send N/ACK message as appropriate. Message cmd
  60. * name is decoded here and appropriate handler is called.
  61. */
  62. void rmnet_map_command(struct sk_buff *skb, struct rmnet_port *port)
  63. {
  64. struct rmnet_map_header *map_header = (void *)skb->data;
  65. struct rmnet_map_control_command *cmd;
  66. unsigned char command_name;
  67. unsigned char rc = 0;
  68. /* Command data immediately follows the MAP header */
  69. cmd = (struct rmnet_map_control_command *)(map_header + 1);
  70. command_name = cmd->command_name;
  71. switch (command_name) {
  72. case RMNET_MAP_COMMAND_FLOW_ENABLE:
  73. rc = rmnet_map_do_flow_control(skb, port, 1);
  74. break;
  75. case RMNET_MAP_COMMAND_FLOW_DISABLE:
  76. rc = rmnet_map_do_flow_control(skb, port, 0);
  77. break;
  78. default:
  79. rc = RMNET_MAP_COMMAND_UNSUPPORTED;
  80. kfree_skb(skb);
  81. break;
  82. }
  83. if (rc == RMNET_MAP_COMMAND_ACK)
  84. rmnet_map_send_ack(skb, rc, port);
  85. }