X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=test%2Futils.h;h=883b9154cedde7cc81865796afc7e674eaba8aa0;hb=4b6c01b1d5383b1a7417244a31ad4652aab2d5db;hp=dfada2c70b6e5dab562676690fe3ee18c1aabcc5;hpb=46079ef8d3adcb693d593cfd362879eb8e4709df;p=meshlink diff --git a/test/utils.h b/test/utils.h index dfada2c7..883b9154 100644 --- a/test/utils.h +++ b/test/utils.h @@ -1,6 +1,9 @@ #ifndef MESHLINK_TEST_UTILS_H #define MESHLINK_TEST_UTILS_H +#include +#include + #include "../src/meshlink.h" // Simple synchronisation between threads @@ -10,6 +13,7 @@ struct sync_flag { bool flag; }; +extern void init_sync_flag(struct sync_flag *s); extern void set_sync_flag(struct sync_flag *s, bool value); extern bool check_sync_flag(struct sync_flag *s); extern bool wait_sync_flag(struct sync_flag *s, int seconds); @@ -24,11 +28,14 @@ extern void start_meshlink_pair(meshlink_handle_t *a, meshlink_handle_t *b); extern void stop_meshlink_pair(meshlink_handle_t *a, meshlink_handle_t *b); /// Stop and cleanup a pair of meshlink instances. -extern void close_meshlink_pair(meshlink_handle_t *a, meshlink_handle_t *b, const char *prefix); +extern void close_meshlink_pair(meshlink_handle_t *a, meshlink_handle_t *b); /// Link two meshlink instances. extern void link_meshlink_pair(meshlink_handle_t *a, meshlink_handle_t *b); +/// Default log callback +extern void log_cb(meshlink_handle_t *mesh, meshlink_log_level_t level, const char *text); + #define assert_after(cond, timeout)\ do {\ for(int i = 0; i++ <= timeout;) {\ @@ -39,4 +46,14 @@ extern void link_meshlink_pair(meshlink_handle_t *a, meshlink_handle_t *b); sleep(1);\ }\ } while(0) + #endif + +/// Compare two timespec values. +static inline bool timespec_lt(const struct timespec *a, const struct timespec *b) { + if(a->tv_sec == b->tv_sec) { + return a->tv_nsec < b->tv_nsec; + } else { + return a->tv_sec < b->tv_sec; + } +}