summaryrefslogtreecommitdiff
path: root/cpp/demo/book/evictor_filesystem/Server.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/demo/book/evictor_filesystem/Server.cpp')
-rw-r--r--cpp/demo/book/evictor_filesystem/Server.cpp85
1 files changed, 85 insertions, 0 deletions
diff --git a/cpp/demo/book/evictor_filesystem/Server.cpp b/cpp/demo/book/evictor_filesystem/Server.cpp
new file mode 100644
index 00000000000..72af8fe658d
--- /dev/null
+++ b/cpp/demo/book/evictor_filesystem/Server.cpp
@@ -0,0 +1,85 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2009 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 <PersistentFilesystemI.h>
+
+using namespace std;
+using namespace Filesystem;
+
+class FilesystemApp : virtual public Ice::Application
+{
+public:
+
+ FilesystemApp(const string& envName) :
+ _envName(envName)
+ {
+ }
+
+ virtual int run(int, char*[])
+ {
+ //
+ // Install object factories.
+ //
+ Ice::ObjectFactoryPtr factory = new NodeFactory;
+ communicator()->addObjectFactory(factory, PersistentFile::ice_staticId());
+ communicator()->addObjectFactory(factory, PersistentDirectory::ice_staticId());
+
+ //
+ // Create an object adapter.
+ //
+ Ice::ObjectAdapterPtr adapter = communicator()->createObjectAdapter("EvictorFilesystem");
+
+ //
+ // Create the Freeze evictor (stored in the NodeI::_evictor static member).
+ //
+ Freeze::ServantInitializerPtr init = new NodeInitializer;
+ NodeI::_evictor = Freeze::createTransactionalEvictor(adapter, _envName, "evictorfs",
+ Freeze::FacetTypeMap(), init);
+
+ adapter->addServantLocator(NodeI::_evictor, "");
+
+ //
+ // Create the root node if it doesn't exist.
+ //
+ Ice::Identity rootId = communicator()->stringToIdentity("RootDir");
+ if(!NodeI::_evictor->hasObject(rootId))
+ {
+ PersistentDirectoryPtr root = new DirectoryI(rootId);
+ root->nodeName = "/";
+ NodeI::_evictor->add(root, rootId);
+ }
+
+ //
+ // Ready to accept requests now.
+ //
+ adapter->activate();
+
+ //
+ // Wait until we are done.
+ //
+ communicator()->waitForShutdown();
+ if(interrupted())
+ {
+ cerr << appName() << ": received signal, shutting down" << endl;
+ }
+
+ return 0;
+ }
+
+private:
+
+ string _envName;
+};
+
+int
+main(int argc, char* argv[])
+{
+ FilesystemApp app("db");
+ return app.main(argc, argv, "config.server");
+}