node_pthread.h

Go to the documentation of this file.

 
#include <pthread.h>
 
#undef RBT_NODE_ROOT_T
#define RBT_NODE_ROOT_T RBT_TOKEN_2_W(RBT_NODE_H_PREFIX_, node_root_t)
typedef
struct RBT_NODE_ROOT_T
{
  RBT_NODE_T * node;
 
  unsigned int readers;
 
  unsigned int writers;
 
  pthread_mutex_t mutex;
 
  pthread_cond_t cond;
}
RBT_NODE_ROOT_T;
 
 
RBT_NODE_ROOT_T
RBT_NODE_NEW()
{
  RBT_NODE_ROOT_T root;
  root.node = RBT_NODE_CREATE(NULL, 0, RBT_VALUE_NULL, NULL, NULL);
  root.mutex = PTHREAD_MUTEX_INITIALIZER;
  root.cond = PTHREAD_COND_INITIALIZER;
  root.readers = 0;
  root.writers = 0;
}
 
#undef RBT_NODE_ROOT_READ
#define RBT_NODE_ROOT_READ(root, func, ...) \
pthread_mutex_lock(&(root.mutex)); \
while (root.writers) \
{ \
  pthread_cond_wait(&(root.cond), &(root.mutex)); \
} \
root.readers ++; \
pthread_mutex_unlock(&(root.mutex)); \
func(root.node, ##__VA_ARGS__); \
pthread_mutex_lock(&(root.mutex)); \
root.readers --; \
if (! root.readers) \
{ \
  pthread_cond_signal(&(root.cond)); \
} \
pthread_mutex_unlock(&(root.mutex))
 
 
#undef RBT_NODE_ROOT_WRITE
#define RBT_NODE_ROOT_WRITE(root, func, ...) \
pthread_mutex_lock(&(root.mutex)); \
root.writers ++; \
while (root.readers) \
{ \
  pthread_cond_wait(&(root.cond), &(root.mutex)); \
} \
func(root.node, ##__VA_ARGS__); \
root.writers --; \
pthread_cond_signal(&(root.cond)); \
pthread_mutex_unlock(&(root.mutex))
 
 
 
#ifdef RBT_NODE_CACHE_SIZE
#undef RBT_NODE_CACHE_MUTEX
#define RBT_NODE_CACHE_MUTEX RBT_TOKEN_2_W(RBT_NODE_H_PREFIX_, node_cache_mutex)
pthread_mutex_t RBT_NODE_CACHE_MUTEX = PTHREAD_MUTEX_INITIALIZER;
 
#undef RBT_NODE_CACHE_LOCK
#define RBT_NODE_CACHE_LOCK pthread_mutex_lock(&RBT_NODE_CACHE_MUTEX)
 
#undef RBT_NODE_CACHE_UNLOCK
#define RBT_NODE_CACHE_UNLOCK pthread_mutex_unlock(&RBT_NODE_CACHE_MUTEX)
 
#endif //RBT_NODE_CACHE_SIZE