blob: 0b759e6249e447e0c30de0540c4a5bb7583208bb (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
#include "NetworkClient.hpp"
NetworkClient::NetworkClient(std::string address, unsigned short port, std::string username, bool &quit)
: network(address, port), isRunning(quit) {
state = Handshaking;
PacketHandshake handshake;
handshake.protocolVersion = 335;
handshake.serverAddress = "127.0.0.1";
handshake.serverPort = 25565;
handshake.nextState = 2;
network.SendPacket(handshake);
state = Login;
PacketLoginStart loginStart;
loginStart.Username = "HelloOne";
network.SendPacket(loginStart);
auto response = std::static_pointer_cast<PacketLoginSuccess>(network.ReceivePacket(Login));
if (response->Username != username) {
throw std::logic_error("Received username is not sended username");
}
state = Play;
isActive = true;
std::thread thread(&NetworkClient::NetworkLoop, this);
std::swap(networkThread, thread);
}
NetworkClient::~NetworkClient() {
isActive = false;
networkThread.join();
}
std::shared_ptr<Packet> NetworkClient::ReceivePacket() {
if (toReceive.empty())
return std::shared_ptr<Packet>(nullptr);
toReceiveMutex.lock();
auto ret = toReceive.front();
toReceive.pop();
toReceiveMutex.unlock();
return ret;
}
void NetworkClient::SendPacket(std::shared_ptr<Packet> packet) {
toSendMutex.lock();
toSend.push(packet);
toSendMutex.unlock();
}
void NetworkClient::NetworkLoop() {
auto timeOfLastKeepAlivePacket = std::chrono::steady_clock::now();
el::Helpers::setThreadName("Network");
LOG(INFO) << "Network thread is started";
try {
while (isActive) {
toSendMutex.lock();
while (!toSend.empty()) {
if (toSend.front()!=nullptr)
network.SendPacket(*toSend.front());
toSend.pop();
}
toSendMutex.unlock();
auto packet = network.ReceivePacket(state);
if (packet.get() != nullptr) {
if (packet->GetPacketId() != PacketNamePlayCB::KeepAliveCB) {
toReceiveMutex.lock();
toReceive.push(packet);
toReceiveMutex.unlock();
} else {
timeOfLastKeepAlivePacket = std::chrono::steady_clock::now();
auto packetKeepAlive = std::static_pointer_cast<PacketKeepAliveCB>(packet);
auto packetKeepAliveSB = std::make_shared<PacketKeepAliveSB>(packetKeepAlive->KeepAliveId);
network.SendPacket(*packetKeepAliveSB);
}
}
using namespace std::chrono_literals;
if (std::chrono::steady_clock::now() - timeOfLastKeepAlivePacket > 20s) {
auto disconnectPacket = std::make_shared<PacketDisconnectPlay>();
disconnectPacket->Reason = "Timeout";
toReceiveMutex.lock();
toReceive.push(disconnectPacket);
toReceiveMutex.unlock();
break;
}
}
} catch (std::exception &e) {
LOG(ERROR) << "Exception catched in NetworkLoop: " << e.what();
isRunning = false;
}
LOG(INFO) << "Network thread is stopped";
}
|
