// find better nodes to connect to
- if(!connect_to && min_connects <= cur_connects < max_connects)
+ if(!connect_to && min_connects <= cur_connects && cur_connects < max_connects)
{
unsigned int connects = 0;
// heal partitions
- if(!connect_to && min_connects <= cur_connects < max_connects)
+ if(!connect_to && min_connects <= cur_connects && cur_connects < max_connects)
{
splay_tree_t *nodes = splay_alloc_tree(node_compare_devclass_asc_last_connect_try_desc, NULL);
// disconnect suboptimal outgoing connections
- if(min_connects < cur_connects <= max_connects)
+ if(min_connects < cur_connects && cur_connects <= max_connects)
{
unsigned int connects = 0;
mesh->datafromapp.signum = 0;
signal_add(&(mesh->loop),&(mesh->datafromapp), (signal_cb_t)meshlink_send_from_queue,mesh, mesh->datafromapp.signum);
- if(!event_loop_run(&mesh->loop)) {
+ if(!event_loop_run(&(mesh->loop), &(mesh->mesh_mutex))) {
logger(mesh, MESHLINK_ERROR, "Error while waiting for input: %s", strerror(errno));
return 1;
}