From 377c86144221ffc5b49bdaa9b8dcc3507fe4a50f Mon Sep 17 00:00:00 2001 From: Christian Mollekopf Date: Mon, 30 Nov 2015 20:45:59 +0100 Subject: Fixed some warnings --- common/queryrunner.cpp | 18 +++--------------- 1 file changed, 3 insertions(+), 15 deletions(-) (limited to 'common/queryrunner.cpp') diff --git a/common/queryrunner.cpp b/common/queryrunner.cpp index e365cfc..9f6d23f 100644 --- a/common/queryrunner.cpp +++ b/common/queryrunner.cpp @@ -53,27 +53,17 @@ static inline ResultSet fullScan(const Akonadi2::Storage::Transaction &transacti template QueryRunner::QueryRunner(const Akonadi2::Query &query, const Akonadi2::ResourceAccessInterface::Ptr &resourceAccess, const QByteArray &instanceIdentifier, const DomainTypeAdaptorFactoryInterface::Ptr &factory, const QByteArray &bufferType) : QueryRunnerBase(), - mResourceAccess(resourceAccess), mResultProvider(new ResultProvider), + mResourceAccess(resourceAccess), mDomainTypeAdaptorFactory(factory), - mQuery(query), mResourceInstanceIdentifier(instanceIdentifier), - mBufferType(bufferType) + mBufferType(bufferType), + mQuery(query) { Trace() << "Starting query"; //We delegate loading of initial data to the result provider, os it can decide for itself what it needs to load. mResultProvider->setFetcher([this, query](const typename DomainType::Ptr &parent) { Trace() << "Running fetcher"; - - // auto watcher = new QFutureWatcher; - // QObject::connect(watcher, &QFutureWatcher::finished, [](qint64 newRevision) { - // mResourceAccess->sendRevisionReplayedCommand(newRevision); - // }); - // auto future = QtConcurrent::run([&resultProvider]() -> qint64 { - // const qint64 newRevision = executeInitialQuery(query, parent, resultProvider); - // return newRevision; - // }); - // watcher->setFuture(future); const qint64 newRevision = executeInitialQuery(query, parent, *mResultProvider); mResourceAccess->sendRevisionReplayedCommand(newRevision); }); @@ -109,11 +99,9 @@ typename Akonadi2::ResultEmitter::Ptr QueryRunneremitter(); } -//TODO move into result provider? template void QueryRunner::replaySet(ResultSet &resultSet, Akonadi2::ResultProviderInterface &resultProvider) { - // Trace() << "Replay set"; int counter = 0; while (resultSet.next([&resultProvider, &counter](const Akonadi2::ApplicationDomain::ApplicationDomainType::Ptr &value, Akonadi2::Operation operation) -> bool { counter++; -- cgit v1.2.3