Merge lp:~marcustomlinson/unity-scopes-api/loop-prevention into lp:unity-scopes-api

[Marcus Tomlinson]

Added loop detection for subsearch(). If an aggregation loop is detected, the current subquery immediately finishes with a status of OK, but a message saying that a loop was found. This returns an empty results set for the subquery() that detected the loop to the client, while leaving other subqueries alone.

[PS Jenkins bot (ps-jenkins)]

PASSED: Continuous integration, rev:289
http://jenkins.qa.ubuntu.com/job/unity-scopes-api-ci/550/
Executed test runs:
    SUCCESS: http://jenkins.qa.ubuntu.com/job/unity-scopes-api-vivid-amd64-ci/77
    SUCCESS: http://jenkins.qa.ubuntu.com/job/unity-scopes-api-vivid-armhf-ci/75
        deb: http://jenkins.qa.ubuntu.com/job/unity-scopes-api-vivid-armhf-ci/75/artifact/work/output/*zip*/output.zip
    SUCCESS: http://jenkins.qa.ubuntu.com/job/unity-scopes-api-vivid-i386-ci/76

Click here to trigger a rebuild:
http://s-jenkins.ubuntu-ci:8080/job/unity-scopes-api-ci/550/rebuild

review: Approve (continuous-integration)

[Michi Henning (michihenning)]

Minor glitches:

+ [ Michi Henning ]
+ * Added utility subdir to header tests.
+ * Bunch of miscellaneous fixes:
+
+ [ James Henstridge ]

Looks like some text has gone missing here. It should be:

* Bunch of miscellaneous fixes:

- Added warning for non-virtual destructors.
- Warnings will disappear once Marcus's child_scopes branch is merged.
- Tidied up the way compiler flags are set in CMakeLists.txt for clarity.
- Added missing dependencies to demos, so we can't run with an out-of-date registry or scoperunner.
- Fixed a number of warnings when building the developer doc.
- Minor doc fixes.
- Minor stylistic code fixes.

My fault, typo in CONFIGFILES:

The value must be a semicolon-separate list of channel names.

Should be "semicolon-separated". When you fix the changelog could you throw that in too for me please?

Other than that, looks good, tests pass for me here, and looking through the changes doesn't show anything unusual.

- Added missing tmp_dir_initialized_ initializer to ScopeBaseImpl.
- Removed redundant lock in QueryCtrlImpl constructor.

review: Needs Fixing

[Michi Henning (michihenning)]

Oops, made an editing mistake earlier. Here is the correct changelog text:

* Bunch of miscellaneous fixes:

- Added warning for non-virtual destructors.
- Warnings will disappear once Marcus's child_scopes branch is merged.
- Tidied up the way compiler flags are set in CMakeLists.txt for clarity.
- Added missing dependencies to demos, so we can't run with an out-of-date registry or scoperunner.
- Fixed a number of warnings when building the developer doc.
- Minor doc fixes.
- Minor stylistic code fixes.
- Added missing tmp_dir_initialized_ initializer to ScopeBaseImpl.
- Removed redundant lock in QueryCtrlImpl constructor.

And, in CONFIGFILES, change "colon-seperate" to "colon-separated".

Apologies for the noise…

[Marcus Tomlinson (marcustomlinson)]

> Oops, made an editing mistake earlier. Here is the correct changelog text:
>
> * Bunch of miscellaneous fixes:
>
> - Added warning for non-virtual destructors.
> - Warnings will disappear once Marcus's child_scopes branch is merged.
> - Tidied up the way compiler flags are set in CMakeLists.txt for clarity.
> - Added missing dependencies to demos, so we can't run with an out-of-date
> registry or scoperunner.
> - Fixed a number of warnings when building the developer doc.
> - Minor doc fixes.
> - Minor stylistic code fixes.
> - Added missing tmp_dir_initialized_ initializer to ScopeBaseImpl.
> - Removed redundant lock in QueryCtrlImpl constructor.
>
> And, in CONFIGFILES, change "colon-seperate" to "colon-separated".
>
> Apologies for the noise…

done.

[PS Jenkins bot (ps-jenkins)]

PASSED: Continuous integration, rev:290
http://jenkins.qa.ubuntu.com/job/unity-scopes-api-ci/552/
Executed test runs:
    SUCCESS: http://jenkins.qa.ubuntu.com/job/unity-scopes-api-vivid-amd64-ci/79
    SUCCESS: http://jenkins.qa.ubuntu.com/job/unity-scopes-api-vivid-armhf-ci/77
        deb: http://jenkins.qa.ubuntu.com/job/unity-scopes-api-vivid-armhf-ci/77/artifact/work/output/*zip*/output.zip
    SUCCESS: http://jenkins.qa.ubuntu.com/job/unity-scopes-api-vivid-i386-ci/78

Click here to trigger a rebuild:
http://s-jenkins.ubuntu-ci:8080/job/unity-scopes-api-ci/552/rebuild

review: Approve (continuous-integration)

[lp:~marcustomlinson/unity-scopes-api/loop-prevention]

290. By Marcus Tomlinson on 2015-01-26

Merged child_scopes_ordered

=== modified file 'CONFIGFILES'
--- CONFIGFILES	2015-01-16 02:59:43 +0000
+++ CONFIGFILES	2015-01-26 17:28:26 +0000
@@ -167,7 +167,7 @@
     Trace inter-process messages activity.
 
   The environment variable UNITY_SCOPES_LOG_TRACECHANNELS overrides this key.
-  The value must be a semicolon-separate list of channel names.
+  The value must be a semicolon-separated list of channel names.
 
 
 Zmq.ini

