You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
79 lines
2.1 KiB
79 lines
2.1 KiB
#pragma once |
|
|
|
#include <string> |
|
#include <memory> |
|
#include <array> |
|
#include <asio/ts/buffer.hpp> |
|
#include <asio/ts/internet.hpp> |
|
#include <asio/ts/io_context.hpp> |
|
#include <asio/ts/net.hpp> |
|
|
|
#include "dvlnet/packet.h" |
|
#include "dvlnet/abstract_net.h" |
|
#include "dvlnet/frame_queue.h" |
|
|
|
namespace devilution { |
|
namespace net { |
|
|
|
class server_exception : public dvlnet_exception { |
|
public: |
|
const char *what() const throw() override |
|
{ |
|
return "Invalid player ID"; |
|
} |
|
}; |
|
|
|
class tcp_server { |
|
public: |
|
tcp_server(asio::io_context &ioc, const std::string &bindaddr, |
|
unsigned short port, std::string pw); |
|
std::string localhost_self(); |
|
void close(); |
|
virtual ~tcp_server(); |
|
|
|
private: |
|
static constexpr int timeout_connect = 30; |
|
static constexpr int timeout_active = 60; |
|
|
|
struct client_connection { |
|
frame_queue recv_queue; |
|
buffer_t recv_buffer = buffer_t(frame_queue::max_frame_size); |
|
plr_t plr = PLR_BROADCAST; |
|
asio::ip::tcp::socket socket; |
|
asio::steady_timer timer; |
|
int timeout; |
|
client_connection(asio::io_context &ioc) |
|
: socket(ioc) |
|
, timer(ioc) |
|
{ |
|
} |
|
}; |
|
|
|
typedef std::shared_ptr<client_connection> scc; |
|
|
|
asio::io_context &ioc; |
|
packet_factory pktfty; |
|
std::unique_ptr<asio::ip::tcp::acceptor> acceptor; |
|
std::array<scc, MAX_PLRS> connections; |
|
buffer_t game_init_info; |
|
|
|
scc make_connection(); |
|
plr_t next_free(); |
|
bool empty(); |
|
void start_accept(); |
|
void handle_accept(const scc &con, const asio::error_code &ec); |
|
void start_recv(const scc &con); |
|
void handle_recv(const scc &con, const asio::error_code &ec, size_t bytes_read); |
|
void handle_recv_newplr(const scc &con, packet &pkt); |
|
void handle_recv_packet(packet &pkt); |
|
void send_connect(const scc &con); |
|
void send_packet(packet &pkt); |
|
void start_send(const scc &con, packet &pkt); |
|
void handle_send(const scc &con, const asio::error_code &ec, size_t bytes_sent); |
|
void start_timeout(const scc &con); |
|
void handle_timeout(const scc &con, const asio::error_code &ec); |
|
void drop_connection(const scc &con); |
|
}; |
|
|
|
} //namespace net |
|
} //namespace devilution
|
|
|