eu07/maszyna
17
0
Fork 0
mirror of https://github.com/MaSzyna-EU07/maszyna.git synced 2026-10-31 16:59:06 +01:00
Code Issues 156 Wiki Activity

pch migration to modules [wip]

Browse Source
This commit is contained in:
maj00r
2026-09-09 20:35:26 +02:00
parent c3007e3237
commit 3f7960aad5
350 changed files with 5958 additions and 3059 deletions
Download Patch File Download Diff File Expand all files Collapse all files

114
network/backend/asio.cpp → network/backend/asio.cppm
View File

@@ -1,7 +1,113 @@
#include "stdafx.h"
#include "network/backend/asio.h"
#include "scene/sn_utils.h"
#include "utilities/Logs.h"
module;
#define ASIO_DISABLE_VISIBILITY
#include <asio.hpp>
#include <cstdint>
#include <cstddef>
#include <functional>
#include <memory>
#include <ostream>
#include <sstream>
#include <string>
#include <vector>
export module eu07.network.backend.asio;
import eu07.network.message;
import eu07.network.network;
import eu07.gl.buffer;
import eu07.rendering.geometrybank;
import eu07.scene.sn_utils;
import eu07.utilities.logs;
export {
#ifdef DBG_NEW
#undef new
#endif
namespace network::tcp
{
const uint32_t NETWORK_MAGIC = 0x37305545;
const uint32_t MAX_MSG_SIZE = 100000;
class connection : public network::connection
{
friend class server;
friend class client;
public:
connection(asio::io_context &io_ctx, bool client = false, size_t counter = 0);
~connection();
virtual void connected() override;
virtual void disconnect() override;
virtual void send_messages(const std::vector<std::shared_ptr<message> > &messages) override;
virtual void send_message(const message &msg) override;
asio::ip::tcp::socket m_socket;
private:
std::string m_header_buffer;
std::string m_body_buffer;
void write_message(const message &msg, std::ostream &stream);
void send_data(std::shared_ptr<std::string> buffer);
void read_header();
void handle_header(const asio::error_code &err, size_t bytes_transferred);
void handle_data(const asio::error_code &err, size_t bytes_transferred);
};
class server : public network::server
{
private:
void accept_conn();
void handle_accept(std::shared_ptr<connection> conn, const asio::error_code &err);
asio::ip::tcp::acceptor m_acceptor;
asio::io_context &m_io_ctx;
public:
server(std::shared_ptr<std::istream> buf, asio::io_context &io_ctx, const std::string &host, uint32_t port);
};
class client : public network::client
{
private:
void handle_accept(const asio::error_code &err);
asio::io_context &io_ctx;
std::string host;
uint32_t port;
protected:
virtual void connect() override;
public:
client(asio::io_context &io_ctx, const std::string &host, uint32_t port);
};
class asio_manager : public network::backend_manager {
asio::io_context io_context;
public:
asio_manager();
virtual std::shared_ptr<network::server> create_server(std::shared_ptr<std::fstream>, const std::string &conf) override;
virtual std::shared_ptr<network::client> create_client(const std::string &conf) override;
virtual void update() override;
};
asio_manager manager;
}
} // export
// The implementation lives here rather than in a separate implementation unit:
// asio defines its customization points as objects in an anonymous namespace, and
// GCC emits those a second time in any implementation unit that also includes
// asio.hpp, which the assembler rejects as duplicate symbols. One translation unit
// including asio is the way around it.
network::tcp::connection::connection(asio::io_context &io_ctx, bool client, size_t counter)
: network::connection(client, counter),

82
network/backend/asio.h
View File

@@ -1,82 +0,0 @@
#ifdef DBG_NEW
#undef new
#endif
#define ASIO_DISABLE_VISIBILITY
#include <asio.hpp>
#include "network/network.h"
namespace network::tcp
{
const uint32_t NETWORK_MAGIC = 0x37305545;
const uint32_t MAX_MSG_SIZE = 100000;
class connection : public network::connection
{
friend class server;
friend class client;
public:
connection(asio::io_context &io_ctx, bool client = false, size_t counter = 0);
~connection();
virtual void connected() override;
virtual void disconnect() override;
virtual void send_messages(const std::vector<std::shared_ptr<message> > &messages) override;
virtual void send_message(const message &msg) override;
asio::ip::tcp::socket m_socket;
private:
std::string m_header_buffer;
std::string m_body_buffer;
void write_message(const message &msg, std::ostream &stream);
void send_data(std::shared_ptr<std::string> buffer);
void read_header();
void handle_header(const asio::error_code &err, size_t bytes_transferred);
void handle_data(const asio::error_code &err, size_t bytes_transferred);
};
class server : public network::server
{
private:
void accept_conn();
void handle_accept(std::shared_ptr<connection> conn, const asio::error_code &err);
asio::ip::tcp::acceptor m_acceptor;
asio::io_context &m_io_ctx;
public:
server(std::shared_ptr<std::istream> buf, asio::io_context &io_ctx, const std::string &host, uint32_t port);
};
class client : public network::client
{
private:
void handle_accept(const asio::error_code &err);
asio::io_context &io_ctx;
std::string host;
uint32_t port;
protected:
virtual void connect() override;
public:
client(asio::io_context &io_ctx, const std::string &host, uint32_t port);
};
class asio_manager : public network::backend_manager {
asio::io_context io_context;
public:
asio_manager();
virtual std::shared_ptr<network::server> create_server(std::shared_ptr<std::fstream>, const std::string &conf) override;
virtual std::shared_ptr<network::client> create_client(const std::string &conf) override;
virtual void update() override;
};
asio_manager manager;
}