=== modified file 'RELEASE_NOTES.md'
--- RELEASE_NOTES.md	2015-01-26 17:28:26 +0000
+++ RELEASE_NOTES.md	2015-01-26 17:28:26 +0000
@@ -7,6 +7,8 @@
     list of child scopes at runtime.
   - Added missing virtual destructor to AbstractScopeBase. (LP: #1360266)
   - Removed deprecated Runtime::run_scope() method.
+  - Prevent query from looping indefinitely if a query is forwarded
+    among aggregators and loops back to an earlier aggregator.
 
 Changes in version 0.6.11
 =========================

=== modified file 'STRUCTS'
--- STRUCTS	2014-12-03 08:05:20 +0000
+++ STRUCTS	2015-01-26 17:28:26 +0000
@@ -161,10 +161,10 @@
 
 QueryMetadata (returned by serialize())
 =======================================
- 'type'        : string (metadata type)
- 'locale'      : string
- 'form_factor' : string
- 'hints'       : dict
+ 'type'                  : string (metadata type)
+ 'locale'                : string
+ 'form_factor'           : string
+ 'hints'                 : dict
  'internet_connectivity' : bool (optional)
 
 SearchMetadata (returned by serialize())

=== modified file 'debian/changelog'
--- debian/changelog	2015-01-26 17:28:26 +0000
+++ debian/changelog	2015-01-26 17:28:26 +0000
@@ -4,8 +4,10 @@
     list of child scopes at runtime.
   * Added missing virtual destructor to AbstractScopeBase. (LP: #1360266)
   * Removed deprecated Runtime::run_scope() method.
+  * Prevent query from looping indefinitely if a query is forwarded
+    among aggregators and loops back to an earlier aggregator.
 
- -- Marcus Tomlinson <[e-mail]>  Tue, 20 Jan 2015 07:52:23 +0200
+ -- Marcus Tomlinson <[e-mail]>  Mon, 26 Jan 2015 10:25:49 +0200
 
 unity-scopes-api (0.6.11+15.04.20150126-0ubuntu1) vivid; urgency=low
 
@@ -32,6 +34,15 @@
   [ Michi Henning ]
   * Added utility subdir to header tests.
   * Bunch of miscellaneous fixes:
+    - Added warning for non-virtual destructors.
+    - Warnings will disappear once Marcus's child_scopes branch is merged.
+    - Tidied up the way compiler flags are set in CMakeLists.txt for clarity.
+    - Added missing dependencies to demos, so we can't run with an out-of-date registry or scoperunner.
+    - Fixed a number of warnings when building the developer doc.
+    - Minor doc fixes.
+    - Minor stylistic code fixes.
+    - Added missing tmp_dir_initialized_ initializer to ScopeBaseImpl.
+    - Removed redundant lock in QueryCtrlImpl constructor.
 
   [ James Henstridge ]
   * Expose the deserialize() static method on FilterBase and FilterState

=== modified file 'debian/libunity-scopes3.symbols'
--- debian/libunity-scopes3.symbols	2015-01-26 17:28:26 +0000
+++ debian/libunity-scopes3.symbols	2015-01-26 17:28:26 +0000
@@ -478,12 +478,14 @@
  (c++)"unity::scopes::internal::ScopeImpl::fwd()@Base" 0.4.3+14.10.20140428
  (c++)"unity::scopes::internal::ScopeImpl::perform_action(unity::scopes::Result const&, unity::scopes::ActionMetadata const&, std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, std::shared_ptr<unity::scopes::ActivationListenerBase> const&)@Base" 0.4.0+14.04.20140312.1
  (c++)"unity::scopes::internal::ScopeImpl::preview(unity::scopes::Result const&, unity::scopes::ActionMetadata const&, std::shared_ptr<unity::scopes::PreviewListenerBase> const&)@Base" 0.4.0+14.04.20140312.1
+ (c++)"unity::scopes::internal::ScopeImpl::runtime() const@Base" 0replaceme
  (c++)"unity::scopes::internal::ScopeImpl::~ScopeImpl()@Base" 0.4.0+14.04.20140312.1
  (c++)"unity::scopes::internal::ScopeImpl::ScopeImpl(std::shared_ptr<unity::scopes::internal::MWScope> const&, std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&)@Base" 0.6.11+15.04.20150119
  (c++)"unity::scopes::internal::ScopeImpl::search(std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, unity::scopes::FilterState const&, unity::scopes::SearchMetadata const&, std::shared_ptr<unity::scopes::SearchListenerBase> const&)@Base" 0.4.0+14.04.20140312.1
+ (c++)"unity::scopes::internal::ScopeImpl::search(std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, unity::scopes::FilterState const&, unity::scopes::SearchMetadata const&, std::vector<std::tuple<std::basic_string<char, std::char_traits<char>, std::allocator<char> >, std::basic_string<char, std::char_traits<char>, std::allocator<char> >, std::basic_string<char, std::char_traits<char>, std::allocator<char> > >, std::allocator<std::tuple<std::basic_string<char, std::char_traits<char>, std::allocator<char> >, std::basic_string<char, std::char_traits<char>, std::allocator<char> >, std::basic_string<char, std::char_traits<char>, std::allocator<char> > > > > const&, std::shared_ptr<unity::scopes::SearchListenerBase> const&)@Base" 0replaceme
  (c++)"unity::scopes::internal::ScopeImpl::search(std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, unity::scopes::FilterState const&, unity::scopes::SearchMetadata const&, std::shared_ptr<unity::scopes::SearchListenerBase> const&)@Base" 0.4.0+14.04.20140312.1
  (c++)"unity::scopes::internal::ScopeImpl::search(std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, unity::scopes::SearchMetadata const&, std::shared_ptr<unity::scopes::SearchListenerBase> const&)@Base" 0.4.0+14.04.20140312.1
- (c++)"unity::scopes::internal::ScopeImpl::search(unity::scopes::CannedQuery const&, unity::scopes::SearchMetadata const&, std::shared_ptr<unity::scopes::SearchListenerBase> const&)@Base" 0.4.0+14.04.20140312.1
+ (c++)"unity::scopes::internal::ScopeImpl::search(unity::scopes::CannedQuery const&, unity::scopes::SearchMetadata const&, std::vector<std::tuple<std::basic_string<char, std::char_traits<char>, std::allocator<char> >, std::basic_string<char, std::char_traits<char>, std::allocator<char> >, std::basic_string<char, std::char_traits<char>, std::allocator<char> > >, std::allocator<std::tuple<std::basic_string<char, std::char_traits<char>, std::allocator<char> >, std::basic_string<char, std::char_traits<char>, std::allocator<char> >, std::basic_string<char, std::char_traits<char>, std::allocator<char> > > > > const&, std::shared_ptr<unity::scopes::SearchListenerBase> const&)@Base" 0replaceme
  (c++)"unity::scopes::internal::ScopeImpl::set_child_scopes_ordered(std::list<unity::scopes::ChildScope, std::allocator<unity::scopes::ChildScope> > const&)@Base" 0replaceme
  (c++)"unity::scopes::internal::ScopeLoader::libpath() const@Base" 0.4.0+14.04.20140312.1
  (c++)"unity::scopes::internal::ScopeLoader::load(std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&)@Base" 0.6.0+14.10.20140804.1
@@ -546,8 +548,8 @@
  (c++)"unity::scopes::internal::ScopeObject::preview(unity::scopes::Result const&, unity::scopes::ActionMetadata const&, std::shared_ptr<unity::scopes::internal::MWReply> const&, unity::scopes::internal::InvokeInfo const&)@Base" 0.4.0+14.04.20140312.1
  (c++)"unity::scopes::internal::ScopeObject::query(std::shared_ptr<unity::scopes::internal::MWReply> const&, unity::scopes::internal::MiddlewareBase*, std::function<std::shared_ptr<unity::scopes::QueryBase> ()> const&, std::function<std::shared_ptr<unity::scopes::internal::QueryObjectBase> (std::shared_ptr<unity::scopes::QueryBase>, std::shared_ptr<unity::scopes::internal::MWQueryCtrl>)> const&)@Base" 0.4.0+14.04.20140312.1
  (c++)"unity::scopes::internal::ScopeObject::~ScopeObject()@Base" 0.4.0+14.04.20140312.1
- (c++)"unity::scopes::internal::ScopeObject::ScopeObject(unity::scopes::ScopeBase*, bool)@Base" 0.6.11+15.04.20150119
- (c++)"unity::scopes::internal::ScopeObject::search(unity::scopes::CannedQuery const&, unity::scopes::SearchMetadata const&, std::shared_ptr<unity::scopes::internal::MWReply> const&, unity::scopes::internal::InvokeInfo const&)@Base" 0.4.0+14.04.20140312.1
+ (c++)"unity::scopes::internal::ScopeObject::ScopeObject(unity::scopes::ScopeBase*, bool)@Base" 0replaceme
+ (c++)"unity::scopes::internal::ScopeObject::search(unity::scopes::CannedQuery const&, unity::scopes::SearchMetadata const&, std::map<std::basic_string<char, std::char_traits<char>, std::allocator<char> >, unity::scopes::Variant, std::less<std::basic_string<char, std::char_traits<char>, std::allocator<char> > >, std::allocator<std::pair<std::basic_string<char, std::char_traits<char>, std::allocator<char> > const, unity::scopes::Variant> > > const&, std::shared_ptr<unity::scopes::internal::MWReply> const&, unity::scopes::internal::InvokeInfo const&)@Base" 0replaceme
  (c++)"unity::scopes::internal::ScopeObject::set_child_scopes_ordered(std::list<unity::scopes::ChildScope, std::allocator<unity::scopes::ChildScope> > const&)@Base" 0replaceme
  (c++)"unity::scopes::internal::smartscopes::SSConfig::http_reply_timeout() const@Base" 0.4.4+14.10.20140508
  (c++)"unity::scopes::internal::smartscopes::SSConfig::reg_refresh_fail_timeout() const@Base" 0.4.4+14.10.20140508
@@ -575,7 +577,7 @@
  (c++)"unity::scopes::internal::smartscopes::SSScopeObject::perform_action(unity::scopes::Result const&, unity::scopes::ActionMetadata const&, std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, std::shared_ptr<unity::scopes::internal::MWReply> const&, unity::scopes::internal::InvokeInfo const&)@Base" 0.4.0+14.04.20140312.1
  (c++)"unity::scopes::internal::smartscopes::SSScopeObject::preview(unity::scopes::Result const&, unity::scopes::ActionMetadata const&, std::shared_ptr<unity::scopes::internal::MWReply> const&, unity::scopes::internal::InvokeInfo const&)@Base" 0.4.0+14.04.20140312.1
  (c++)"unity::scopes::internal::smartscopes::SSScopeObject::query(unity::scopes::internal::InvokeInfo const&, std::shared_ptr<unity::scopes::internal::MWReply> const&, std::function<std::shared_ptr<unity::scopes::QueryBase> ()> const&, std::function<void (std::shared_ptr<unity::scopes::QueryBase>)> const&)@Base" 0.4.0+14.04.20140312.1
- (c++)"unity::scopes::internal::smartscopes::SSScopeObject::search(unity::scopes::CannedQuery const&, unity::scopes::SearchMetadata const&, std::shared_ptr<unity::scopes::internal::MWReply> const&, unity::scopes::internal::InvokeInfo const&)@Base" 0.4.0+14.04.20140312.1
+ (c++)"unity::scopes::internal::smartscopes::SSScopeObject::search(unity::scopes::CannedQuery const&, unity::scopes::SearchMetadata const&, std::map<std::basic_string<char, std::char_traits<char>, std::allocator<char> >, unity::scopes::Variant, std::less<std::basic_string<char, std::char_traits<char>, std::allocator<char> > >, std::allocator<std::pair<std::basic_string<char, std::char_traits<char>, std::allocator<char> > const, unity::scopes::Variant> > > const&, std::shared_ptr<unity::scopes::internal::MWReply> const&, unity::scopes::internal::InvokeInfo const&)@Base" 0replaceme
  (c++)"unity::scopes::internal::smartscopes::SSScopeObject::set_child_scopes_ordered(std::list<unity::scopes::ChildScope, std::allocator<unity::scopes::ChildScope> > const&)@Base" 0replaceme
  (c++)"unity::scopes::internal::smartscopes::SSScopeObject::~SSScopeObject()@Base" 0.4.0+14.04.20140312.1
  (c++)"unity::scopes::internal::smartscopes::SSScopeObject::SSScopeObject(std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, std::shared_ptr<unity::scopes::internal::MiddlewareBase>, std::shared_ptr<unity::scopes::internal::smartscopes::SSRegistryObject>)@Base" 0.4.0+14.04.20140312.1

=== modified file 'include/unity/scopes/QueryBase.h'
--- include/unity/scopes/QueryBase.h	2014-11-03 05:31:30 +0000
+++ include/unity/scopes/QueryBase.h	2015-01-26 17:28:26 +0000
@@ -123,8 +123,8 @@
 private:
     friend class internal::QueryObject;                    // So QueryObject can call cancel()
     friend class internal::smartscopes::SSQueryObject;     // So SSQueryObject can call cancel()
-    friend class internal::ScopeObject;                    // So ScopeObject can call set_metadata() and set_department_id()
-    friend class internal::smartscopes::SSScopeObject;     // So SSQueryObject can call set_department_id()
+    friend class internal::ScopeObject;                    // So ScopeObject can call set_department_id()
+    friend class internal::smartscopes::SSScopeObject;     // So SSScopeObject can call set_department_id()
 };
 
 } // namespace scopes

=== modified file 'include/unity/scopes/QueryMetadata.h'
--- include/unity/scopes/QueryMetadata.h	2014-11-03 05:31:30 +0000
+++ include/unity/scopes/QueryMetadata.h	2015-01-26 17:28:26 +0000
@@ -31,6 +31,7 @@
 {
 
 class QueryMetadataImpl;
+class SearchQueryBaseImpl;
 
 }
 
