local_event.c 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115
  1. // SPDX-License-Identifier: GPL-2.0-or-later
  2. /* AF_RXRPC local endpoint management
  3. *
  4. * Copyright (C) 2007 Red Hat, Inc. All Rights Reserved.
  5. * Written by David Howells ([email protected])
  6. */
  7. #define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
  8. #include <linux/module.h>
  9. #include <linux/net.h>
  10. #include <linux/skbuff.h>
  11. #include <linux/slab.h>
  12. #include <net/sock.h>
  13. #include <net/af_rxrpc.h>
  14. #include <generated/utsrelease.h>
  15. #include "ar-internal.h"
  16. static const char rxrpc_version_string[65] = "linux-" UTS_RELEASE " AF_RXRPC";
  17. /*
  18. * Reply to a version request
  19. */
  20. static void rxrpc_send_version_request(struct rxrpc_local *local,
  21. struct rxrpc_host_header *hdr,
  22. struct sk_buff *skb)
  23. {
  24. struct rxrpc_wire_header whdr;
  25. struct rxrpc_skb_priv *sp = rxrpc_skb(skb);
  26. struct sockaddr_rxrpc srx;
  27. struct msghdr msg;
  28. struct kvec iov[2];
  29. size_t len;
  30. int ret;
  31. _enter("");
  32. if (rxrpc_extract_addr_from_skb(&srx, skb) < 0)
  33. return;
  34. msg.msg_name = &srx.transport;
  35. msg.msg_namelen = srx.transport_len;
  36. msg.msg_control = NULL;
  37. msg.msg_controllen = 0;
  38. msg.msg_flags = 0;
  39. whdr.epoch = htonl(sp->hdr.epoch);
  40. whdr.cid = htonl(sp->hdr.cid);
  41. whdr.callNumber = htonl(sp->hdr.callNumber);
  42. whdr.seq = 0;
  43. whdr.serial = 0;
  44. whdr.type = RXRPC_PACKET_TYPE_VERSION;
  45. whdr.flags = RXRPC_LAST_PACKET | (~hdr->flags & RXRPC_CLIENT_INITIATED);
  46. whdr.userStatus = 0;
  47. whdr.securityIndex = 0;
  48. whdr._rsvd = 0;
  49. whdr.serviceId = htons(sp->hdr.serviceId);
  50. iov[0].iov_base = &whdr;
  51. iov[0].iov_len = sizeof(whdr);
  52. iov[1].iov_base = (char *)rxrpc_version_string;
  53. iov[1].iov_len = sizeof(rxrpc_version_string);
  54. len = iov[0].iov_len + iov[1].iov_len;
  55. _proto("Tx VERSION (reply)");
  56. ret = kernel_sendmsg(local->socket, &msg, iov, 2, len);
  57. if (ret < 0)
  58. trace_rxrpc_tx_fail(local->debug_id, 0, ret,
  59. rxrpc_tx_point_version_reply);
  60. else
  61. trace_rxrpc_tx_packet(local->debug_id, &whdr,
  62. rxrpc_tx_point_version_reply);
  63. _leave("");
  64. }
  65. /*
  66. * Process event packets targeted at a local endpoint.
  67. */
  68. void rxrpc_process_local_events(struct rxrpc_local *local)
  69. {
  70. struct sk_buff *skb;
  71. char v;
  72. _enter("");
  73. skb = skb_dequeue(&local->event_queue);
  74. if (skb) {
  75. struct rxrpc_skb_priv *sp = rxrpc_skb(skb);
  76. rxrpc_see_skb(skb, rxrpc_skb_seen);
  77. _debug("{%d},{%u}", local->debug_id, sp->hdr.type);
  78. switch (sp->hdr.type) {
  79. case RXRPC_PACKET_TYPE_VERSION:
  80. if (skb_copy_bits(skb, sizeof(struct rxrpc_wire_header),
  81. &v, 1) < 0)
  82. return;
  83. _proto("Rx VERSION { %02x }", v);
  84. if (v == 0)
  85. rxrpc_send_version_request(local, &sp->hdr, skb);
  86. break;
  87. default:
  88. /* Just ignore anything we don't understand */
  89. break;
  90. }
  91. rxrpc_free_skb(skb, rxrpc_skb_freed);
  92. }
  93. _leave("");
  94. }