From 1c91b7a1d7f28da6dc476c87ddd0e94a38a62dcb Mon Sep 17 00:00:00 2001 From: Andreas Tsouchlos Date: Sat, 19 Apr 2025 14:12:16 +0200 Subject: [PATCH] Code style --- src/tcp.cpp | 10 ++++++---- src/tcp.hpp | 31 +++++++++++-------------------- 2 files changed, 17 insertions(+), 24 deletions(-) diff --git a/src/tcp.cpp b/src/tcp.cpp index 0071ad8..24bce00 100644 --- a/src/tcp.cpp +++ b/src/tcp.cpp @@ -102,8 +102,10 @@ bool NonBlockingServer::next_client_available() { [[nodiscard]] std::expected NonBlockingServer::accept_next_client() { disconnect(); + socklen_t clientAddrLen = sizeof(m_clientAddress); + int result = ::accept(m_serverSocket, (struct sockaddr*)&m_clientAddress, - &m_clientAddrLen); + &clientAddrLen); if (result < 0) return std::unexpected{errno}; m_clientSocket = result; @@ -256,7 +258,7 @@ NonBlockingClient::~NonBlockingClient() { } [[nodiscard]] std::expected -NonBlockingClient::connect(HostString host, uint16_t port) { +NonBlockingClient::connect(const HostString& host, uint16_t port) { /// Resolve host auto addrRes = resolve_remote_address(host.data(), port); @@ -292,7 +294,7 @@ NonBlockingClient::get_last_connection_status() { /// Check if connect operation has been completed - auto pendingOpRes = new_error_codes_available(); + auto pendingOpRes = socket_has_new_output_event(); if (!pendingOpRes) return std::unexpected{pendingOpRes.error()}; if (!pendingOpRes.value()) return EINPROGRESS; @@ -418,7 +420,7 @@ void NonBlockingClient::close_socket() { } [[nodiscard]] std::expected -NonBlockingClient::new_error_codes_available() { +NonBlockingClient::socket_has_new_output_event() { int ret = poll(&m_pfdOut, 1, 0); if (ret < 0) { spdlog::error("tcp::NonBlockingClient: poll() failed with errno={}", diff --git a/src/tcp.hpp b/src/tcp.hpp index 32a7e47..b2dd51e 100644 --- a/src/tcp.hpp +++ b/src/tcp.hpp @@ -41,29 +41,22 @@ public: [[nodiscard]] std::expected accept_next_client(); void disconnect(); - [[nodiscard]] std::expected - send(std::span data); - - [[nodiscard]] std::expected - recv(std::span buffer); - - bool data_available(); - [[nodiscard]] std::expected, int> get_client_ip_as_string(); + bool data_available(); + + [[nodiscard]] std::expected send(std::span data); + [[nodiscard]] std::expected recv(std::span buffer); + private: - ServerSettings m_settings; - const struct sockaddr_in m_serverAddress; - int m_serverSocket = -1; + int m_serverSocket = -1; pollfd m_serverPfdIn = {.fd = -1, .events = POLLIN}; pollfd m_clientPfdIn = {.fd = -1, .events = POLLIN}; - int m_clientSocket = -1; - struct sockaddr m_clientAddress; - socklen_t m_clientAddrLen = sizeof(m_clientAddress); - + int m_clientSocket = -1; + struct sockaddr m_clientAddress = {0}; [[nodiscard]] std::expected create_socket(); void close_server_socket(); @@ -87,10 +80,8 @@ public: NonBlockingClient& operator=(NonBlockingClient&&) = delete; ~NonBlockingClient(); - // clang-format off - [[nodiscard]] std::expected - connect(HostString host, uint16_t port); - // clang-format on + [[nodiscard]] std::expected connect(const HostString& host, + uint16_t port); void disconnect(); @@ -112,7 +103,7 @@ private: void close_socket(); [[nodiscard]] std::expected create_socket(); - [[nodiscard]] std::expected new_error_codes_available(); + [[nodiscard]] std::expected socket_has_new_output_event(); };