@@ -96,6 +97,8 @@
 
     std::unique_ptr<internal::QueryMetadataImpl> p;
     QueryMetadata(internal::QueryMetadataImpl* impl);
+
+    friend class internal::SearchQueryBaseImpl;  // Allow access for loop detection
     /// @endcond
 };
 

=== modified file 'include/unity/scopes/SearchMetadata.h'
--- include/unity/scopes/SearchMetadata.h	2014-11-03 05:31:30 +0000
+++ include/unity/scopes/SearchMetadata.h	2015-01-26 17:28:26 +0000
@@ -31,8 +31,9 @@
 
 namespace internal
 {
+
 class SearchMetadataImpl;
-class ScopeObject;
+
 }
 
 /**

=== modified file 'include/unity/scopes/SearchQueryBase.h'
--- include/unity/scopes/SearchQueryBase.h	2014-11-03 05:31:30 +0000
+++ include/unity/scopes/SearchQueryBase.h	2015-01-26 17:28:26 +0000
@@ -149,10 +149,10 @@
     void set_department_id(std::string const& department_id);
     std::string department_id() const;
 
-    friend class internal::QueryObject;                    // So QueryObject can call cancel() and set_department_id()
-    friend class internal::ScopeObject;                    // So ScopeObject can call set_metadata() and set_department_id()
-    friend class internal::smartscopes::SSQueryObject;     // So SSQueryObject can call cancel()
-    friend class internal::smartscopes::SSScopeObject;     // So SSQueryObject can call set_department_id()
+    friend class internal::QueryObject;                 // So QueryObject can call cancel() and set_department_id()
+    friend class internal::ScopeObject;                 // So ScopeObject can set department and query context
+    friend class internal::smartscopes::SSQueryObject;  // So SSQueryObject can call cancel()
+    friend class internal::smartscopes::SSScopeObject;  // So SSScopeObject can call set_department_id()
 };
 
 } // namespace scopes

=== modified file 'include/unity/scopes/internal/MWScope.h'
--- include/unity/scopes/internal/MWScope.h	2015-01-26 17:28:26 +0000
+++ include/unity/scopes/internal/MWScope.h	2015-01-26 17:28:26 +0000
@@ -40,12 +40,28 @@
 public:
     virtual ~MWScope();
 
-    virtual QueryCtrlProxy search(CannedQuery const& query, VariantMap const& hints, MWReplyProxy const& reply) = 0;
-    virtual QueryCtrlProxy activate(VariantMap const& result, VariantMap const& hints, MWReplyProxy const& reply) = 0;
-    virtual QueryCtrlProxy perform_action(VariantMap const& result, VariantMap const& hints, std::string const& widget_id, std::string const& action_id, MWReplyProxy const& reply) = 0;
-    virtual QueryCtrlProxy preview(VariantMap const& result, VariantMap const& hints, MWReplyProxy const& reply) = 0;
+    virtual QueryCtrlProxy search(CannedQuery const& query,
+                                  VariantMap const& hints,
+                                  VariantMap const& details,
+                                  MWReplyProxy const& reply) = 0;
+
+    virtual QueryCtrlProxy activate(VariantMap const& result,
+                                    VariantMap const& hints,
+                                    MWReplyProxy const& reply) = 0;
+
+    virtual QueryCtrlProxy perform_action(VariantMap const& result,
+                                          VariantMap const& hints,
+                                          std::string const& widget_id,
+                                          std::string const& action_id,
+                                          MWReplyProxy const& reply) = 0;
+
+    virtual QueryCtrlProxy preview(VariantMap const& result,
+                                   VariantMap const& hints,
+                                   MWReplyProxy const& reply) = 0;
+
     virtual ChildScopeList child_scopes_ordered() = 0;
     virtual bool set_child_scopes_ordered(ChildScopeList const& child_scopes_ordered) = 0;
+
     virtual bool debug_mode() = 0;
 
 protected:

=== modified file 'include/unity/scopes/internal/ScopeImpl.h'
--- include/unity/scopes/internal/ScopeImpl.h	2015-01-26 17:28:26 +0000
+++ include/unity/scopes/internal/ScopeImpl.h	2015-01-26 17:28:26 +0000
@@ -18,13 +18,14 @@
 
 #pragma once
 
+#include <unity/scopes/ActivationListenerBase.h>
 #include <unity/scopes/internal/MWScopeProxyFwd.h>
 #include <unity/scopes/internal/ObjectImpl.h>
+#include <unity/scopes/internal/SearchQueryBaseImpl.h>
+#include <unity/scopes/PreviewListenerBase.h>
 #include <unity/scopes/QueryCtrlProxyFwd.h>
+#include <unity/scopes/Scope.h>
 #include <unity/scopes/SearchListenerBase.h>
-#include <unity/scopes/ActivationListenerBase.h>
-#include <unity/scopes/PreviewListenerBase.h>
-#include <unity/scopes/Scope.h>
 
 namespace unity
 {
@@ -48,6 +49,8 @@
     ScopeImpl(MWScopeProxy const& mw_proxy, std::string const& scope_id);
     virtual ~ScopeImpl();
 
+    RuntimeImpl* runtime() const;
+
     virtual QueryCtrlProxy search(std::string const& q,
                                   SearchMetadata const& metadata,
                                   SearchListenerBase::SPtr const& reply) override;
@@ -63,9 +66,17 @@
                                   SearchMetadata const& metadata,
                                   SearchListenerBase::SPtr const& reply) override;
 
+    QueryCtrlProxy search(std::string const& query_string,
+                          std::string const& department_id,
+                          FilterState const& filter_state,
+                          SearchMetadata const& metadata,
+                          SearchQueryBaseImpl::History const& history,
+                          SearchListenerBase::SPtr const& reply);       // Not remote, hence not override
+
     QueryCtrlProxy search(CannedQuery const& query,
                           SearchMetadata const& metadata,
-                          SearchListenerBase::SPtr const& reply); // Not remote, hence not override
+                          SearchQueryBaseImpl::History const& history,
+                          SearchListenerBase::SPtr const& reply);       // Not remote, hence not override
 
     virtual QueryCtrlProxy activate(Result const& result,
                                     ActionMetadata const& metadata,

=== modified file 'include/unity/scopes/internal/ScopeObject.h'
--- include/unity/scopes/internal/ScopeObject.h	2015-01-26 17:28:26 +0000
+++ include/unity/scopes/internal/ScopeObject.h	2015-01-26 17:28:26 +0000
@@ -55,14 +55,15 @@
 
     // Remote operation implementations
     virtual MWQueryCtrlProxy search(CannedQuery const& q,
-                                          SearchMetadata const& hints,
-                                          MWReplyProxy const& reply,
-                                          InvokeInfo const& info) override;
+                                    SearchMetadata const& hints,
+                                    VariantMap const& context,
+                                    MWReplyProxy const& reply,
+                                    InvokeInfo const& info) override;
 
     virtual MWQueryCtrlProxy activate(Result const& result,
-                              ActionMetadata const& hints,
-                              MWReplyProxy const &reply,
-                              InvokeInfo const& info) override;
+                                      ActionMetadata const& hints,
+                                      MWReplyProxy const &reply,
+                                      InvokeInfo const& info) override;
 
     virtual MWQueryCtrlProxy perform_action(Result const& result,
                                             ActionMetadata const& hints,

=== modified file 'include/unity/scopes/internal/ScopeObjectBase.h'
--- include/unity/scopes/internal/ScopeObjectBase.h	2015-01-26 17:28:26 +0000
+++ include/unity/scopes/internal/ScopeObjectBase.h	2015-01-26 17:28:26 +0000
@@ -48,6 +48,7 @@
 
     virtual MWQueryCtrlProxy search(CannedQuery const& query,
                                           SearchMetadata const& hints,
+                                          VariantMap const& context,
                                           MWReplyProxy const& reply,
                                           InvokeInfo const& info) = 0;
 

=== modified file 'include/unity/scopes/internal/SearchQueryBaseImpl.h'
--- include/unity/scopes/internal/SearchQueryBaseImpl.h	2014-11-03 05:31:30 +0000
+++ include/unity/scopes/internal/SearchQueryBaseImpl.h	2015-01-26 17:28:26 +0000
@@ -41,21 +41,17 @@
     SearchQueryBaseImpl(CannedQuery const& query, SearchMetadata const& metadata);
     CannedQuery query() const;
     SearchMetadata search_metadata() const;
+
     void set_department_id(std::string const& department_id);
     std::string department_id() const;
 
-    QueryCtrlProxy subsearch(ScopeProxy const& scope,
-                                   std::string const& query_string,
-                                   SearchListenerBase::SPtr const& reply);
-    QueryCtrlProxy subsearch(ScopeProxy const& scope,
-                                   std::string const& query_string,
-                                   FilterState const& filter_state,
-                                   SearchListenerBase::SPtr const& reply);
-    QueryCtrlProxy subsearch(ScopeProxy const& scope,
-                                   std::string const& query_string,
-                                   std::string const& department_id,
-                                   FilterState const& filter_state,
-                                   SearchListenerBase::SPtr const& reply);
+    void set_client_id(const std::string& id);
+
+    typedef std::tuple<std::string, std::string, std::string> HistoryData;
+    typedef std::vector<HistoryData> History;
+
+    void set_history(History const& h);
+
     QueryCtrlProxy subsearch(ScopeProxy const& scope,
                                    std::string const& query_string,
                                    std::string const& department_id,
@@ -67,12 +63,17 @@
     bool valid() const override;
 
 private:
+    CannedQuery const canned_query_;
+    SearchMetadata const search_metadata_;
+
+    mutable std::mutex mutex_;
     bool valid_;
-    mutable std::mutex mutex_;
-    const CannedQuery canned_query_;
-    const SearchMetadata search_metadata_;
     std::string department_id_;
+    std::string client_id_;
+    History history_;
     std::vector<QueryCtrlProxy> subqueries_;
+
+    QueryCtrlProxy check_for_query_loop(ScopeProxy const& scope, SearchListenerBase::SPtr const& reply);
 };
 
 } // namespace internal

=== modified file 'include/unity/scopes/internal/smartscopes/SSScopeObject.h'
--- include/unity/scopes/internal/smartscopes/SSScopeObject.h	2015-01-26 17:28:26 +0000
+++ include/unity/scopes/internal/smartscopes/SSScopeObject.h	2015-01-26 17:28:26 +0000
@@ -53,6 +53,7 @@
     // Remote operation implementations
     MWQueryCtrlProxy search(CannedQuery const& q,
                             SearchMetadata const& hints,
+                            VariantMap const& context,
                             MWReplyProxy const& reply,
                             InvokeInfo const& info) override;
 

=== modified file 'include/unity/scopes/internal/zmq_middleware/ZmqScope.h'
--- include/unity/scopes/internal/zmq_middleware/ZmqScope.h	2015-01-26 17:28:26 +0000
+++ include/unity/scopes/internal/zmq_middleware/ZmqScope.h	2015-01-26 17:28:26 +0000
@@ -45,8 +45,9 @@
     virtual ~ZmqScope();
 
     virtual QueryCtrlProxy search(CannedQuery const& query,
-                                        VariantMap const& hints,
-                                        MWReplyProxy const& reply) override;
+                                  VariantMap const& hints,
+                                  VariantMap const& context,
+                                  MWReplyProxy const& reply) override;
 
     virtual QueryCtrlProxy activate(VariantMap const& result,
                                     VariantMap const& hints,

=== modified file 'include/unity/scopes/utility/internal/BufferedResultForwarderImpl.h'
--- include/unity/scopes/utility/internal/BufferedResultForwarderImpl.h	2014-12-01 09:47:04 +0000
+++ include/unity/scopes/utility/internal/BufferedResultForwarderImpl.h	2015-01-26 17:28:26 +0000
@@ -55,8 +55,8 @@
     std::atomic<bool> ready_;
     std::atomic<bool> has_previous_;
     std::atomic<bool> previous_ready_;
-    unity::scopes::SearchReplyProxy const upstream_;  // Immutable
-    BufferedResultForwarder::SPtr next_;              // Immutable
+    unity::scopes::SearchReplyProxy const upstream_;
+    BufferedResultForwarder::SPtr const next_;
 };
 
 } // namespace internal

=== modified file 'include/unity/scopes/utility/internal/BufferedSearchReplyImpl.h'
--- include/unity/scopes/utility/internal/BufferedSearchReplyImpl.h	2014-12-01 01:51:38 +0000
+++ include/unity/scopes/utility/internal/BufferedSearchReplyImpl.h	2015-01-26 17:28:26 +0000
@@ -78,7 +78,7 @@
 
 private:
     std::mutex mutex_;
-    unity::scopes::SearchReplyProxy upstream_;  // Immutable
+    unity::scopes::SearchReplyProxy const upstream_;
     std::atomic<bool> buffer_;
     std::vector<CategorisedResult> results_;
 };

=== modified file 'src/scopes/SearchQueryBase.cpp'
--- src/scopes/SearchQueryBase.cpp	2014-06-12 16:16:01 +0000
+++ src/scopes/SearchQueryBase.cpp	2015-01-26 17:28:26 +0000
@@ -61,7 +61,7 @@
                                           string const& query_string,
                                           SearchListenerBase::SPtr const& reply)
 {
-    return fwd()->subsearch(scope, query_string, reply);
+    return subsearch(scope, query_string, "", FilterState(), fwd()->search_metadata(), reply);
 }
 
 QueryCtrlProxy SearchQueryBase::subsearch(ScopeProxy const& scope,
@@ -69,7 +69,7 @@
                                           FilterState const& filter_state,
                                           SearchListenerBase::SPtr const& reply)
 {
-    return fwd()->subsearch(scope, query_string, filter_state, reply);
+    return subsearch(scope, query_string, "", filter_state, fwd()->search_metadata(), reply);
 }
 
 QueryCtrlProxy SearchQueryBase::subsearch(ScopeProxy const& scope,
@@ -78,7 +78,7 @@
                                           FilterState const& filter_state,
                                           SearchListenerBase::SPtr const& reply)
 {
-    return fwd()->subsearch(scope, query_string, department_id, filter_state, reply);
+    return subsearch(scope, query_string, department_id, filter_state, fwd()->search_metadata(), reply);
 }
 
 QueryCtrlProxy SearchQueryBase::subsearch(ScopeProxy const& scope,

=== modified file 'src/scopes/internal/QueryCtrlImpl.cpp'
--- src/scopes/internal/QueryCtrlImpl.cpp	2015-01-20 04:14:26 +0000
+++ src/scopes/internal/QueryCtrlImpl.cpp	2015-01-26 17:28:26 +0000
@@ -45,8 +45,6 @@
 {
     // We remember the reply proxy so, when the query is cancelled, we can
     // inform the reply object belonging to this query that the query is finished.
-    assert(reply_proxy);
-
     ready_ = ctrl_proxy != nullptr;
     cancelled_ = false;
 }
@@ -87,12 +85,16 @@
 void QueryCtrlImpl::set_proxy(MWQueryCtrlProxy const& p)
 {
     assert(proxy() == nullptr);
-    ObjectImpl::set_proxy(p);
-
-    bool need_cancel;
-
+
+    bool need_cancel = false;
     {
         lock_guard<mutex> lock(mutex_);
+
+        if (!reply_proxy_)
+        {
+            return;
+        }
+        ObjectImpl::set_proxy(p);
         ready_ = true;
         need_cancel = cancelled_;
     } // Unlock

=== modified file 'src/scopes/internal/ScopeImpl.cpp'
--- src/scopes/internal/ScopeImpl.cpp	2015-01-26 17:28:26 +0000
+++ src/scopes/internal/ScopeImpl.cpp	2015-01-26 17:28:26 +0000
@@ -55,6 +55,11 @@
 {
 }
 
+RuntimeImpl* ScopeImpl::runtime() const
+{
+    return runtime_;
+}
+
 QueryCtrlProxy ScopeImpl::search(std::string const& query_string,
                                  std::string const& department_id,
                                  FilterState const& filter_state,
@@ -63,7 +68,7 @@
 {
     CannedQuery query(scope_id_, query_string, department_id);
     query.set_filter_state(filter_state);
-    return search(query, metadata, reply);
+    return search(query, metadata, SearchQueryBaseImpl::History(), reply);
 }
 
 QueryCtrlProxy ScopeImpl::search(std::string const& query_string,
@@ -71,23 +76,34 @@
                                  SearchMetadata const& metadata,
                                  SearchListenerBase::SPtr const& reply)
 {
-    CannedQuery query(scope_id_);
-    query.set_query_string(query_string);
+    CannedQuery query(scope_id_, query_string, "");
     query.set_filter_state(filter_state);
-    return search(query, metadata, reply);
+    return search(query, metadata, SearchQueryBaseImpl::History(), reply);
 }
 
 QueryCtrlProxy ScopeImpl::search(string const& query_string,
                                  SearchMetadata const& metadata,
                                  SearchListenerBase::SPtr const& reply)
 {
-    CannedQuery query(scope_id_);
-    query.set_query_string(query_string);
-    return search(query, metadata, reply);
+    CannedQuery query(scope_id_, query_string, "");
+    return search(query, metadata, SearchQueryBaseImpl::History(), reply);
+}
+
+QueryCtrlProxy ScopeImpl::search(std::string const& query_string,
+                                 std::string const& department_id,
+                                 FilterState const& filter_state,
+                                 SearchMetadata const& metadata,
+                                 SearchQueryBaseImpl::History const& history,
+                                 SearchListenerBase::SPtr const& reply)
+{
+    CannedQuery query(scope_id_, query_string, department_id);
+    query.set_filter_state(filter_state);
+    return search(query, metadata, history, reply);
 }
 
 QueryCtrlProxy ScopeImpl::search(CannedQuery const& query,
                                  SearchMetadata const& metadata,
+                                 SearchQueryBaseImpl::History const& history,
                                  SearchListenerBase::SPtr const& reply)
 {
     if (reply == nullptr)
@@ -107,12 +123,32 @@
     // sent in the new thread, the lambda will call into this by-now-destroyed instance.
     auto impl = dynamic_pointer_cast<ScopeImpl>(shared_from_this());
 
-    auto send_search = [impl, query, metadata, rp, ro, ctrl]() -> void
+    string const my_id = runtime_->scope_id();
+    auto send_search = [my_id, impl, query, metadata, history, rp, ro, ctrl]() -> void
     {
         try
         {
+            // Create query context with our own ID and the query history for loop detection.
+            VariantMap context;
+            context["client_id"] = my_id;
+
+            VariantArray hist;
+            for (auto const& tuple : history)
+            {
+                VariantMap d;
+                d["c"] = get<0>(tuple);  // Client
+                d["a"] = get<1>(tuple);  // Aggregator
+                d["r"] = get<2>(tuple);  // Receiver
+                hist.push_back(Variant(d));
+            }
+            context["history"] = Variant(hist);
+
             // Forward the (synchronous) search() method across the bus.
-            auto real_ctrl = dynamic_pointer_cast<QueryCtrlImpl>(impl->fwd()->search(query, metadata.serialize(), rp));
+            auto real_ctrl = dynamic_pointer_cast<QueryCtrlImpl>(impl->fwd()->search(query,
+                                                                                     metadata.serialize(),
+                                                                                     context,
+                                                                                     rp));
+
             assert(real_ctrl);
 
             // Call has completed now, so we update the MWQueryCtrlProxy for the fake proxy

=== modified file 'src/scopes/internal/ScopeObject.cpp'
--- src/scopes/internal/ScopeObject.cpp	2015-01-26 17:28:26 +0000
+++ src/scopes/internal/ScopeObject.cpp	2015-01-26 17:28:26 +0000
@@ -27,6 +27,8 @@
 #include <unity/scopes/internal/QueryObject.h>
 #include <unity/scopes/internal/RuntimeImpl.h>
 #include <unity/scopes/internal/ScopeBaseImpl.h>
+#include <unity/scopes/internal/SearchMetadataImpl.h>
+#include <unity/scopes/internal/SearchQueryBaseImpl.h>
 #include <unity/scopes/ScopeBase.h>
 #include <unity/UnityExceptions.h>
 
@@ -145,13 +147,44 @@
 
 MWQueryCtrlProxy ScopeObject::search(CannedQuery const& q,
                                      SearchMetadata const& hints,
+                                     VariantMap const& context,
                                      MWReplyProxy const& reply,
                                      InvokeInfo const& info)
 {
     return query(reply, info.mw,
-            [&q, &hints, this]() -> SearchQueryBase::UPtr {
+            [&q, &hints, &context, this]() -> SearchQueryBase::UPtr {
                  auto search_query = this->scope_base_->search(q, hints);
                  search_query->set_department_id(q.department_id());
+
+                 auto sqb = dynamic_cast<SearchQueryBaseImpl*>(search_query->fwd());
+                 assert(sqb);
+
+                 // Set client ID and history that we received in the SearchQueryBase
+                 // for loop detection.
+                 auto const c_it = context.find("client_id");
+                 if (c_it != context.end())
+                 {
+                     string client_id;
+                     client_id = c_it->second.get_string();
+                     sqb->set_client_id(client_id);
+                 }
+
+                 auto const h_it = context.find("history");
+                 if (h_it != context.end())
+                 {
+                    auto const hlist = h_it->second.get_array();
+                    SearchQueryBaseImpl::History history;
+                    for (auto const& t : hlist)
+                    {
+                        string client_id = t.get_dict()["c"].get_string();
+                        string agg = t.get_dict()["a"].get_string();
+                        string recv = t.get_dict()["r"].get_string();
+                        SearchQueryBaseImpl::HistoryData hd = make_tuple(client_id, agg, recv);
+                        history.push_back(hd);
+                    }
+                    sqb->set_history(history);
+                 }
+
                  return search_query;
             },
             [&reply, &hints, this](QueryBase::SPtr query_base, MWQueryCtrlProxy ctrl_proxy) -> QueryObjectBase::SPtr {

=== modified file 'src/scopes/internal/SearchMetadataImpl.cpp'
--- src/scopes/internal/SearchMetadataImpl.cpp	2015-01-14 02:19:17 +0000
+++ src/scopes/internal/SearchMetadataImpl.cpp	2015-01-26 17:28:26 +0000
@@ -50,6 +50,7 @@
     auto it = find_or_throw("SearchMetadataImpl()", var, "cardinality");
     cardinality_ = it->second.get_int();
     check_cardinality("SearchMetadataImpl(VariantMap)", cardinality_);
+
     try
     {
         it = find_or_throw("SearchMetadataImpl()", var, "location");
@@ -90,7 +91,6 @@
     return location_;
 }
 
-
 std::string SearchMetadataImpl::metadata_type() const
 {
     static const std::string t("search_metadata");

=== modified file 'src/scopes/internal/SearchQueryBaseImpl.cpp'
--- src/scopes/internal/SearchQueryBaseImpl.cpp	2014-08-05 06:42:04 +0000
+++ src/scopes/internal/SearchQueryBaseImpl.cpp	2015-01-26 17:28:26 +0000
@@ -18,9 +18,17 @@
  */
 
 #include <unity/scopes/internal/SearchQueryBaseImpl.h>
