1 files changed, 112 insertions, 0 deletions
diff --git a/cpp/demo/IceGrid/customLoadBalancing/RegistryPlugin.cpp b/cpp/demo/IceGrid/customLoadBalancing/RegistryPlugin.cpp
new file mode 100644
index 00000000000..e3b0c2b8903
--- /dev/null
+++ b/cpp/demo/IceGrid/customLoadBalancing/RegistryPlugin.cpp
@@ -0,0 +1,112 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2014 ZeroC, Inc. All rights reserved.
+//
+// This copy of Ice is licensed to you under the terms described in the
+// ICE_LICENSE file included in this distribution.
+//
+// **********************************************************************
+
+#include <Ice/Ice.h>
+#include <IceGrid/IceGrid.h>
+
+using namespace std;
+using namespace IceGrid;
+
+namespace
+{
+
+class RegistryPluginI : public Ice::Plugin
+{
+public:
+
+    RegistryPluginI(const Ice::CommunicatorPtr&);
+    
+    virtual void initialize();
+    virtual void destroy();
+
+private:
+
+    const Ice::CommunicatorPtr _communicator;
+};
+
+class ReplicaGroupFilterI : public IceGrid::ReplicaGroupFilter
+{
+public:
+
+    ReplicaGroupFilterI(const RegistryPluginFacadePtr&);
+
+    virtual Ice::StringSeq filter(const string&, const Ice::StringSeq&, const Ice::ConnectionPtr&, const Ice::Context&);
+
+private:
+
+    RegistryPluginFacadePtr _facade;
+};
+
+}
+
+//
+extern "C"
+{
+
+ICE_DECLSPEC_EXPORT Ice::Plugin*
+createRegistryPlugin(const Ice::CommunicatorPtr& communicator, const string&, const Ice::StringSeq&)
+{
+    return new RegistryPluginI(communicator);
+}
+
+}
+
+RegistryPluginI::RegistryPluginI(const Ice::CommunicatorPtr& communicator) : _communicator(communicator)
+{
+}
+
+void
+RegistryPluginI::initialize()
+{
+    IceGrid::RegistryPluginFacadePtr facade = IceGrid::getRegistryPluginFacade();
+    if(facade)
+    {
+        facade->addReplicaGroupFilter("filterByCurrency", new ReplicaGroupFilterI(facade));
+    }
+}
+
+void
+RegistryPluginI::destroy()
+{
+}
+
+ReplicaGroupFilterI::ReplicaGroupFilterI(const IceGrid::RegistryPluginFacadePtr& facade) : _facade(facade)
+{
+}
+
+Ice::StringSeq
+ReplicaGroupFilterI::filter(const string& replicaGroupId, 
+                            const Ice::StringSeq& adapters, 
+                            const Ice::ConnectionPtr&, 
+                            const Ice::Context& ctx)
+{
+    Ice::Context::const_iterator p = ctx.find("currency");
+    if(p == ctx.end())
+    {
+        return adapters;
+    }
+
+    string currency = p->second;
+
+    //
+    // Get the Currencies property value from the server descriptor
+    // that owns the adapter and only keep adapters for servers that
+    // are configured with the currency specified in the client
+    // context.
+    //
+    Ice::StringSeq filteredAdapters;
+    for(Ice::StringSeq::const_iterator p = adapters.begin(); p != adapters.end(); ++p)
+    {
+        if(_facade->getPropertyForAdapter(*p, "Currencies").find(currency) != string::npos)
+        {
+            filteredAdapters.push_back(*p);
+        }
+    }
+    return filteredAdapters;
+}