]> git.meshlink.io Git - meshlink/blob - test/utils.h
Add reset_sync_flag().
[meshlink] / test / utils.h
1 #ifndef MESHLINK_TEST_UTILS_H
2 #define MESHLINK_TEST_UTILS_H
3
4 #include <assert.h>
5 #include <time.h>
6
7 #include "../src/meshlink.h"
8
9 // Simple synchronisation between threads
10 struct sync_flag {
11         pthread_mutex_t mutex;
12         pthread_cond_t cond;
13         bool flag;
14 };
15
16 extern void init_sync_flag(struct sync_flag *s);
17 extern void set_sync_flag(struct sync_flag *s, bool value);
18 extern void reset_sync_flag(struct sync_flag *s);
19 extern bool check_sync_flag(struct sync_flag *s);
20 extern bool wait_sync_flag(struct sync_flag *s, int seconds);
21
22 /// Create a pair of meshlink instances that are already joined together.
23 extern void open_meshlink_pair(meshlink_handle_t **a, meshlink_handle_t **b, const char *prefix);
24
25 /// Start a pair of meshlink instances and wait for them to connect together.
26 extern void start_meshlink_pair(meshlink_handle_t *a, meshlink_handle_t *b);
27
28 /// Stop a pair of meshlink instances.
29 extern void stop_meshlink_pair(meshlink_handle_t *a, meshlink_handle_t *b);
30
31 /// Stop and cleanup a pair of meshlink instances.
32 extern void close_meshlink_pair(meshlink_handle_t *a, meshlink_handle_t *b);
33
34 /// Link two meshlink instances.
35 extern void link_meshlink_pair(meshlink_handle_t *a, meshlink_handle_t *b);
36
37 /// Default log callback
38 extern void log_cb(meshlink_handle_t *mesh, meshlink_log_level_t level, const char *text);
39
40 #define assert_after(cond, timeout)\
41         do {\
42                 for(int i = 0; i++ <= timeout;) {\
43                         if(cond)\
44                                 break;\
45                         if(i == timeout)\
46                                 assert(cond);\
47                         sleep(1);\
48                 }\
49         } while(0)
50
51 #endif
52
53 /// Compare two timespec values.
54 static inline bool timespec_lt(const struct timespec *a, const struct timespec *b) {
55         if(a->tv_sec == b->tv_sec) {
56                 return a->tv_nsec < b->tv_nsec;
57         } else {
58                 return a->tv_sec < b->tv_sec;
59         }
60 }