+
+#include <unity/scopes/internal/QueryCtrlImpl.h>
+#include <unity/scopes/internal/RuntimeImpl.h>
+#include <unity/scopes/internal/ScopeImpl.h>
+#include <unity/scopes/internal/SearchMetadataImpl.h>
+#include <unity/scopes/ScopeExceptions.h>
+
 #include <unity/UnityExceptions.h>
-#include <unity/scopes/QueryCtrl.h>
-#include <unity/scopes/Scope.h>
+
+#include <algorithm>
+#include <cassert>
 
 namespace unity
 {
@@ -35,9 +43,9 @@
 
 SearchQueryBaseImpl::SearchQueryBaseImpl(CannedQuery const& query, SearchMetadata const& metadata)
     : QueryBaseImpl(),
-      valid_(true),
       canned_query_(query),
-      search_metadata_(metadata)
+      search_metadata_(metadata),
+      valid_(true)
 {
 }
 
@@ -52,72 +60,6 @@
 }
 
 QueryCtrlProxy SearchQueryBaseImpl::subsearch(ScopeProxy const& scope,
-                                              string const& query_string,
-                                              SearchListenerBase::SPtr const& reply)
-{
-    if (!scope)
-    {
-        throw InvalidArgumentException("QueryBase::subsearch(): scope cannot be nullptr");
-    }
-    if (!reply)
-    {
-        throw InvalidArgumentException("QueryBase::subsearch(): reply cannot be nullptr");
-    }
-
-    // Forward the create request to the child scope and remember the control.
-    // This allows cancel() to forward incoming cancellations to subqueries
-    // without intervention from the scope application code.
-    QueryCtrlProxy qcp = scope->search(query_string, search_metadata_, reply);
-
-    lock_guard<mutex> lock(mutex_);
-    subqueries_.push_back(qcp);
-    return qcp;
-}
-
-QueryCtrlProxy SearchQueryBaseImpl::subsearch(ScopeProxy const& scope,
-                                              std::string const& query_string,
-                                              FilterState const& filter_state,
-                                              SearchListenerBase::SPtr const& reply)
-{
-    if (!scope)
-    {
-        throw InvalidArgumentException("QueryBase::subsearch(): scope cannot be nullptr");
-    }
-    if (!reply)
-    {
-        throw InvalidArgumentException("QueryBase::subsearch(): reply cannot be nullptr");
-    }
-
-    QueryCtrlProxy qcp = scope->search(query_string, filter_state, search_metadata_, reply);
-
-    lock_guard<mutex> lock(mutex_);
-    subqueries_.push_back(qcp);
-    return qcp;
-}
-
-QueryCtrlProxy SearchQueryBaseImpl::subsearch(ScopeProxy const& scope,
-                                   std::string const& query_string,
-                                   std::string const& department_id,
-                                   FilterState const& filter_state,
-                                   SearchListenerBase::SPtr const& reply)
-{
-    if (!scope)
-    {
-        throw InvalidArgumentException("QueryBase::subsearch(): scope cannot be nullptr");
-    }
-    if (!reply)
-    {
-        throw InvalidArgumentException("QueryBase::subsearch(): reply cannot be nullptr");
-    }
-
-    QueryCtrlProxy qcp = scope->search(query_string, department_id, filter_state, search_metadata_, reply);
-
-    lock_guard<mutex> lock(mutex_);
-    subqueries_.push_back(qcp);
-    return qcp;
-}
-
-QueryCtrlProxy SearchQueryBaseImpl::subsearch(ScopeProxy const& scope,
                                               std::string const& query_string,
                                               std::string const& department_id,
                                               FilterState const& filter_state,
@@ -133,11 +75,28 @@
         throw InvalidArgumentException("QueryBase::subsearch(): reply cannot be nullptr");
     }
 
