Add a mutex for each Reflection

2 files changed, 29 insertions, 0 deletions

diff --git a/src/reflist.c b/src/reflist.c
index 45cd132e..d17dca2f 100644
--- a/src/reflist.c
+++ b/src/reflist.c
@@ -13,6 +13,7 @@
 #include <stdlib.h>
 #include <assert.h>
 #include <stdio.h>
+#include <pthread.h>
 
 #include "reflist.h"
 #include "utils.h"
@@ -103,6 +104,7 @@ struct _reflection {
 	enum _nodecol col;            /* Colour (red or black) */
 
 	/* Payload */
+	pthread_mutex_t lock;         /* Protects the contents of "data" */
 	struct _refldata data;
 };
 
@@ -133,6 +135,7 @@ static Reflection *new_node(unsigned int serial)
 	new->child[0] = NULL;
 	new->child[1] = NULL;
 	new->col = RED;
+	pthread_mutex_init(&new->lock, NULL);
 
 	return new;
 }
@@ -959,3 +962,27 @@ int tree_depth(RefList *list)
 {
 	return recursive_depth(list->head);
 }
+
+
+/**
+ * lock_reflection:
+ * @refl: A %Reflection
+ *
+ * Acquires a lock on the reflection.
+ */
+void lock_reflection(Reflection *refl)
+{
+	pthread_mutex_lock(&refl->lock);
+}
+
+
+/**
+ * unlock_reflection:
+ * @refl: A %Reflection
+ *
+ * Releases a lock on the reflection.
+ */
+void unlock_reflection(Reflection *refl)
+{
+	pthread_mutex_unlock(&refl->lock);
+}
diff --git a/src/reflist.h b/src/reflist.h
index a49d4a61..65c8ef0b 100644
--- a/src/reflist.h
+++ b/src/reflist.h
@@ -103,5 +103,7 @@ extern Reflection *next_refl(Reflection *refl, RefListIterator *iter);
 /* Misc */
 extern int num_reflections(RefList *list);
 extern int tree_depth(RefList *list);
+extern void lock_reflection(Reflection *refl);
+extern void unlock_reflection(Reflection *refl);
 
 #endif	/* REFLIST_H */