X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Froute.c;h=242b5864cfa04df44167fbd5b918046c2064c016;hb=0b07d0ad19634f8c28c852d64d1b22bab49924c4;hp=21559728eecae0e261fdf374dc2d0825ba4dc3fd;hpb=bab14fc67cc85f59775ad29b57d9e9adea4de526;p=meshlink diff --git a/src/route.c b/src/route.c index 21559728..242b5864 100644 --- a/src/route.c +++ b/src/route.c @@ -27,22 +27,6 @@ bool decrement_ttl = false; -static bool ratelimit(int frequency) { - static time_t lasttime = 0; - static int count = 0; - - if(lasttime == now.tv_sec) { - if(count >= frequency) - return true; - } else { - lasttime = now.tv_sec; - count = 0; - } - - count++; - return false; -} - static bool checklength(node_t *source, vpn_packet_t *packet, uint16_t length) { if(packet->len < length) { logger(DEBUG_TRAFFIC, LOG_WARNING, "Got too short packet from %s (%s)", source->name, source->hostname); @@ -51,13 +35,13 @@ static bool checklength(node_t *source, vpn_packet_t *packet, uint16_t length) { return true; } -void route(node_t *source,vpn_packet_t *packet) { +void route(meshlink_handle_t *mesh, node_t *source, vpn_packet_t *packet) { // TODO: route on name or key node_t* owner = NULL; node_t* via = NULL; meshlink_packethdr_t* hdr = (meshlink_packethdr_t*)packet->data; - owner = lookup_node(hdr->destination); + owner = lookup_node(mesh, hdr->destination); logger(DEBUG_TRAFFIC, LOG_WARNING, "Routing packet from: %s . To: %s \n",hdr->source,hdr->destination); //Check Lenght @@ -90,6 +74,6 @@ void route(node_t *source,vpn_packet_t *packet) { return; } - send_packet(owner,packet); + send_packet(mesh, owner, packet); return; }