-    QueryCtrlProxy qcp = scope->search(query_string, department_id, filter_state, metadata, reply);
+    auto query_ctrl = check_for_query_loop(scope, reply);
+    if (query_ctrl)
+    {
+        return query_ctrl;  // Loop was detected, return dummy QueryCtrlProxy.
+    }
+
+    // scope_impl can be nullptr if we use a mock scope: TypedScopeFixture<testing::Scope>
+    // If so, we call the normal search without passing the history through because
+    // we don't need loop detection for mock scopes.
+    auto scope_impl = dynamic_pointer_cast<ScopeImpl>(scope);
+    if (scope_impl)
+    {
+        query_ctrl = scope_impl->search(query_string, department_id, filter_state, metadata, history_, reply);
+    }
+    else
+    {
+        query_ctrl = scope->search(query_string, department_id, filter_state, metadata, reply);
+    }
 
     lock_guard<mutex> lock(mutex_);
-    subqueries_.push_back(qcp);
-    return qcp;
+    subqueries_.push_back(query_ctrl);  // Remember subsearch in case we get a cancel() later that we need to forward.
+    return query_ctrl;
 }
 
 void SearchQueryBaseImpl::cancel()
@@ -171,12 +130,70 @@
     return department_id_;
 }
 
+void SearchQueryBaseImpl::set_client_id(std::string const& id)
+{
+    lock_guard<mutex> lock(mutex_);
+    client_id_ = id;
+}
+
+void SearchQueryBaseImpl::set_history(History const& h)
+{
+    lock_guard<mutex> lock(mutex_);
+    history_ = h;
+}
+
 bool SearchQueryBaseImpl::valid() const
 {
     lock_guard<mutex> lock(mutex_);
     return valid_;
 }
 
