43 lines
715 B
C++
43 lines
715 B
C++
#include <string>
|
|
#include <pthread.h>
|
|
#include <cppunit/TestFixture.h>
|
|
#include <cppunit/extensions/HelperMacros.h>
|
|
|
|
#include "pbd/rcu.h"
|
|
|
|
class RCUTest : public CppUnit::TestFixture
|
|
{
|
|
CPPUNIT_TEST_SUITE (RCUTest);
|
|
CPPUNIT_TEST (race);
|
|
CPPUNIT_TEST_SUITE_END ();
|
|
|
|
public:
|
|
RCUTest ();
|
|
void setUp ();
|
|
void race ();
|
|
|
|
void read_thread ();
|
|
void write_thread ();
|
|
|
|
private:
|
|
class Value {
|
|
public:
|
|
Value (std::string const& v)
|
|
: val (v)
|
|
{}
|
|
std::string val;
|
|
};
|
|
|
|
typedef std::map<std::string, std::shared_ptr<Value> > Values;
|
|
|
|
SerializedRCUManager<Values> _values;
|
|
|
|
#ifdef __APPLE__
|
|
pthread_mutex_t _mutex;
|
|
pthread_cond_t _cond;
|
|
size_t _cnt;
|
|
#else
|
|
pthread_barrier_t _barrier;
|
|
#endif
|
|
};
|