/*****************************************************************************/
// Copyright 2006-2019 Adobe Systems Incorporated
// All Rights Reserved.
//
// NOTICE:	Adobe permits you to use, modify, and distribute this file in
// accordance with the terms of the Adobe license agreement accompanying it.
/*****************************************************************************/

#ifndef __dng_mutex__
#define __dng_mutex__

/******************************************************************************/

#include "dng_flags.h"
#include "dng_types.h"
#include "dng_uncopyable.h"

#if qDNGThreadSafe
#include "dng_pthread.h"
#endif

#include <mutex>

typedef std::mutex					 dng_std_mutex;
typedef std::lock_guard<std::mutex>	 dng_lock_std_mutex;
typedef std::unique_lock<std::mutex> dng_unique_lock;

// We should try to phase out use of dng_mutex over time.
// 
// Note that dng_mutex differs from dng_std_mutex (std::mutex) in that
// dng_mutex supports recursive locking (hierarchical mutex).

/******************************************************************************/

class dng_mutex: private dng_uncopyable
	{
	
	public:
	
		enum
			{
			kDNGMutexLevelLeaf	 = 0x70000000u,
			kDNGMutexLevelIgnore = 0x7FFFFFFFu
			};

		dng_mutex (const char *mutexName,
				   uint32 mutexLevel = kDNGMutexLevelLeaf);

		virtual ~dng_mutex ();

		void Lock ();

		void Unlock ();
		
		const char *MutexName () const;

	protected:
	
		#if qDNGThreadSafe
	
		pthread_mutex_t fPthreadMutex;
	
		const uint32 fMutexLevel;

		uint32 fRecursiveLockCount;

		dng_mutex *fPrevHeldMutex;

		const char * const fMutexName;

		friend class dng_condition;
		
		#endif

	};
		
/*****************************************************************************/

class dng_lock_mutex: private dng_uncopyable
	{
	
	private:
	
		dng_mutex *fMutex;
	
	public:
	
		dng_lock_mutex (dng_mutex *mutex);
		
		dng_lock_mutex (dng_mutex &mutex);
			
		~dng_lock_mutex ();
			
	};
	
/*****************************************************************************/

class dng_unlock_mutex: private dng_uncopyable
	{
	
	private:
	
		dng_mutex *fMutex;
	
	public:
	
		dng_unlock_mutex (dng_mutex *mutex);
		
		dng_unlock_mutex (dng_mutex &mutex);
			
		~dng_unlock_mutex ();
			
	};

/*****************************************************************************/

class dng_condition: private dng_uncopyable
	{
	
	public:

		dng_condition ();

		~dng_condition ();

		bool Wait (dng_mutex &mutex, double timeoutSecs = -1.0);

		void Signal ();
		
		void Broadcast ();

	protected:
	
	
#if qDNGThreadSafe
		pthread_cond_t fPthreadCondition;
#endif // qDNGThreadSafe

	};

/*****************************************************************************/

#endif
	
/*****************************************************************************/