+// Check if this query has been through this aggregator before by checking the
+// history. The history is a list of <client, aggregator, receiver> scope ID tuples.
+// If a query loops around to this aggregator, and has been sent to the same child
+// previously on behalf of the same client, we immediately call finished to indicate
+// an empty result set. If a loop is detected, we return a dummy QueryCtrl. Otherwise,
+// we add the current <client, aggregator, receiver> tuple to the history before forwarding the search.
+//
+// Note that we do this unconditionally, whether the receiver is a leaf or an aggregator.
+// This means that an aggregator can ask a *leaf scope* more than once for data.
+// This works because normal searches do not check the query history (only
+// subsearches do). But an aggregator cannot ask another *aggregator* more
+// than once for data, even if that would not create a loop.
+//
+// It is possible for an aggregator to send a query to itself, but only once.
+
+QueryCtrlProxy SearchQueryBaseImpl::check_for_query_loop(ScopeProxy const& scope,
+                                                         SearchListenerBase::SPtr const& reply)
+{
+    shared_ptr<QueryCtrlImpl> ctrl_proxy;
+
+    lock_guard<mutex> lock(mutex_);
+
+    HistoryData tuple = make_tuple(client_id_, canned_query_.scope_id(), scope->identity());
+    auto it = find(history_.begin(), history_.end(), tuple);
+    if (it != history_.end())
+    {
+        // Query has been here before from the same client and with the same child scope as the target.
+        reply->finished(CompletionDetails(CompletionDetails::OK,
+                                          "empty result set due to aggregator loop or repeated query on aggregating scope "
+                                          + get<1>(tuple)));
+        auto scope_impl = dynamic_pointer_cast<ScopeImpl>(scope);
+        auto logger = scope_impl->runtime()->logger();
+        ctrl_proxy = make_shared<QueryCtrlImpl>(nullptr, nullptr);  // Dummy proxy in already-cancelled state
+        BOOST_LOG_SEV(logger, Logger::Warning)
+            << "query loop for query \"" << canned_query_.query_string()
+            << "\", client: " << get<0>(tuple)
+            << ", aggregator: " << get<1>(tuple)
+            << ", receiver: " << get<2>(tuple) << endl;
+    }
+    else
+    {
+        history_.push_back(tuple);
+    }
+
+    return ctrl_proxy;  // null proxy if there was no loop
+}
 
 } // namespace internal
 

=== modified file 'src/scopes/internal/smartscopes/SSScopeObject.cpp'
--- src/scopes/internal/smartscopes/SSScopeObject.cpp	2015-01-26 17:28:26 +0000
+++ src/scopes/internal/smartscopes/SSScopeObject.cpp	2015-01-26 17:28:26 +0000
@@ -64,9 +64,10 @@
 }
 
 MWQueryCtrlProxy SSScopeObject::search(CannedQuery const& q,
-                                             SearchMetadata const& hints,
-                                             MWReplyProxy const& reply,
-                                             InvokeInfo const& info)
+                                       SearchMetadata const& hints,
+                                       VariantMap const& /* context */,
+                                       MWReplyProxy const& reply,
+                                       InvokeInfo const& info)
 {
     return query(info,
                  reply,

=== modified file 'src/scopes/internal/zmq_middleware/ScopeI.cpp'
--- src/scopes/internal/zmq_middleware/ScopeI.cpp	2015-01-26 17:28:26 +0000
+++ src/scopes/internal/zmq_middleware/ScopeI.cpp	2015-01-26 17:28:26 +0000
@@ -98,10 +98,12 @@
                               proxy.getEndpoint().cStr(),
                               proxy.getIdentity().cStr(),
                               proxy.getCategory().cStr()));
+    auto context = to_variant_map(req.getContext());
     auto delegate = dynamic_pointer_cast<ScopeObjectBase>(del());
     assert(delegate);
     auto ctrl_proxy = dynamic_pointer_cast<ZmqQueryCtrl>(delegate->search(query,
                                                                           metadata,
+                                                                          context,
                                                                           reply_proxy,
                                                                           to_info(current)));
     assert(ctrl_proxy);

=== modified file 'src/scopes/internal/zmq_middleware/ZmqScope.cpp'
--- src/scopes/internal/zmq_middleware/ZmqScope.cpp	2015-01-26 17:28:26 +0000
+++ src/scopes/internal/zmq_middleware/ZmqScope.cpp	2015-01-26 17:28:26 +0000
@@ -78,7 +78,10 @@
 {
 }
 
-QueryCtrlProxy ZmqScope::search(CannedQuery const& query, VariantMap const& hints, MWReplyProxy const& reply)
+QueryCtrlProxy ZmqScope::search(CannedQuery const& query,
+                                VariantMap const& hints,
+                                VariantMap const& context,
+                                MWReplyProxy const& reply)
 {
     capnp::MallocMessageBuilder request_builder;
     auto reply_proxy = dynamic_pointer_cast<ZmqReply>(reply);
@@ -93,6 +96,8 @@
         p.setEndpoint(reply_proxy->endpoint().c_str());
         p.setIdentity(reply_proxy->identity().c_str());
         p.setCategory(reply_proxy->target_category().c_str());
+        auto d = in_params.initContext();
+        to_value_dict(context, d);
     }
 
     auto future = mw_base()->twoway_pool()->submit([&] { return this->invoke_scope_(request_builder); });

=== modified file 'src/scopes/internal/zmq_middleware/capnproto/Scope.capnp'
--- src/scopes/internal/zmq_middleware/capnproto/Scope.capnp	2015-01-26 17:28:26 +0000
+++ src/scopes/internal/zmq_middleware/capnproto/Scope.capnp	2015-01-26 17:28:26 +0000
@@ -25,27 +25,17 @@
 using Proxy = import "Proxy.capnp";
 using ValueDict = import "ValueDict.capnp";
 
-# Factory for queries. The Scope object runs on the ctrl-endpoint.
+# Factory for queries.
 # createQuery() creates a Query object on the normal endpoint, and a QueryCtrl object
 # on the ctrl-endpoint. It then calls run() on the Query object to set it executing in its own thread, before
 # returning the QueryCtrl proxy that permits cancellation. This guarantees that createQuery() will not block.
 
-# Scope interface
-#
-# Operations:
-#
-# Proxy createQuery(string query, ValueDict hints, Proxy reply_proxy);
-
-# The createQuery method instantiates a Query Object and its corresponding QueryCtrlObject.
-# The return value is the proxy to the QueryCtrl object.
-# The implementation of createQuery calls the Query's run() method to give a thread of control
-# to the application code.
-
 struct CreateQueryRequest
 {
     query @0      : ValueDict.ValueDict;
     hints @1      : ValueDict.ValueDict;
     replyProxy @2 : Proxy.Proxy;
+    context @3    : ValueDict.ValueDict;  # Additional context for the request, such as client ID and history.
 }
 
 struct CreateQueryResponse

=== modified file 'test/gtest/scopes/CMakeLists.txt'
--- test/gtest/scopes/CMakeLists.txt	2015-01-26 17:28:26 +0000
+++ test/gtest/scopes/CMakeLists.txt	2015-01-26 17:28:26 +0000
@@ -20,6 +20,7 @@
 add_subdirectory(IdleShutdown)
 add_subdirectory(Invocation)
 add_subdirectory(Location)
+add_subdirectory(LoopDetection)
 add_subdirectory(OnlineAccountClient)
 add_subdirectory(OptionSelectorFilter)
 add_subdirectory(RadioButtonsFilter)

=== added directory 'test/gtest/scopes/LoopDetection'
=== added file 'test/gtest/scopes/LoopDetection/CMakeLists.txt'
--- test/gtest/scopes/LoopDetection/CMakeLists.txt	1970-01-01 00:00:00 +0000
+++ test/gtest/scopes/LoopDetection/CMakeLists.txt	2015-01-26 17:28:26 +0000
@@ -0,0 +1,26 @@
+configure_file(TestRegistry.ini.in ${CMAKE_CURRENT_BINARY_DIR}/TestRegistry.ini)
+configure_file(Runtime.ini.in ${CMAKE_CURRENT_BINARY_DIR}/Runtime.ini)
+configure_file(Zmq.ini.in ${CMAKE_CURRENT_BINARY_DIR}/Zmq.ini)
+
+add_definitions(-DTEST_RUNTIME_PATH="${CMAKE_CURRENT_BINARY_DIR}")
+add_definitions(-DTEST_RUNTIME_FILE="${CMAKE_CURRENT_BINARY_DIR}/Runtime.ini")
+add_definitions(-DTEST_REGISTRY_PATH="${PROJECT_BINARY_DIR}/scoperegistry")
+
+add_executable(LoopDetection_test LoopDetection_test.cpp LoopScope.cpp)
+target_link_libraries(LoopDetection_test ${TESTLIBS})
+
+add_dependencies(LoopDetection_test scoperegistry scoperunner)
+
+add_test(LoopDetection LoopDetection_test)
+
+set(SCOPE_DIR "${CMAKE_CURRENT_BINARY_DIR}/scopes")
+
+foreach (scope A B C D)
+    file(MAKE_DIRECTORY "${SCOPE_DIR}/${scope}")
+    configure_file(LoopScope.ini.in ${SCOPE_DIR}/${scope}/${scope}.ini)
+    add_library(${scope} MODULE LoopScope.cpp)
+    set_target_properties(${scope}
+      PROPERTIES
+        LIBRARY_OUTPUT_DIRECTORY "${SCOPE_DIR}/${scope}/"
+    )
+endforeach()

