1 files changed, 144 insertions, 0 deletions
diff --git a/cpp/include/IceUtil/Shared.h b/cpp/include/IceUtil/Shared.h
new file mode 100644
index 00000000000..8432f37e447
--- /dev/null
+++ b/cpp/include/IceUtil/Shared.h
@@ -0,0 +1,144 @@
+// **********************************************************************
+//
+// Copyright (c) 2001
+// MutableRealms, Inc.
+// Huntsville, AL, USA
+//
+// All Rights Reserved
+//
+// **********************************************************************
+
+#ifndef ICE_UTIL_SHARED_H
+#define ICE_UTIL_SHARED_H
+
+#include <IceUtil/Config.h>
+
+//
+// Base classes for reference counted types. For "smart pointers" or
+// "handles" for reference counted types derived from these base
+// classes, use IceUtil::Handle.
+//
+// IceUtil::SimpleShared
+// =====================
+//
+// A non thread-safe base class for reference-counted types.
+//
+// IceUtil::Shared
+// ===============
+//
+// A thread-safe base class for reference-counted types.
+//
+namespace IceUtil
+{
+
+class SimpleShared : public noncopyable
+{
+public:
+
+    SimpleShared() :
+	_ref(0),
+	_noDelete(false)
+    {
+    }
+
+    virtual ~SimpleShared()
+    {
+    }
+
+    void __incRef()
+    {
+	assert(_ref >= 0);
+	++_ref;
+    }
+
+    void __decRef()
+    {
+	assert(_ref > 0);
+	if (--_ref == 0)
+	{
+	    if(!_noDelete)
+	    {
+		delete this;
+	    }
+	}
+    }
+
+    int __getRef()
+    {
+	return _ref;
+    }
+
+    void __setNoDelete(bool b)
+    {
+	_noDelete = b;
+    }
+
+private:
+
+    int _ref;
+    bool _noDelete;
+};
+
+class Shared : public noncopyable
+{
+public:
+
+    Shared() :
+	_ref(0),
+	_noDelete(false)
+    {
+    }
+    
+    virtual ~Shared()
+    {
+    }
+
+    void __incRef()
+    {
+	_mutex.lock();
+	assert(_ref >= 0);
+	++_ref;
+	_mutex.unlock();
+    }
+
+    void __decRef()
+    {
+	_mutex.lock();
+	bool doDelete = false;
+	assert(_ref > 0);
+	if (--_ref == 0)
+	{
+	    doDelete = !_noDelete;
+	}
+	_mutex.unlock();
+	if (doDelete)
+	{
+	    delete this;
+	}
+    }
+
+    int __getRef()
+    {
+	_mutex.lock();
+	int ref = _ref;
+	_mutex.unlock();
+	return ref;
+    }
+
+    void __setNoDelete(bool b)
+    {
+	_mutex.lock();
+	_noDelete = b;
+	_mutex.unlock();
+    }
+
+private:
+
+    int _ref;
+    bool _noDelete;
+    JTCMutex _mutex;
+};
+
+}
+
+#endif