diff options
| author | littleblack111 <littleblack11111@gmail.com> | 2025-05-31 16:09:30 +0800 |
|---|---|---|
| committer | littleblack111 <littleblack11111@gmail.com> | 2025-05-31 16:09:30 +0800 |
| commit | f1a152c02b34979a27316a024f2f1450b9d1c278 (patch) | |
| tree | dd99f04c6cd9417a37d2cc8a4eb0c0c701090a96 /src/server.cpp | |
| parent | 404b6c7c74fd1eecb54b63e13073b4a093a475b0 (diff) | |
internal: all CFileDescriptor is now wrapped in shared_ptr
shared_ptr operations are atomic
good for multi threading
Diffstat (limited to 'src/server.cpp')
| -rw-r--r-- | src/server.cpp | 17 |
1 files changed, 9 insertions, 8 deletions
diff --git a/src/server.cpp b/src/server.cpp index 9b5dae0..db92481 100644 --- a/src/server.cpp +++ b/src/server.cpp @@ -1,27 +1,28 @@ #include "server.hpp" #include "log.hpp" #include <cstring> +#include <memory> #include <sys/socket.h> CServer::CServer(uint16_t port) - : m_sockfd(CFileDescriptor{socket(AF_INET, SOCK_STREAM, 0)}) { - if (!m_sockfd.isValid()) + : m_sockfd(std::make_shared<CFileDescriptor>(socket(AF_INET, SOCK_STREAM, 0))) { + if (!m_sockfd->isValid()) throw std::runtime_error("Failed to create socket"); constexpr int opt = 1; constexpr int size = sizeof(opt); - if (setsockopt(m_sockfd.get(), SOL_SOCKET, SO_REUSEADDR, &opt, size) < 0) + if (setsockopt(m_sockfd->get(), SOL_SOCKET, SO_REUSEADDR, &opt, size) < 0) log(stderr, WARN, "setsockopt(SO_REUSEADDR) failed"); - if (setsockopt(m_sockfd.get(), SOL_SOCKET, SO_KEEPALIVE, &opt, size) < 0) + if (setsockopt(m_sockfd->get(), SOL_SOCKET, SO_KEEPALIVE, &opt, size) < 0) log(stderr, WARN, "setsockopt(SO_KEEPALIVE) failed"); memset(&m_addr, 0, sizeof(m_addr)); m_addr.sin_family = AF_INET; m_addr.sin_port = htons(port); m_addr.sin_addr.s_addr = INADDR_ANY; - bind(m_sockfd.get(), reinterpret_cast<sockaddr *>(&m_addr), sizeof(m_addr)) || - listen(m_sockfd.get(), 5) + bind(m_sockfd->get(), reinterpret_cast<sockaddr *>(&m_addr), sizeof(m_addr)) || + listen(m_sockfd->get(), 5) ? throw std::runtime_error("Failed to bind or listen") : log(LOG, "Server started on port: {}", port); @@ -33,6 +34,6 @@ CServer::~CServer() { log(SYS, "Server: bye"); } -const CFileDescriptor *CServer::getSocket() const { - return &m_sockfd; +std::shared_ptr<CFileDescriptor> CServer::getSocket() const { + return m_sockfd; } |
