1 files changed, 52 insertions, 0 deletions
diff --git a/libddekit/condvar.c b/libddekit/condvar.c
new file mode 100644
index 00000000..64df3ed6
--- /dev/null
+++ b/libddekit/condvar.c
@@ -0,0 +1,52 @@
+/**
+ * Unchecked (no BSD invariants) condition variable implementation for
+ * dde-internal use. Written from scratch.
+ *
+ * \author Thomas Friebel <tf13@os.inf.tu-dresden.de>
+ */
+#include <pthread.h>
+
+#include "ddekit/memory.h"
+#include "ddekit/condvar.h"
+
+struct ddekit_condvar {
+	pthread_cond_t cond;
+};
+
+ddekit_condvar_t *ddekit_condvar_init() {
+	ddekit_condvar_t *cvp;
+
+	cvp = ddekit_simple_malloc (sizeof (*cvp));
+
+	if (cvp == NULL)
+		return NULL;
+
+	pthread_cond_init (&cvp->cond, NULL);
+	return cvp;
+}
+
+void ddekit_condvar_deinit(ddekit_condvar_t *cvp) {
+	ddekit_simple_free (cvp);
+}
+
+void ddekit_condvar_wait(ddekit_condvar_t *cvp, ddekit_lock_t *mp) {
+	/* This isn't nice. The encapsulation is broken.
+	 * TODO I can merge the two files condvar.c and lock.c. */
+	pthread_cond_wait (&cvp->cond, (pthread_mutex_t *) *mp);
+}
+
+int ddekit_condvar_wait_timed(ddekit_condvar_t *cvp,
+			      ddekit_lock_t *mp, int timo) {
+	// TODO currently just let it like this.
+	ddekit_condvar_wait (cvp, mp);
+	return 0;
+}
+
+void ddekit_condvar_signal(ddekit_condvar_t *cvp)
+{
+	pthread_cond_signal (&cvp->cond);
+}
+
+void ddekit_condvar_broadcast(ddekit_condvar_t *cvp) {
+	pthread_cond_broadcast (&cvp->cond);
+}