#include "utils.h"
+void init_sync_flag(struct sync_flag *s) {
+ assert(pthread_mutex_init(&s->mutex, NULL) == 0);
+ assert(pthread_cond_init(&s->cond, NULL) == 0);
+}
+
void set_sync_flag(struct sync_flag *s, bool value) {
- pthread_mutex_lock(&s->mutex);
+ assert(pthread_mutex_lock(&s->mutex) == 0);
s->flag = value;
- pthread_cond_broadcast(&s->cond);
- pthread_mutex_unlock(&s->mutex);
+ assert(pthread_cond_broadcast(&s->cond) == 0);
+ assert(pthread_mutex_unlock(&s->mutex) == 0);
}
bool check_sync_flag(struct sync_flag *s) {
bool flag;
- pthread_mutex_lock(&s->mutex);
+ assert(pthread_mutex_lock(&s->mutex) == 0);
flag = s->flag;
- pthread_mutex_unlock(&s->mutex);
+ assert(pthread_mutex_unlock(&s->mutex) == 0);
return flag;
}
clock_gettime(CLOCK_REALTIME, &timeout);
timeout.tv_sec += seconds;
- pthread_mutex_lock(&s->mutex);
+ assert(pthread_mutex_lock(&s->mutex) == 0);
while(!s->flag) {
if(!pthread_cond_timedwait(&s->cond, &s->mutex, &timeout) || errno != EINTR) {
}
}
- pthread_mutex_unlock(&s->mutex);
+ assert(pthread_mutex_unlock(&s->mutex) == 0);
return s->flag;
}
void link_meshlink_pair(meshlink_handle_t *a, meshlink_handle_t *b) {
// Import and export both side's data
- meshlink_add_address(a, "localhost");
- meshlink_add_address(b, "localhost");
+ assert(meshlink_set_canonical_address(a, meshlink_get_self(a), "localhost", NULL));
+ assert(meshlink_set_canonical_address(b, meshlink_get_self(b), "localhost", NULL));
char *data = meshlink_export(a);
assert(data);
void start_meshlink_pair(meshlink_handle_t *a, meshlink_handle_t *b) {
struct sync_flag pair_status = {.flag = false};
+ init_sync_flag(&pair_status);
a->priv = &pair_status;
meshlink_set_node_status_cb(a, pair_status_cb);