X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fmeshlink.c;fp=src%2Fmeshlink.c;h=3790117939fee5f5503a45da16df0cb0c9a08218;hb=46ef967244d11a2e1dc9c0c61f5d1e2caf08b51a;hp=122afa58dd2763ed6d6dc3e102295def5ae62aae;hpb=fee338aeb6400d8da4076d21a7b9e0b9f984f320;p=meshlink diff --git a/src/meshlink.c b/src/meshlink.c index 122afa58..37901179 100644 --- a/src/meshlink.c +++ b/src/meshlink.c @@ -862,9 +862,15 @@ bool meshlink_send(meshlink_handle_t *mesh, meshlink_node_t *destination, const signal_trigger(&(mesh->loop),&(mesh->datafromapp)); } -bool meshlink_send_from_queue (meshlink_handle_t *mesh,outpacketqueue_t* p) { +bool meshlink_send_from_queue(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;