Open Tibia Server List
Grow your
Open Tibia server.
Reach new players
•
Build your community
•
Climb the rankings
net_connection.h
main 91 lines · 2.3 KB Raw
1
//////////////////////////////////////////////////////////////////////2
// This file is part of Remere's Map Editor3
//////////////////////////////////////////////////////////////////////4
// Remere's Map Editor is free software: you can redistribute it and/or modify5
// it under the terms of the GNU General Public License as published by6
// the Free Software Foundation, either version 3 of the License, or7
// (at your option) any later version.8
//9
// Remere's Map Editor is distributed in the hope that it will be useful,10
// but WITHOUT ANY WARRANTY; without even the implied warranty of11
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the12
// GNU General Public License for more details.13
//14
// You should have received a copy of the GNU General Public License15
// along with this program. If not, see <http://www.gnu.org/licenses/>.16
//////////////////////////////////////////////////////////////////////17
18
#ifndef _RME_NET_CONNECTION_H_19
#define _RME_NET_CONNECTION_H_20
21
#include "position.h"22
23
#include <string>24
#include <vector>25
#include <cstdint>26
#include <thread>27
#include <mutex>28
29
struct NetworkMessage {30
NetworkMessage();31
32
void clear();33
void expand(const size_t length);34
35
//36
template <typename T>37
T read() {38
// Check if we have enough data left to read39
if (position + sizeof(T) > buffer.size()) {40
throw std::runtime_error("Buffer underflow - attempted to read past buffer end");41
}42
T& value = *reinterpret_cast<T*>(&buffer[position]);43
position += sizeof(T);44
return value;45
}46
47
template <typename T>48
void write(const T& value) {49
expand(sizeof(T));50
memcpy(&buffer[position], &value, sizeof(T));51
position += sizeof(T);52
}53
54
//55
std::vector<uint8_t> buffer;56
size_t position;57
size_t size;58
};59
60
template <>61
std::string NetworkMessage::read<std::string>();62
template <>63
Position NetworkMessage::read<Position>();64
template <>65
void NetworkMessage::write<std::string>(const std::string& value);66
template <>67
void NetworkMessage::write<Position>(const Position& value);68
69
class NetworkConnection {70
private:71
NetworkConnection();72
NetworkConnection(const NetworkConnection& copy) = delete;73
74
public:75
~NetworkConnection();76
77
static NetworkConnection& getInstance();78
79
bool start();80
void stop();81
82
boost::asio::io_context& get_service();83
84
private:85
boost::asio::io_context* service;86
std::thread thread;87
bool stopped;88
};89
90
#endif91