From e12977bdc287bc2cdd5502ce8c50df4dd6c3ec0b Mon Sep 17 00:00:00 2001 From: Frederico Linhares Date: Thu, 20 Feb 2025 21:22:08 -0300 Subject: feat Code for networking --- src/blu_cat/net/server/server.hpp | 54 +++++++++++++++++++++++++++++++++++++++ 1 file changed, 54 insertions(+) create mode 100644 src/blu_cat/net/server/server.hpp (limited to 'src/blu_cat/net/server/server.hpp') diff --git a/src/blu_cat/net/server/server.hpp b/src/blu_cat/net/server/server.hpp new file mode 100644 index 0000000..271d75a --- /dev/null +++ b/src/blu_cat/net/server/server.hpp @@ -0,0 +1,54 @@ +/* + * Copyright 2022-2025 Frederico de Oliveira Linhares + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef BLU_CAT_SERVER_SERVER_H +#define BLU_CAT_SERVER_SERVER_H 1 + +#include "../common/connection.hpp" +#include "../common/connection_callback.hpp" +#include "../common/tsqueue.hpp" + +namespace BluCat::NET +{ + +class Server: public ConnectionCallback +{ + std::mutex mut; + asio::io_context io_context; + std::thread thread_context; + asio::ip::tcp::acceptor acceptor; + MessageCallback *(*callback_instantiator)(); + + TSQueue free_connection_slots; + std::vector connections; + + void + wait_for_client_connections(); + +public: + void + read_messages(); + + void + end_connection(unsigned long index); + + Server(MessageCallback *(*callback_instantiator)(), const uint16_t port); + ~Server(); +}; + +} + +#endif /* BLU_CAT_SERVER_SERVER_H */ -- cgit v1.2.3