Add CMake config

[dragonstd.git] / dragonstd / flag.c

diff --git a/dragonstd/flag.c b/dragonstd/flag.c
new file mode 100644 (file)
index 0000000..2aa6a90
--- /dev/null
+++ b/dragonstd/flag.c
@@ -0,0 +1,50 @@
+#include "flag.h"
+
+void flag_ini(Flag *flag)
+{
+       flag->set = false;
+       pthread_cond_init(&flag->cnd, NULL);
+       pthread_mutex_init(&flag->mtx, NULL);
+       list_ini(&flag->cvs);
+       flag_sub(flag, &flag->cnd);
+}
+
+void flag_dst(Flag *flag)
+{
+       pthread_cond_destroy(&flag->cnd);
+       pthread_mutex_destroy(&flag->mtx);
+       list_clr(&flag->cvs, NULL, NULL, NULL);
+}
+
+void flag_sub(Flag *flag, pthread_cond_t *cnd)
+{
+       pthread_mutex_lock(&flag->mtx);
+       list_add(&flag->cvs, cnd, cnd, &cmp_ref, NULL);
+       pthread_mutex_unlock(&flag->mtx);
+}
+
+void flag_uns(Flag *flag, pthread_cond_t *cnd)
+{
+       pthread_mutex_lock(&flag->mtx);
+       list_del(&flag->cvs, cnd, &cmp_ref, NULL, NULL, NULL);
+       pthread_mutex_unlock(&flag->mtx);
+}
+
+void flag_set(Flag *flag)
+{
+       pthread_mutex_lock(&flag->mtx);
+       flag->set = true;
+
+       LIST_ITERATE(&flag->cvs, node)
+               pthread_cond_broadcast(node->dat);
+
+       pthread_mutex_unlock(&flag->mtx);
+}
+
+void flag_slp(Flag *flag)
+{
+       pthread_mutex_lock(&flag->mtx);
+       if (!flag->set)
+               pthread_cond_wait(&flag->cnd, &flag->mtx);
+       pthread_mutex_unlock(&flag->mtx);
+}