X-Git-Url: http://git.meshlink.io/?p=meshlink;a=blobdiff_plain;f=test%2Futils.c;h=9a9bd211fcef7b85a5ee7904062e30f305009134;hp=a2b7b143972991d824ad23b9922860172f279921;hb=99ab0b58b4a20473670b442981eeed417dde1582;hpb=ecfe7cbbe08dc99ba6f329ad66bb8ee09ce9539b

diff --git a/test/utils.c b/test/utils.c
index a2b7b143..9a9bd211 100644
--- a/test/utils.c
+++ b/test/utils.c
@@ -15,6 +15,14 @@ void set_sync_flag(struct sync_flag *s, bool value) {
 	pthread_mutex_unlock(&s->mutex);
 }
 
+bool check_sync_flag(struct sync_flag *s) {
+	bool flag;
+	pthread_mutex_lock(&s->mutex);
+	flag = s->flag;
+	pthread_mutex_unlock(&s->mutex);
+	return flag;
+}
+
 bool wait_sync_flag(struct sync_flag *s, int seconds) {
 	struct timespec timeout;
 	clock_gettime(CLOCK_REALTIME, &timeout);
@@ -22,10 +30,11 @@ bool wait_sync_flag(struct sync_flag *s, int seconds) {
 
 	pthread_mutex_lock(&s->mutex);
 
-	while(!s->flag)
+	while(!s->flag) {
 		if(!pthread_cond_timedwait(&s->cond, &s->mutex, &timeout) || errno != EINTR) {
 			break;
 		}
+	}
 
 	pthread_mutex_unlock(&s->mutex);