=== added file 'test/gtest/scopes/LoopDetection/LoopDetection_test.cpp'
--- test/gtest/scopes/LoopDetection/LoopDetection_test.cpp	1970-01-01 00:00:00 +0000
+++ test/gtest/scopes/LoopDetection/LoopDetection_test.cpp	2015-01-26 17:28:26 +0000
@@ -0,0 +1,249 @@
+/*
+ * Copyright (C) 2014 Canonical Ltd
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser 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 Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ * Authored by: Michi Henning <[e-mail]>
+ */
+
+#include <unity/scopes/CategorisedResult.h>
+#include <unity/scopes/internal/RegistryObject.h>
+#include <unity/scopes/internal/RuntimeImpl.h>
+#include <unity/scopes/internal/ScopeImpl.h>
+
+#include <gtest/gtest.h>
+
+#include "LoopScope.h"
+
+using namespace std;
+using namespace unity::scopes;
+using namespace unity::scopes::internal;
+
+class CountReceiver : public SearchListenerBase
+{
+public:
+    CountReceiver()
+        : query_complete_(false)
+    {
+    }
+
+    virtual void push(CategorisedResult result) override
+    {
+        string cat = result.category()->id();
+        string title = result.title();
+
+        lock_guard<mutex> lock(mutex_);
+        auto it = results_.find(cat);
+        if (it != results_.end())
+        {
+            it->second.push_back(title);
+        }
+        else
+        {
+            results_.insert(make_pair(cat, vector<string>{ title }));
+        }
+        cerr << "inserted " << cat << ", " << title << endl;
+    }
+
+    virtual void finished(CompletionDetails const& details) override
+    {
+        EXPECT_EQ(CompletionDetails::OK, details.status());
+        lock_guard<mutex> lock(mutex_);
+        query_complete_ = true;
+        cond_.notify_one();
+    }
+
+    void wait_until_finished()
+    {
+        unique_lock<mutex> lock(mutex_);
+        cond_.wait(lock, [this] { return this->query_complete_; });
+        query_complete_ = false;
+    }
+
+    map<string, vector<string>> results() const
+    {
+        lock_guard<mutex> lock(mutex_);
+
+        return results_;
+    }
+
+private:
+    map<string, vector<string>> results_;
+    bool query_complete_;
+    mutable mutex mutex_;
+    condition_variable cond_;
+};
+
+class LoopDetectionTest : public ::testing::Test
+{
+public:
+    LoopDetectionTest()
+    {
+        runtime_ = Runtime::create(TEST_RUNTIME_FILE);
+        auto reg = runtime_->registry();
+        auto meta = reg->get_metadata("A");  // First scope to receive a search is always A
+        scope_ = meta.proxy();
+    }
+
+    ScopeProxy scope() const
+    {
+        return scope_;
+    }
+
+private:
+    Runtime::UPtr runtime_;
+    ScopeProxy scope_;
+};
+
+// Stop warnings about unused return value from system()
+
+#pragma GCC diagnostic push
+#pragma GCC diagnostic ignored "-Wunused-result"
+
+// The command file for each scope is called A.cmd, B.cmd, etc. It contains scope IDs, one per
+// line. For each scope ID in its command file, the scope sends a subsearch to that scope.
+// Once a scope's subsearch completes, it pushes a single result with the scope's ID as the
+// category ID. This allows us to set up various callgraphs by writing to the various command files.
+
+TEST_F(LoopDetectionTest, no_error)
+{
+    system("cat >A.cmd << EOF\nB\nC\nEOF");
+    system(">B.cmd");
+    system(">C.cmd");
+    auto receiver = make_shared<CountReceiver>();
+    scope()->search("A", SearchMetadata("unused", "unused"), receiver);
+    receiver->wait_until_finished();
+
+    auto r = receiver->results();
+    EXPECT_EQ(3, r.size());
+    EXPECT_TRUE(r.find("A") != r.end());
+    EXPECT_TRUE(r.find("B") != r.end());
+    EXPECT_TRUE(r.find("C") != r.end());
+}
+
+TEST_F(LoopDetectionTest, diamond)
+{
+    system("cat >A.cmd << EOF\nB\nC\nEOF");
+    system("cat >B.cmd << EOF\nD\nEOF");
+    system("cat >C.cmd << EOF\nD\nEOF");
+    system(">D.cmd");
+    auto receiver = make_shared<CountReceiver>();
+    scope()->search("A", SearchMetadata("unused", "unused"), receiver);
+    receiver->wait_until_finished();
+
+    auto r = receiver->results();
+    EXPECT_EQ(4, r.size());
+    EXPECT_TRUE(r.find("A") != r.end());
+    EXPECT_TRUE(r.find("B") != r.end());
+    EXPECT_TRUE(r.find("C") != r.end());
+    EXPECT_TRUE(r.find("D") != r.end());
+    EXPECT_EQ(2, r.find("D")->second.size());  // B, and C each forwarded to D, so there must be 2 results.
+}
+
+TEST_F(LoopDetectionTest, immediate_loop)
+{
+    system("cat >A.cmd << EOF\nA\nEOF");
+    auto receiver = make_shared<CountReceiver>();
+    scope()->search("A", SearchMetadata("unused", "unused"), receiver);
+    receiver->wait_until_finished();
+
+    auto r = receiver->results();
+    EXPECT_EQ(1, r.size());
+    EXPECT_EQ(3, r.find("A")->second.size());  // "A" has sent the query twice to itself, second attempt stops loop
+}
+
+TEST_F(LoopDetectionTest, intermediate_loop)
+{
+    system("cat >A.cmd << EOF\nB\nEOF");
+    system("cat >B.cmd << EOF\nC\nEOF");
+    system("cat >C.cmd << EOF\nA\nEOF");
+    auto receiver = make_shared<CountReceiver>();
+    scope()->search("A", SearchMetadata("unused", "unused"), receiver);
+    receiver->wait_until_finished();
+
+    auto r = receiver->results();
+    EXPECT_EQ(3, r.size());
+    EXPECT_EQ(2, r.find("A")->second.size());  // "A" got results from B and C
+    EXPECT_EQ(2, r.find("B")->second.size());  // "B" got results from C and A
+    EXPECT_EQ(1, r.find("C")->second.size());  // "C" got result from A
+}
+
+TEST_F(LoopDetectionTest, repeated_search_on_leaf)
+{
+    system("cat >A.cmd << EOF\nB\nC\nD\nEOF");
+    system("cat >B.cmd << EOF\nD\nD\nEOF");
+    system("cat >C.cmd << EOF\nD\nEOF");
+    system(">D.cmd");
+    auto receiver = make_shared<CountReceiver>();
+    scope()->search("A", SearchMetadata("unused", "unused"), receiver);
+    receiver->wait_until_finished();
+
+    auto r = receiver->results();
+    EXPECT_EQ(4, r.size());
+    EXPECT_EQ(1, r.find("A")->second.size());
+    EXPECT_EQ(1, r.find("B")->second.size());
+    EXPECT_EQ(1, r.find("C")->second.size());
+    EXPECT_EQ(3, r.find("D")->second.size());
+}
+
+TEST_F(LoopDetectionTest, repeated_search_on_aggregator)
+{
+    system("cat >A.cmd << EOF\nB\nEOF");
+    system("cat >B.cmd << EOF\nC\nC\nEOF");
+    system(">C.cmd << EOF\nD\nEOF");
+    system(">D.cmd");
+    auto receiver = make_shared<CountReceiver>();
+    scope()->search("A", SearchMetadata("unused", "unused"), receiver);
+    receiver->wait_until_finished();
+
+    auto r = receiver->results();
+    EXPECT_EQ(3, r.size());
+    EXPECT_EQ(1, r.find("A")->second.size());
+    EXPECT_EQ(1, r.find("B")->second.size());
+    EXPECT_EQ(1, r.find("C")->second.size());
+}
+
+#pragma GCC diagnostic pop
+
+int main(int argc, char **argv)
+{
+    ::testing::InitGoogleTest(&argc, argv);
+
+    int rc = 0;
+
+    // Set the "TEST_DESKTOP_FILES_DIR" env var before forking as not to create desktop files in ~/.local
+    putenv(const_cast<char*>("TEST_DESKTOP_FILES_DIR=" TEST_RUNTIME_PATH));
+
+    auto rpid = fork();
+    if (rpid == 0)
+    {
+        const char* const args[] = {"scoperegistry [LoopDetecttion_test]", TEST_RUNTIME_FILE, nullptr};
+        if (execv(TEST_REGISTRY_PATH "/scoperegistry", const_cast<char* const*>(args)) < 0)
+        {
+            perror("Error starting scoperegistry:");
+        }
+        return 1;
+    }
+    else if (rpid > 0)
+    {
+        rc = RUN_ALL_TESTS();
+        kill(rpid, SIGTERM);
+        waitpid(rpid, nullptr, 0);
+    }
+    else
+    {
+        perror("Failed to fork:");
+    }
+
+    return rc;
+}

