From c0d10efabf3ffbce0bb41832ea1b270a627c520d Mon Sep 17 00:00:00 2001
From: gabime <gmelman1@gmail.com>
Date: Sun, 5 Sep 2021 16:35:11 +0300
Subject: [PATCH] Cleanup unix udp client

---
 include/spdlog/details/udp_client.h | 51 +++++++++++++++--------------
 1 file changed, 26 insertions(+), 25 deletions(-)

diff --git a/include/spdlog/details/udp_client.h b/include/spdlog/details/udp_client.h
index 661282cd..6d0919b6 100644
--- a/include/spdlog/details/udp_client.h
+++ b/include/spdlog/details/udp_client.h
@@ -3,11 +3,13 @@
 
 #pragma once
 
+// Helper RAII over unix udp client socket.
+// Will throw on construction if the socket creation failed.
+
 #ifdef _WIN32
-#error include udp_client-windows.h instead
+#    error "include udp_client-windows.h instead"
 #endif
 
-// udp client helper
 #include <spdlog/common.h>
 #include <spdlog/details/os.h>
 
@@ -24,41 +26,46 @@ namespace details {
 
 class udp_client
 {
-    const int TX_BUFFER_SIZE = 10240;
+    static constexpr int TX_BUFFER_SIZE = 1024 * 10;
     int socket_ = -1;
     struct sockaddr_in sockAddr_;
-public:
 
-    bool init(const std::string &host, uint16_t port)
+    
+    void cleanup_()
+    {
+        if (socket_ != -1)
+        {
+            ::close(socket_);
+            socket_ = -1;
+        }
+    }
+
+public:
+    udp_client(const std::string &host, uint16_t port)
     {
-        socket_ = socket(PF_INET, SOCK_DGRAM, 0);
+        socket_ = ::socket(PF_INET, SOCK_DGRAM, 0);
         if (socket_ < 0)
         {
             throw_spdlog_ex("error: Create Socket Failed!");
         }
 
         int option_value = TX_BUFFER_SIZE;
-        if (setsockopt(socket_, SOL_SOCKET, SO_SNDBUF, (char*)&option_value, sizeof(option_value)) < 0)
+        if (::setsockopt(socket_, SOL_SOCKET, SO_SNDBUF, reinterpret_cast<const char *>(&option_value), sizeof(option_value)) < 0)
         {
-            close();
+            cleanup_();
             throw_spdlog_ex("error: setsockopt(SO_SNDBUF) Failed!");
         }
 
         sockAddr_.sin_family = AF_INET;
         sockAddr_.sin_port = htons(port);
-        inet_aton(host.c_str(), &sockAddr_.sin_addr);
+        ::inet_aton(host.c_str(), &sockAddr_.sin_addr);
 
-        memset(sockAddr_.sin_zero, 0x00, sizeof(sockAddr_.sin_zero));
-        return true;
+        ::memset(sockAddr_.sin_zero, 0x00, sizeof(sockAddr_.sin_zero));
     }
 
-    void close()
+    ~udp_client()
     {
-        if (socket_ != -1)
-        {
-            ::close(socket_);
-            socket_ = -1;
-        }
+        cleanup_();
     }
 
     int fd() const
@@ -66,20 +73,14 @@ public:
         return socket_;
     }
 
-    ~udp_client()
-    {
-        close();
-    }
-
     // Send exactly n_bytes of the given data.
     // On error close the connection and throw.
     void send(const char *data, size_t n_bytes)
     {
         ssize_t toslen = 0;
         socklen_t tolen = sizeof(struct sockaddr);
-        if (( toslen = sendto(socket_, data, n_bytes, 0, (struct sockaddr *)&sockAddr_, tolen)) == -1)
-        {
-            close();
+        if ((toslen = ::sendto(socket_, data, n_bytes, 0, (struct sockaddr *)&sockAddr_, tolen)) == -1)
+        {            
             throw_spdlog_ex("sendto(2) failed", errno);
         }
     }