X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fmeshlink.c;h=36a8b663c5e36b0ec7c384db2399c56e7ec99f00;hb=96965b151a80a5d33a1cd089a0a0430427694ba8;hp=122afa58dd2763ed6d6dc3e102295def5ae62aae;hpb=9e4d3c4a7b248c1e07b50108c0d99dd510178ee8;p=meshlink diff --git a/src/meshlink.c b/src/meshlink.c index 122afa58..36a8b663 100644 --- a/src/meshlink.c +++ b/src/meshlink.c @@ -860,11 +860,18 @@ bool meshlink_send(meshlink_handle_t *mesh, meshlink_node_t *destination, const //notify event loop signal_trigger(&(mesh->loop),&(mesh->datafromapp)); + return true; } -bool meshlink_send_from_queue (meshlink_handle_t *mesh,outpacketqueue_t* p) { +bool 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; + if (sizeof(meshlink_packethdr_t) + p->len > MAXSIZE) { //log something return false;