From 08688972ae56b474e2e2fd954c5caaeb1233a1be Mon Sep 17 00:00:00 2001 From: littleblack111 Date: Sun, 15 Jun 2025 13:59:30 +0800 Subject: init: server --- src/server/server.cpp | 38 ++++++++++++++++++++++++++++++++++++++ 1 file changed, 38 insertions(+) create mode 100644 src/server/server.cpp (limited to 'src/server/server.cpp') diff --git a/src/server/server.cpp b/src/server/server.cpp new file mode 100644 index 0000000..0692a74 --- /dev/null +++ b/src/server/server.cpp @@ -0,0 +1,38 @@ +#include "libsock/server/server.hpp" +#include "misc/memory.hpp" +#include +#include +#include + +using namespace LibSock::Server; + +Server::Server(uint16_t port, bool reuseaddr, bool keepalive) + : m_sockfd( + std::make_shared(socket(AF_INET, SOCK_STREAM, 0))) { + std::lock_guard lk(m_mutex); + if (!m_sockfd->isValid() || m_sockfd->get() < 0) + throw std::runtime_error("Failed to create socket"); + + constexpr int opt = 1; + constexpr int size = sizeof(opt); + if (keepalive && + setsockopt(m_sockfd->get(), SOL_SOCKET, SO_REUSEADDR, &opt, size) < 0) + throw std::runtime_error("setsockopt(SO_REUSEADDR) failed"); + + if (reuseaddr && + setsockopt(m_sockfd->get(), SOL_SOCKET, SO_KEEPALIVE, &opt, size) < 0) + throw std::runtime_error("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; + if (bind(m_sockfd->get(), reinterpret_cast(&m_addr), + sizeof(m_addr)) || + listen(m_sockfd->get(), 5)) + throw std::runtime_error("Failed to bind or listen on socket"); +}; + +Server::~Server() { m_sockfd.reset(); } + +std::shared_ptr Server::getSocket() const { return m_sockfd; } -- cgit v1.2.3