Added Yellow implementation.

1 files changed, 121 insertions, 0 deletions

diff --git a/cpp/src/Yellow/Service.cpp b/cpp/src/Yellow/Service.cpp
new file mode 100644
index 00000000000..223c2a2381c
--- /dev/null
+++ b/cpp/src/Yellow/Service.cpp
@@ -0,0 +1,121 @@
+// **********************************************************************
+//
+// Copyright (c) 2001
+// MutableRealms, Inc.
+// Huntsville, AL, USA
+//
+// All Rights Reserved
+//
+// **********************************************************************
+
+#include <Yellow/AdminI.h>
+#include <Yellow/QueryI.h>
+
+#include <IceBox/IceBox.h>
+
+using namespace std;
+using namespace Ice;
+using namespace Yellow;
+using namespace Freeze;
+
+namespace Yellow
+{
+
+class ServiceI : public ::IceBox::FreezeService
+{
+public:
+
+    ServiceI();
+    virtual ~ServiceI();
+
+    virtual void start(const string&,
+		       const CommunicatorPtr&,
+		       const PropertiesPtr&,
+		       const StringSeq&,
+		       const ::Freeze::DBEnvironmentPtr&);
+
+    virtual void stop();
+
+private:
+
+    ObjectAdapterPtr _queryAdapter;
+    ObjectAdapterPtr _adminAdapter;
+};
+
+} // End namespace Yellow
+
+extern "C"
+{
+
+//
+// Factory function
+//
+::IceBox::FreezeService*
+create(Ice::CommunicatorPtr communicator)
+{
+    return new Yellow::ServiceI;
+}
+
+}
+
+Yellow::ServiceI::ServiceI()
+{
+}
+
+Yellow::ServiceI::~ServiceI()
+{
+}
+
+void
+Yellow::ServiceI::start(const string& name,
+			const CommunicatorPtr& communicator,
+			const PropertiesPtr& properties,
+			const StringSeq& args,
+			const DBEnvironmentPtr& dbEnv)
+{
+    //
+    // The Admin & Query interface implementations each have their own
+    // map. This is safe because a) no iterators are used on the
+    // database, and b) internally the database is synchronized.
+    //
+    DBPtr dbYellow = dbEnv->openDB("yellow", true);
+
+    //
+    // With respect to the adapters I want to support three use-cases:
+    //
+    // 1) admin is not permitted.
+    // 2) both admin & query is permitted on the same endpoint
+    // 3) query & admin are permitted, but on seperate endpoitns
+    //
+    // TODO: At present #2 isn't supported.
+    //
+    string queryEndpoints = properties->getProperty(name + ".Query.Endpoints");
+    _queryAdapter = communicator->createObjectAdapterWithEndpoints(name + "QueryAdapter", queryEndpoints);
+
+    string adminEndpoints = properties->getProperty(name + ".Admin.Endpoints");
+    if(!adminEndpoints.empty())
+    {
+	_adminAdapter = communicator->createObjectAdapterWithEndpoints(name + "AdminAdapter", adminEndpoints);
+	ObjectPtr admin = new AdminI(dbYellow);
+	_adminAdapter->add(admin, stringToIdentity(name + "/Admin"));
+    }
+
+    ObjectPtr query = new QueryI(dbYellow);
+    _queryAdapter->add(query, stringToIdentity(name + "/Query"));
+
+    if(_adminAdapter)
+    {
+	_adminAdapter->activate();
+    }
+    _queryAdapter->activate();
+}
+
+void
+Yellow::ServiceI::stop()
+{
+    if(_adminAdapter)
+    {
+	_adminAdapter->deactivate();
+    }
+    _queryAdapter->deactivate();
+}