stratum-mining-util-proxy/apoolchecker.cpp at master · mezrin/stratum-mining-util-proxy · 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
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
#include <QtCore/QTimer>

#include <QtNetwork/QTcpSocket>

#include "apoolchecker.h"
#include "alogger.h"

// ========================================================================== //
// Конструктор.
// ========================================================================== //
APoolChecker::APoolChecker(QObject *parent)
    : QObject(parent), _socket(new QTcpSocket(this)), _timer(new QTimer(this)) {

    connect(_socket, SIGNAL(connected()), this, SLOT(onSocketConnected()));
    connect(_socket, SIGNAL(readyRead()), this, SLOT(onSocketReadyRead()));
    connect(_socket, SIGNAL(error(QAbstractSocket::SocketError))
        , this, SLOT(onSocketError()));

    _timer->setInterval(5000);
    _timer->setSingleShot(true);

    connect(_timer, SIGNAL(timeout()), this, SLOT(onTimerTimeout()));
}


// ========================================================================== //
// Слот проверки активности пула.
// ========================================================================== //
void APoolChecker::check(const QString &host, int port) {
    if(!host.isEmpty() && port > 0) {
        if(_socket->state() != QAbstractSocket::UnconnectedState)
            _socket->abort();

        return _socket->connectToHost(host, port);
    }

    emit failed();
}


// ========================================================================== //
// Слот установки интервала.
// ========================================================================== //
void APoolChecker::changeCheckingTimeout(int interval) {
    _timer->setInterval(interval*1000);
}


// ========================================================================== //
// Слот подключения сокета к хосту.
// ========================================================================== //
void APoolChecker::onSocketConnected() {
    QByteArray data;
    data.append("{");
    data.append("\"id\": 1");
    data.append(", \"method\": \"mining.subscribe\"");
    data.append(", \"params\": []");
    data.append("}\n");

    _socket->write(data); _timer->start();
}


// ========================================================================== //
// Слот приёма сетевых сообщений.
// ========================================================================== //
void APoolChecker::onSocketReadyRead() {
    _timer->stop(); _socket->disconnectFromHost(); emit succeed();
}


// ========================================================================== //
// Слот обработки ошибок сетевой передачи данных.
// ========================================================================== //
void APoolChecker::onSocketError() {
    _timer->stop(); _socket->abort();

    logWarn(_socket->errorString()); emit failed();
}


// ========================================================================== //
// Слот активации таймера.
// ========================================================================== //
void APoolChecker::onTimerTimeout() {
    logWarn(QString("pool %1:%2 freeze")
        .arg(_socket->peerName()).arg(_socket->peerPort()));

    _socket->abort(); emit failed();
}