=== added file 'test/gtest/scopes/LoopDetection/LoopScope.cpp'
--- test/gtest/scopes/LoopDetection/LoopScope.cpp	1970-01-01 00:00:00 +0000
+++ test/gtest/scopes/LoopDetection/LoopScope.cpp	2015-01-26 17:28:26 +0000
@@ -0,0 +1,177 @@
+/*
+ * Copyright (C) 2014 Canonical Ltd
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser 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 Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ * Authored by: Michi Henning <[e-mail]>
+ */
+
+#include "LoopScope.h"
+
+#include <unity/scopes/CategorisedResult.h>
+#include <unity/scopes/ScopeBase.h>
+#include <unity/scopes/ScopeExceptions.h>
+#include <unity/scopes/SearchReply.h>
+
+#include <unity/UnityExceptions.h>
+#include <unity/util/FileIO.h>
+
+#include <mutex>
+#include <sstream>
+#include <thread>
+
+using namespace std;
+using namespace unity::scopes;
+
+namespace
+{
+
+class Receiver: public SearchListenerBase
+{
+public:
+
+    virtual void push(Category::SCPtr const& category) override
+    {
+        try
+        {
+            upstream_->register_category(category);
+        }
+        catch (unity::InvalidArgumentException const&)
+        {
+        }
+    }
+
+    virtual void push(CategorisedResult result) override
+    {
+        cerr << scope_id_ << ": received result: " << result.uri() << ", " << result.title() << endl;
+        try
+        {
+            upstream_->push(std::move(result));
+        }
+        catch (const unity::InvalidArgumentException &e)
+        {
+            cerr << scope_id_ << ": error pushing result: " << e.what() << endl;
+        }
+    }
+
+    virtual void finished(CompletionDetails const& details) override
+    {
+        cerr << scope_id_ << ": subquery complete, status: " << to_string(details.status())
+             << ", msg: " << details.message() << endl;
+    }
+
+    Receiver(string const& scope_id, SearchReplyProxy const& upstream) :
+        scope_id_(scope_id),
+        upstream_(upstream)
+    {
+    }
+
+private:
+    string scope_id_;
+    SearchReplyProxy upstream_;
+};
+
+class TestQuery : public SearchQueryBase
+{
+public:
+    TestQuery(CannedQuery const& query,
+              SearchMetadata const& metadata,
+              string const& id,
+              RegistryProxy const& reg)
+        : SearchQueryBase(query, metadata)
+        , id_(id)
+        , registry_(reg)
+    {
+    }
+
+    virtual void cancelled() override
+    {
+    }
+
+    virtual void run(SearchReplyProxy const& reply) override
+    {
+        auto cat = reply->register_category(id_, "", "");
+        SearchListenerBase::SPtr receiver(new Receiver(id_, reply));
+
+        // Open the command file and, for each scope ID (one per line),
+        // send a subquery to that scope.
+        istringstream cmds(unity::util::read_text_file(string(TEST_RUNTIME_PATH) + "/" + id_ + ".cmd"));
+        string child_id;
+        while (getline(cmds, child_id))
+        {
+            if (child_id.empty())
+            {
+                continue;  // Ignore empty ID, which is what we get if we act as a leaf scope.
+            }
+            auto proxy = registry_->get_metadata(child_id).proxy();
+            cerr << id_ << ": sending subsearch to " << child_id << endl;
+            subsearch(proxy, id_ + "->" + child_id, receiver);
+        }
+        CategorisedResult res(cat);
+        res.set_uri("uri");
+        res.set_title(id_ + ": result for query \"" + query().query_string() + "\"");
+        if (valid())
+        {
+            reply->push(res);
+        }
+    }
+
+private:
+    string id_;
+    RegistryProxy registry_;
+};
+
+}  // namespace
+
+void LoopScope::start(string const& scope_id)
+{
+    lock_guard<mutex> lock(mutex_);
+    id_ = scope_id;
+}
+
+void LoopScope::stop()
+{
+}
+
+void LoopScope::run()
+{
+}
+
+SearchQueryBase::UPtr LoopScope::search(CannedQuery const& query, SearchMetadata const& metadata)
+{
+    lock_guard<mutex> lock(mutex_);
+    return SearchQueryBase::UPtr(new TestQuery(query, metadata, id_, registry()));
+}
+
+PreviewQueryBase::UPtr LoopScope::preview(Result const&, ActionMetadata const &)
+{
+    return nullptr;  // unused
+}
+
+extern "C"
+{
+
+    unity::scopes::ScopeBase*
+    // cppcheck-suppress unusedFunction
+    UNITY_SCOPE_CREATE_FUNCTION()
+    {
+        return new LoopScope;
+    }
+
+    void
+    // cppcheck-suppress unusedFunction
+    UNITY_SCOPE_DESTROY_FUNCTION(unity::scopes::ScopeBase* scope_base)
+    {
+        delete scope_base;
+    }
+}

=== added file 'test/gtest/scopes/LoopDetection/LoopScope.h'
--- test/gtest/scopes/LoopDetection/LoopScope.h	1970-01-01 00:00:00 +0000
+++ test/gtest/scopes/LoopDetection/LoopScope.h	2015-01-26 17:28:26 +0000
@@ -0,0 +1,41 @@
+/*
+ * Copyright (C) 2014 Canonical Ltd
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser 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 Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ * Authored by: Michi Henning <[e-mail]>
+ */
+
+#pragma once
+
+#include <unity/scopes/ScopeBase.h>
+
+class LoopScope : public unity::scopes::ScopeBase
+{
+public:
+    virtual void start(std::string const&) override;
+
+    virtual void stop() override;
+
+    virtual void run() override;
+
+    virtual unity::scopes::SearchQueryBase::UPtr search(unity::scopes::CannedQuery const &,
+                                                        unity::scopes::SearchMetadata const &) override;
+
+    virtual unity::scopes::PreviewQueryBase::UPtr preview(unity::scopes::Result const&,
+                                                          unity::scopes::ActionMetadata const &) override;
+
+private:
+    std::string id_;
+    std::mutex mutex_;
+};

=== added file 'test/gtest/scopes/LoopDetection/LoopScope.ini.in'
--- test/gtest/scopes/LoopDetection/LoopScope.ini.in	1970-01-01 00:00:00 +0000
+++ test/gtest/scopes/LoopDetection/LoopScope.ini.in	2015-01-26 17:28:26 +0000
@@ -0,0 +1,4 @@
+[ScopeConfig]
+DisplayName = LoopScope
+Description = Aggregator scope that makes various loops
+Author = Michi

=== added file 'test/gtest/scopes/LoopDetection/Runtime.ini.in'
--- test/gtest/scopes/LoopDetection/Runtime.ini.in	1970-01-01 00:00:00 +0000
+++ test/gtest/scopes/LoopDetection/Runtime.ini.in	2015-01-26 17:28:26 +0000
@@ -0,0 +1,6 @@
+[Runtime]
+Registry.Identity = TestRegistry
+Registry.ConfigFile = @CMAKE_CURRENT_BINARY_DIR@/TestRegistry.ini
+Default.Middleware = Zmq
+Zmq.ConfigFile = @CMAKE_CURRENT_BINARY_DIR@/Zmq.ini
+Smartscopes.Registry.Identity =

=== added file 'test/gtest/scopes/LoopDetection/TestRegistry.ini.in'
--- test/gtest/scopes/LoopDetection/TestRegistry.ini.in	1970-01-01 00:00:00 +0000
+++ test/gtest/scopes/LoopDetection/TestRegistry.ini.in	2015-01-26 17:28:26 +0000
@@ -0,0 +1,7 @@
+[Registry]
+Middleware = Zmq
+Zmq.ConfigFile = @CMAKE_CURRENT_BINARY_DIR@/Zmq.ini
+Scope.InstallDir = @CMAKE_CURRENT_BINARY_DIR@/scopes
+OEM.InstallDir = /unused
+Click.InstallDir = @CMAKE_CURRENT_BINARY_DIR@/click
+Scoperunner.Path = @PROJECT_BINARY_DIR@/scoperunner/scoperunner

=== added file 'test/gtest/scopes/LoopDetection/Zmq.ini.in'
--- test/gtest/scopes/LoopDetection/Zmq.ini.in	1970-01-01 00:00:00 +0000
+++ test/gtest/scopes/LoopDetection/Zmq.ini.in	2015-01-26 17:28:26 +0000
@@ -0,0 +1,2 @@
+[Zmq]
+EndpointDir = /tmp

=== modified file 'test/gtest/scopes/internal/zmq_middleware/ZmqMiddleware/ZmqMiddleware_test.cpp'
--- test/gtest/scopes/internal/zmq_middleware/ZmqMiddleware/ZmqMiddleware_test.cpp	2015-01-26 17:28:26 +0000
+++ test/gtest/scopes/internal/zmq_middleware/ZmqMiddleware/ZmqMiddleware_test.cpp	2015-01-26 17:28:26 +0000
@@ -421,6 +421,7 @@
 
     virtual MWQueryCtrlProxy search(CannedQuery const&,
                                           SearchMetadata const&,
+                                          VariantMap const&,
                                           MWReplyProxy const&,
                                           InvokeInfo const&) override
     {

=== modified file 'test/gtest/scopes/testing/IsolatedScope/IsolatedScope_test.cpp'
--- test/gtest/scopes/testing/IsolatedScope/IsolatedScope_test.cpp	2014-12-03 10:01:38 +0000
+++ test/gtest/scopes/testing/IsolatedScope/IsolatedScope_test.cpp	2015-01-26 17:28:26 +0000
@@ -211,7 +211,7 @@
         &queryctrl, [](unity::scopes::QueryCtrl*) {});
 
     auto push_childscope_results =
-        [queryctrl_proxy](Unused, Unused, unity::scopes::SearchListenerBase::SPtr const& listener) -> unity::scopes::QueryCtrlProxy {
+        [queryctrl_proxy](Unused, Unused, Unused, Unused, unity::scopes::SearchListenerBase::SPtr const& listener) -> unity::scopes::QueryCtrlProxy {
         unity::scopes::Category::SCPtr cat(
             new unity::scopes::testing::Category(
                 "id", "title", "icon", unity::scopes::CategoryRenderer()));
@@ -229,7 +229,7 @@
     };
 
     NiceMock<unity::scopes::testing::MockScope> childscope;
-    EXPECT_CALL(childscope, search(aggregator_query, _, _))
+    EXPECT_CALL(childscope, search(aggregator_query, _, _, _, _))
         .WillOnce(Invoke(push_childscope_results));
     unity::scopes::ScopeProxy childscope_proxy(
         &childscope, [](unity::scopes::Scope*) {});