-
Notifications
You must be signed in to change notification settings - Fork 0
/
multiplayerclient.cpp
81 lines (71 loc) · 2.44 KB
/
multiplayerclient.cpp
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
#include "multiplayerclient.h"
#include "multiplayerpacket.h"
#include "game.h"
MultiplayerClient::MultiplayerClient(Game *game, Player *player, QObject *parent) :
QTcpSocket(parent),
m_game(game),
m_player(player),
m_packetSize(0)
{
connect(this, SIGNAL(connected()), SLOT(socket_connected()));
connect(this, SIGNAL(disconnected()), SLOT(socket_disconnected()));
connect(this, SIGNAL(readyRead()), SLOT(socket_readyRead()));
connect(this, SIGNAL(error(QAbstractSocket::SocketError)), SLOT(socket_error(QAbstractSocket::SocketError)));
}
void MultiplayerClient::socket_connected()
{
#ifdef MULTIPLAYERCLIENT_DEBUG
qDebug("MultiplayerClient::socket_connected()");
#endif
}
void MultiplayerClient::socket_disconnected()
{
#ifdef MULTIPLAYERCLIENT_DEBUG
qDebug("MultiplayerClient::socket_disconnected()");
#endif
}
void MultiplayerClient::socket_readyRead()
{
#ifdef MULTIPLAYERCLIENT_DEBUG
qDebug("MultiplayerClient::socket_readyRead(): %li bytes available", (long)bytesAvailable());
#endif
QDataStream in(this);
in.setVersion(QDataStream::Qt_4_8);
while (bytesAvailable() > 0) {
if (m_packetSize == 0) {
if (bytesAvailable() < (int)sizeof(quint32)) // packet size
return;
in >> m_packetSize;
}
if (bytesAvailable() < m_packetSize)
return;
m_packetSize = 0; // reset packet size
// read packet type
qint32 packetType; // MultiplayerPacket::PacketType value
in >> packetType;
#ifdef MULTIPLAYERCLIENT_DEBUG
qDebug("PacketType %i (%s)", packetType, qPrintable(MultiplayerPacket::typeString((MultiplayerPacket::PacketType)packetType)));
#endif
// read and handle packet data
switch ((MultiplayerPacket::PacketType)packetType) {
case MultiplayerPacket::ConnectionAccepted: {
MultiplayerPacket packet(MultiplayerPacket::PlayerJoin);
packet.stream() << *m_player;
packet.send(this);
break;
}
case MultiplayerPacket::ConnectionRefused:
// TODO
break;
default:
qWarning("MultiplayerClient::socket_readyRead(): Illegal PacketType %i", packetType);
return;
}
}
}
void MultiplayerClient::socket_error(QAbstractSocket::SocketError error)
{
#ifdef MULTIPLAYERCLIENT_DEBUG
qDebug("MultiplayerClient::socket_error(%i) => %s", error, qPrintable(errorString()));
#endif
}