~timo-jyrinki/unity-scope-mediascanner/manual_import_rtm_0.2+14.10.20141009-0ubuntu1

« back to all changes in this revision

Viewing changes to src/utils/resultforwarder.cpp

Committer: Timo Jyrinki
Date: 2014-10-29 14:28:38 UTC
Revision ID: timo.jyrinki@canonical.com-20141029142838-uveiptpvvs5yz0pe

Manual import of 0.2+14.10.20141009-0ubuntu1

files removed:
cmake

cmake/ClickBuild.cmake

cmake/ClickScope.cmake

cmake/Intltool.cmake

po/ca@valencia.po

po/cs.po

po/ms.po

src/musicaggregator

src/musicaggregator/CMakeLists.txt

src/musicaggregator/apparmor.json

src/musicaggregator/icon.png

src/musicaggregator/manifest.json.in

src/musicaggregator/musicaggregator-settings.ini.in

src/musicaggregator/musicaggregator.ini.in

src/musicaggregator/musicaggregatorquery.cpp

src/musicaggregator/musicaggregatorquery.h

src/musicaggregator/musicaggregatorscope.cpp

src/musicaggregator/musicaggregatorscope.h

src/musicaggregator/onlinemusicresultforwarder.cpp

src/musicaggregator/onlinemusicresultforwarder.h

src/musicaggregator/paper-white-bg-v2.png

src/musicaggregator/screenshot.jpg

src/mymusic

src/mymusic/CMakeLists.txt

src/mymusic/apparmor.json

src/mymusic/icon.png

src/mymusic/manifest.json.in

src/mymusic/mediascanner-music.ini.in

src/mymusic/music-scope.cpp

src/mymusic/music-scope.h

src/mymusic/screenshot.jpg

src/myvideos

src/myvideos/CMakeLists.txt

src/myvideos/apparmor.json

src/myvideos/icon.png

src/myvideos/manifest.json.in

src/myvideos/mediascanner-video.ini.in

src/myvideos/screenshot.jpg

src/myvideos/video-scope.cpp

src/myvideos/video-scope.h

src/utils

src/utils/CMakeLists.txt

src/utils/bufferedresultforwarder.cpp

src/utils/bufferedresultforwarder.h

src/utils/i18n.cpp

src/utils/i18n.h

src/utils/notify-strategy.cpp

src/utils/notify-strategy.h

src/utils/resultforwarder.cpp

src/utils/resultforwarder.h

src/videoaggregator

src/videoaggregator/CMakeLists.txt

src/videoaggregator/apparmor.json

src/videoaggregator/icon.png

src/videoaggregator/manifest.json.in

src/videoaggregator/paper-white-bg-v2.png

src/videoaggregator/screenshot.jpg

src/videoaggregator/videoaggregator-settings.ini.in

src/videoaggregator/videoaggregator.ini.in

src/videoaggregator/videoaggregatorquery.cpp

src/videoaggregator/videoaggregatorquery.h

src/videoaggregator/videoaggregatorscope.cpp

src/videoaggregator/videoaggregatorscope.h

files modified:
CMakeLists.txt

config.h.in

debian/changelog

po/CMakeLists.txt

po/am.po

po/ast.po

po/br.po

po/ca.po

po/de.po

po/en_AU.po

po/es.po

po/eu.po

po/fa.po

po/fr.po

po/gd.po

po/gl.po

po/hu.po

po/is.po

po/nb.po

po/nl.po

po/pt.po

po/ro.po

po/sl.po

po/ug.po

tests/CMakeLists.txt

tests/test-music-scope.cpp

tests/test-result-forwarder.cpp

tests/test-video-scope.cpp

Show diffs side-by-side

added added

removed removed

src/utils/resultforwarder.cpp

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License version 3 as

* published by the Free Software Foundation.

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <http://www.gnu.org/licenses/>.

* Authored by Jussi Pakkanen <jussi.pakkanen@canonical.com>

* Pawel Stolowski <pawel.stolowski@canonical.com>

#include "resultforwarder.h"

#include <unity/scopes/SearchReply.h>

using namespace unity::scopes;

void ResultForwarder::push(Category::SCPtr const& category) {

upstream->register_category(category);

}

void ResultForwarder::push(CategorisedResult result) {

{

if (result_filter(result))

{

upstream->push(result);

}

if (!ready_)

{

ready_ = notify_strategy_->is_ready(result);

if (ready_)

{

notify_observers();

}

void ResultForwarder::finished(unity::scopes::CompletionDetails const& /*details*/) {

if (!ready_)

{

ready_ = true;

notify_observers();

}

void ResultForwarder::notify_observers()

{

for (auto o: observers_)

{

o->on_forwarder_ready(this);

}

observers_.clear();

}

void ResultForwarder::add_observer(std::shared_ptr<ResultForwarder> result_forwarder)

{

if (result_forwarder.get() != this)

{

observers_.push_back(result_forwarder);

result_forwarder->wait_for_.push_back(this);

}

void ResultForwarder::on_forwarder_ready(ResultForwarder *fw)

{

// remove the forwarder that notified us from the wait_for_ list;

wait_for_.remove_if([fw](ResultForwarder* r) -> bool { return r == fw; });

if (wait_for_.size() == 0)

{

on_all_forwarders_ready();

}

void ResultForwarder::on_all_forwarders_ready()

{

// base impl does nothing

}

Older »