chore(udp): rename ReceiveMetadata to RxMetadata

Signed-off-by: Max SCHMELLER <[email protected]>
tier4 · Dec 13, 2024 · ed904bd · ed904bd
1 parent 11ed243
commit ed904bd
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 7 deletions.
diff --git a/...w_interfaces/include/nebula_hw_interfaces/nebula_hw_interfaces_common/connections/udp.hpp b/...w_interfaces/include/nebula_hw_interfaces/nebula_hw_interfaces_common/connections/udp.hpp
@@ -115,14 +115,14 @@ class UdpSocket
   static constexpr std::string_view broadcast_ip{"255.255.255.255"};
 
 public:
-  struct ReceiveMetadata
+  struct RxMetadata
   {
     std::optional<uint64_t> timestamp_ns;
     uint64_t drops_since_last_receive{0};
     bool truncated;
   };
 
-  using callback_t = std::function<void(const std::vector<uint8_t> &, const ReceiveMetadata &)>;
+  using callback_t = std::function<void(const std::vector<uint8_t> &, const RxMetadata &)>;
 
   /**
    * @brief Construct a UDP socket with timestamp measuring enabled. The minimal way to start
@@ -329,7 +329,7 @@ class UdpSocket
 
         if (!is_accepted_sender(msg_header.sender_addr)) continue;
 
-        ReceiveMetadata metadata;
+        RxMetadata metadata;
         get_receive_metadata(msg_header.msg, metadata);
         metadata.truncated = untruncated_packet_length > buffer_size_;
 
@@ -339,7 +339,7 @@ class UdpSocket
     });
   }
 
-  void get_receive_metadata(msghdr & msg, ReceiveMetadata & inout_metadata)
+  void get_receive_metadata(msghdr & msg, RxMetadata & inout_metadata)
   {
     for (cmsghdr * cmsg = CMSG_FIRSTHDR(&msg); cmsg != nullptr; cmsg = CMSG_NXTHDR(&msg, cmsg)) {
       if (cmsg->cmsg_level != SOL_SOCKET) continue;

diff --git a/nebula_hw_interfaces/test/common/test_udp/utils.hpp b/nebula_hw_interfaces/test/common/test_udp/utils.hpp
@@ -55,14 +55,13 @@ std::optional<int> udp_send(
 }
 
 template <typename _T, typename _R>
-std::optional<
-  std::pair<std::vector<uint8_t>, nebula::drivers::connections::UdpSocket::ReceiveMetadata>>
+std::optional<std::pair<std::vector<uint8_t>, nebula::drivers::connections::UdpSocket::RxMetadata>>
 receive_once(nebula::drivers::connections::UdpSocket & sock, std::chrono::duration<_T, _R> timeout)
 {
   std::condition_variable cv_received_result;
   std::mutex mtx_result;
   std::optional<
-    std::pair<std::vector<uint8_t>, nebula::drivers::connections::UdpSocket::ReceiveMetadata>>
+    std::pair<std::vector<uint8_t>, nebula::drivers::connections::UdpSocket::RxMetadata>>
     result;
 
   sock.subscribe([&](const auto & data, const auto & metadata) {