Qt-Examples/src/ReactorServer/reactorserver.cc at master · RealChuan/Qt-Examples · GitHub

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
#include "reactorserver.hpp"
#include "accepterthread.hpp"

#include <QDebug>

class ReactorServer::ReactorServerPrivate
{
public:
    explicit ReactorServerPrivate(ReactorServer *q)
        : q_ptr(q)
    {}

    ReactorServer *q_ptr;

    AccepterThread *accepter;
};

ReactorServer::ReactorServer(quint16 port, int threadCount, QObject *parent)
    : QObject(parent)
    , d_ptr(new ReactorServerPrivate(this))
{
    d_ptr->accepter = new AccepterThread(port, threadCount, this);
    connect(d_ptr->accepter, &AccepterThread::message, this, &ReactorServer::message);
    connect(d_ptr->accepter,
            &AccepterThread::clientCountChanged,
            this,
            &ReactorServer::clientCountChanged);
    connect(d_ptr->accepter, &AccepterThread::maxClientCount, this, &ReactorServer::maxClientCount);
}

ReactorServer::~ReactorServer()
{
    stop();
}

void ReactorServer::setCallbacks(const ConnectionCallbacks &callbacks)
{
    d_ptr->accepter->setCallbacks(callbacks);
}

void ReactorServer::start()
{
    if (d_ptr->accepter->isRunning()) {
        return;
    }

    d_ptr->accepter->start();
    emit message(tr("ReactorServer started"));
}

void ReactorServer::stop()
{
    if (!d_ptr->accepter->isRunning()) {
        return;
    }

    d_ptr->accepter->quit();
    d_ptr->accepter->wait();
    emit message(tr("ReactorServer stopped"));
}

bool ReactorServer::isRunning() const
{
    return d_ptr->accepter->isRunning();
}