summaryrefslogtreecommitdiff
path: root/src/server.cpp
diff options
context:
space:
mode:
authorlittleblack111 <littleblack11111@gmail.com>2025-05-31 16:09:30 +0800
committerlittleblack111 <littleblack11111@gmail.com>2025-05-31 16:09:30 +0800
commitf1a152c02b34979a27316a024f2f1450b9d1c278 (patch)
treedd99f04c6cd9417a37d2cc8a4eb0c0c701090a96 /src/server.cpp
parent404b6c7c74fd1eecb54b63e13073b4a093a475b0 (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.cpp17
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;
}