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
|
#ifndef MESSAGESERVER_H
#define MESSAGESERVER_H
#include <QTcpServer>
#include <QTcpSocket>
#include <QAbstractSocket>
#include <QScopedPointer>
#include <QList>
#include "Message.h"
class Client;
class MessageServer : public QTcpServer
{
Q_OBJECT
public:
explicit MessageServer(QObject *parent = 0);
virtual ~MessageServer();
protected:
int activeConnections();
void pruneConnections();
void incomingConnection(qintptr handle);
signals:
void message(Message const &message);
void error (QString const&) const;
public slots:
void setServer(QString host, quint16 port=2442);
void setPause(bool paused);
bool start();
void stop();
void setMaxConnections(int n);
void setServerHost(const QString &host){ setServer(host, m_port); }
void setServerPort(quint16 port){ setServer(m_host, port); }
void send(Message const &message);
private:
bool m_paused;
QString m_host;
quint16 m_port;
int m_maxConnections;
QList<Client*> m_clients;
};
class Client : public QObject
{
Q_OBJECT
public:
explicit Client(MessageServer *server, QObject *parent = 0);
bool isConnected() const { return m_connected; }
void setSocket(qintptr handle);
void send(const Message &message);
void close();
bool awaitingResponse(int id){
return id <= 0 || m_requests.contains(id);
}
signals:
public slots:
void setConnected(bool connected);
void onDisconnected();
void readyRead();
private:
QMap<int, Message> m_requests;
MessageServer * m_server;
QTcpSocket * m_socket;
bool m_connected;
};
#endif // MESSAGESERVER_H
|
