New demo: IceUtil::Cache-based evictor

1 files changed, 65 insertions, 0 deletions

diff --git a/cpp/demo/Freeze/customEvictor/CurrentDatabase.cpp b/cpp/demo/Freeze/customEvictor/CurrentDatabase.cpp
new file mode 100644
index 00000000000..a2d928a30be
--- /dev/null
+++ b/cpp/demo/Freeze/customEvictor/CurrentDatabase.cpp
@@ -0,0 +1,65 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2007 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 <CurrentDatabase.h>
+#include <Freeze/Freeze.h>
+
+using namespace std;
+
+//
+// This implementation is very simple but not restartable, i.e.
+// you can only create and destroy one CurrentDatabase per process run.
+//
+
+#ifdef _MSC_VER
+   #define __thread __declspec(thread)
+#endif
+
+namespace
+{
+
+//
+// We keep a db on each thread
+//
+
+__thread Database* db = 0;
+
+}
+
+
+CurrentDatabase::CurrentDatabase(const Ice::CommunicatorPtr& communicator, const string& envName, const string& dbName) 
+    : _communicator(communicator),
+      _envName(envName),
+      _dbName(dbName)
+{
+}
+
+CurrentDatabase::~CurrentDatabase()
+{
+    for(list<Database*>::iterator p = _dbList.begin(); p != _dbList.end(); ++p)
+    {
+        delete *p;
+    }
+}
+
+
+Database&
+CurrentDatabase::get()
+{
+    if(db == 0)
+    {
+        Freeze::ConnectionPtr connection = Freeze::createConnection(_communicator, _envName);
+        db = new Database(connection, _dbName);
+        _dbList.push_back(db);
+    }
+    return *db;
+}
+ 
+
+