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 "abstractprotobufoperation.h"
#include <QTimer>
#include "mainresponseinterface.h"
using namespace Flipper;
using namespace Zero;
AbstractProtobufOperation::AbstractProtobufOperation(uint32_t id, QObject *parent):
AbstractOperation(parent),
m_id(id)
{}
AbstractProtobufOperation::~AbstractProtobufOperation()
{}
uint32_t AbstractProtobufOperation::id() const
{
return m_id;
}
bool AbstractProtobufOperation::hasMoreData() const
{
// Default implementation for single-part operations
return false;
}
bool AbstractProtobufOperation::isFinished() const
{
return operationState() == AbstractOperation::Finished;
}
void AbstractProtobufOperation::start()
{
if(!begin()) {
// begin() has to fill the error() and errorString() fields
finishLater();
} else {
setOperationState(Started);
startTimeout();
}
}
void AbstractProtobufOperation::finishLater()
{
QTimer::singleShot(0, this, &AbstractOperation::finish);
}
void AbstractProtobufOperation::abort(const QString &reason)
{
finishWithError(BackendError::UnknownError, reason);
}
void AbstractProtobufOperation::feedResponse(QObject *response)
{
auto *mainResponse = qobject_cast<MainResponseInterface*>(response);
if(mainResponse->isError()) {
finishWithError(BackendError::ProtocolError, QStringLiteral("Device replied with error: %1").arg(mainResponse->errorString()));
} else if(!processResponse(response)) {
finishWithError(BackendError::ProtocolError, QStringLiteral("Operation finished with error: %1").arg(mainResponse->errorString()));
} else if(!mainResponse->hasNext()) {
finish();
} else {
startTimeout();
}
}
bool AbstractProtobufOperation::begin()
{
// Empty default implementation
return true;
}
bool AbstractProtobufOperation::processResponse(QObject *response)
{
// Default implementation, checks whether we got an empty response
// TODO: add isOk() check
return qobject_cast<EmptyResponseInterface*>(response);
}
|
