dev

分支 (7)

标签 (101)

管理

管理

dev

2.5.x

2.4.x

2.3.x

2.2.x

2.1.x

next

2.5.20

2.4.11client

2.4.8client

2.4.9

2.3.7

2.3.6

2.2.4client

2.2.7

2.2.6

2.1.20

2.2.3client

2.2.5

2.2.4

2.2.1client

2.2.2

2.1.15client

2.1.14client

2.1.18

2.1.13client

2.1.17

urbackup_backend
/
SharedMutex_lin.h

#pragma once

#include <pthread.h>
#include "Interface/SharedMutex.h"
#include <memory>

#if defined(_DEBUG) || (!defined(_WIN32) && !defined(NDEBUG))
#define SHARED_MUTEX_CHECK
#define SHARED_MUTEX_CHECK_P(x) ,x
#include <set>
#else
#define SHARED_MUTEX_CHECK_P(x)
#endif

class SharedMutex : public ISharedMutex
{
public:
	SharedMutex();
	~SharedMutex();

	virtual ILock* readLock();

	virtual ILock* writeLock();

#ifdef SHARED_MUTEX_CHECK
	void rmLockCheck();
#endif

private:
	pthread_rwlock_t lock;

#ifdef SHARED_MUTEX_CHECK
	std::unique_ptr<IMutex> check_mutex;
	std::set<pthread_t> check_threads;
#endif
};

class ReadLock : public ILock
{
public:
	ReadLock(pthread_rwlock_t* read_lock
			SHARED_MUTEX_CHECK_P(SharedMutex* shared_mutex));
	~ReadLock();

private:
	pthread_rwlock_t* read_lock;
#ifdef SHARED_MUTEX_CHECK
	SharedMutex* shared_mutex;
#endif
};

class WriteLock : public ILock
{
public:
	WriteLock(pthread_rwlock_t* write_lock);
	~WriteLock();

private:
	pthread_rwlock_t* write_lock;
};