X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/dba614edd2aad3c17e244914eaef3809d8300cb1..c31218a50b890d768c6b276a702cb9c22f89fb70:/lib/base/object.h

diff --git a/lib/base/object.h b/lib/base/object.h
index edd68a86..8cea2cd1 100644
--- a/lib/base/object.h
+++ b/lib/base/object.h
@@ -2,13 +2,12 @@
 #define __base_object_h
 
 #include <assert.h>
+#include <lib/base/smartptr.h>
+#include <lib/base/elock.h>
 
-// #define OBJECT_DEBUG
+//#define OBJECT_DEBUG
 
-#include <lib/base/smartptr.h>
-#ifdef OBJECT_DEBUG
 #include <lib/base/eerror.h>
-#endif
 
 typedef int RESULT;
 
@@ -24,35 +23,154 @@ public:
 	virtual void Release()=0;
 };
 
-class oRefCount
-{
-	int ref;
-public:
-	oRefCount(): ref(0) { }
-	operator int&() { return ref; }
-	~oRefCount() { 
-#ifdef OBJECT_DEBUG
-		if (ref) eDebug("OBJECT_DEBUG FATAL: %p has %d references!", this, ref); else eDebug("OBJECT_DEBUG refcount ok! (%p)", this); 
-#endif
-	}
-};
-
 #ifndef SWIG
-#define DECLARE_REF(x) private: oRefCount ref; public: void AddRef(); void Release();
-#ifdef OBJECT_DEBUG
-extern int object_total_remaining;
-#define DEFINE_REF(c) void c::AddRef() { ++object_total_remaining; ++ref; eDebug("OBJECT_DEBUG " #c "+%p now %d", this, (int)ref); } void c::Release() { --object_total_remaining; eDebug("OBJECT_DEBUG " #c "-%p now %d", this, ref-1); if (!--ref) delete this; }
-#else
-#define DEFINE_REF(c) void c::AddRef() { ++ref; } void c::Release() { if (!--ref) delete this; }
-#endif
-#else
-#define DECLARE_REF(x) private: void AddRef(); void Release();
-#endif
-
-#ifdef SWIG
-class Object
-{
-};
-#endif
+	struct oRefCount
+	{
+		volatile int count;
+		oRefCount(): count(0) { }
+		operator volatile int&() { return count; }
+		~oRefCount()
+		{ 
+	#ifdef OBJECT_DEBUG
+			if (count)
+				eDebug("OBJECT_DEBUG FATAL: %p has %d references!", this, count);
+			else
+				eDebug("OBJECT_DEBUG refcount ok! (%p)", this); 
+	#endif
+		}
+	};
+
+	#if defined(OBJECT_DEBUG)
+		extern int object_total_remaining;
+		#define DECLARE_REF(x) 			\
+			private:oRefCount ref; 	\
+					eSingleLock ref_lock; \
+			public: void AddRef(); 		\
+					void Release();
+		#define DEFINE_REF(c) \
+			void c::AddRef() \
+			{ \
+				eSingleLocker l(ref_lock); \
+				++object_total_remaining; \
+				++ref; \
+				eDebug("OBJECT_DEBUG " #c "+%p now %d", this, (int)ref); \
+			} \
+			void c::Release() \
+			{ \
+				{ \
+					eSingleLocker l(ref_lock); \
+					--object_total_remaining; \
+					--ref; \
+					eDebug("OBJECT_DEBUG " #c "-%p now %d", this, (int)ref); \
+				} \
+				if (!ref) \
+					delete this; \
+			}
+	#elif defined(__mips__)
+		#define DECLARE_REF(x) 			\
+			private: oRefCount ref; 	\
+			public: void AddRef(); 		\
+					void Release();
+		#define DEFINE_REF(c) \
+			void c::AddRef() \
+			{ \
+				unsigned long temp; \
+				__asm__ __volatile__( \
+				"		.set	mips3											\n" \
+				"1:		ll		%0, %1	# load counter							\n" \
+				"		.set	mips0											\n" \
+				"		addu	%0, 1	# increment								\n" \
+				"		.set	mips3											\n" \
+				"		sc		%0, %1	# try to store, checking for atomicity	\n" \
+				"		.set	mips0											\n" \
+				"		beqz	%0, 1b	# if not atomic (0), try again			\n" \
+				: "=&r" (temp), "=m" (ref.count) \
+				: "m" (ref.count) \
+				: ); \
+			} \
+			void c::Release() \
+			{ \
+				unsigned long temp; \
+				__asm__ __volatile__( \
+				"		.set	mips3				\n" \
+				"1:		ll		%0, %1				\n" \
+				"		.set	mips0				\n" \
+				"		subu	%0, 1	# decrement	\n" \
+				"		.set	mips3				\n" \
+				"		sc		%0, %1				\n" \
+				"		.set	mips0				\n" \
+				"		beqz	%0, 1b				\n" \
+				: "=&r" (temp), "=m" (ref.count) \
+				: "m" (ref.count) \
+				: ); \
+				if (!ref) \
+					delete this; \
+			}
+	#elif defined(__ppc__) || defined(__powerpc__)
+		#define DECLARE_REF(x) 			\
+			private: oRefCount ref; 	\
+			public: void AddRef(); 		\
+					void Release();
+		#define DEFINE_REF(c) \
+			void c::AddRef() \
+			{ \
+				int temp; \
+				__asm__ __volatile__( \
+				"1:		lwarx	%0, 0, %3	\n" \
+				"		add		%0, %2, %0	\n" \
+				"		dcbt	0, %3		# workaround for PPC405CR Errata\n" \
+				"		stwcx.	%0, 0, %3	\n" \
+				"		bne-	1b			\n" \
+				: "=&r" (temp), "=m" (ref.count) \
+				: "r" (1), "r" (&ref.count), "m" (ref.count) \
+				: "cc"); \
+			} \
+			void c::Release() \
+			{ \
+				int temp; \
+				__asm__ __volatile__( \
+				"1:		lwarx	%0, 0, %3	\n" \
+				"		subf	%0, %2, %0	\n" \
+				"		dcbt	0, %3		# workaround for PPC405CR Errata\n" \
+				"		stwcx.	%0, 0, %3	\n" \
+				"		bne-	1b			\n" \
+				: "=&r" (temp), "=m" (ref.count) \
+				: "r" (1), "r" (&ref.count), "m" (ref.count) \
+				: "cc"); \
+				if (!ref) \
+					delete this; \
+			}
+	#else
+		#warning use non optimized implementation of refcounting.
+		#define DECLARE_REF(x) 			\
+			private:oRefCount ref; 	\
+					eSingleLock ref_lock; \
+			public: void AddRef(); 		\
+					void Release();
+		#define DEFINE_REF(c) \
+			void c::AddRef() \
+			{ \
+				eSingleLocker l(ref_lock); \
+				++ref; \
+			} \
+			void c::Release() \
+	 		{ \
+				{ \
+					eSingleLocker l(ref_lock); \
+					--ref; \
+				} \
+				if (!ref) \
+					delete this; \
+			}
+	#endif
+#else  // SWIG
+	#define DECLARE_REF(x) \
+		private: \
+			void AddRef(); \
+			void Release();
+	class Object
+	{
+	};
+#endif  // SWIG
 
-#endif
+#endif  // __base_object_h