X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fmeshlink.c;h=dc897f478172e63fd2221b13e438dcdbd6687aaf;hb=b6513796888ed88ceae3b7570c9d5617d4b8a371;hp=36a8b663c5e36b0ec7c384db2399c56e7ec99f00;hpb=d1abe4a2961b78edc2a215e7f1d6608d8fb711fa;p=meshlink diff --git a/src/meshlink.c b/src/meshlink.c index 36a8b663..dc897f47 100644 --- a/src/meshlink.c +++ b/src/meshlink.c @@ -863,18 +863,18 @@ bool meshlink_send(meshlink_handle_t *mesh, meshlink_node_t *destination, const return true; } -bool meshlink_send_from_queue(event_loop_t* el,meshlink_handle_t *mesh) { +void meshlink_send_from_queue(event_loop_t* el,meshlink_handle_t *mesh) { vpn_packet_t packet; meshlink_packethdr_t *hdr = (meshlink_packethdr_t *)packet.data; outpacketqueue_t* p = list_get_tail(mesh->outpacketqueue); if (p) list_delete_tail(mesh->outpacketqueue); - else return false; + else return ; if (sizeof(meshlink_packethdr_t) + p->len > MAXSIZE) { //log something - return false; + return ; } packet.probe = false; @@ -888,7 +888,7 @@ bool meshlink_send_from_queue(event_loop_t* el,meshlink_handle_t *mesh) { mesh->self->in_packets++; mesh->self->in_bytes += packet.len; route(mesh, mesh->self, &packet); - return false; + return ; } meshlink_node_t *meshlink_get_node(meshlink_handle_t *mesh, const char *name) {