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
|
/*
* SPDX-FileCopyrightText: 2017 Aleix Pol Gonzalez <aleixpol@blue-systems.com>
*
* SPDX-License-Identifier: GPL-2.0-only OR GPL-3.0-only OR LicenseRef-KDE-Accepted-GPL
*/
#include "PKResolveTransaction.h"
#include "PackageKitBackend.h"
#include <PackageKit/Daemon>
#include <QDebug>
PKResolveTransaction::PKResolveTransaction(PackageKitBackend *backend)
: m_backend(backend)
{
m_floodTimer.setInterval(1000);
m_floodTimer.setSingleShot(true);
connect(&m_floodTimer, &QTimer::timeout, this, &PKResolveTransaction::start);
}
void PKResolveTransaction::start()
{
Q_EMIT started();
PackageKit::Transaction *tArch = PackageKit::Daemon::resolve(m_packageNames, PackageKit::Transaction::FilterArch);
connect(tArch, &PackageKit::Transaction::package, m_backend, &PackageKitBackend::addPackageArch);
connect(tArch, &PackageKit::Transaction::errorCode, m_backend, &PackageKitBackend::transactionError);
PackageKit::Transaction *tNotArch = PackageKit::Daemon::resolve(m_packageNames, PackageKit::Transaction::FilterNotArch);
connect(tNotArch, &PackageKit::Transaction::package, m_backend, &PackageKitBackend::addPackageNotArch);
connect(tNotArch, &PackageKit::Transaction::errorCode, m_backend, &PackageKitBackend::transactionError);
m_transactions = {tArch, tNotArch};
for (auto transaction : std::as_const(m_transactions)) {
connect(transaction, &PackageKit::Transaction::finished, this, &PKResolveTransaction::transactionFinished);
}
}
void PKResolveTransaction::transactionFinished(PackageKit::Transaction::Exit exit)
{
auto transaction = qobject_cast<PackageKit::Transaction *>(sender());
if (exit != PackageKit::Transaction::ExitSuccess) {
qWarning() << "failed" << exit << transaction;
}
m_transactions.removeAll(transaction);
if (m_transactions.isEmpty()) {
Q_EMIT allFinished();
deleteLater();
}
}
void PKResolveTransaction::addPackageNames(const QStringList &packageNames)
{
m_packageNames += packageNames;
m_packageNames.removeDuplicates();
m_floodTimer.start();
}
#include "moc_PKResolveTransaction.cpp"
|
