X-Git-Url: http://git.meshlink.io/?p=meshlink;a=blobdiff_plain;f=src%2Froute.c;h=ee36a9bfe4b17c8289d85053312a7d44ed2692c3;hp=f7a728dc80278cac5ed62f2912f6b163428a534c;hb=963c5055505f2fc117cd5efa06eaa02c9b2bf85d;hpb=b67296418c51784d39a24c3041e2cb199bee06f2 diff --git a/src/route.c b/src/route.c index f7a728dc..ee36a9bf 100644 --- a/src/route.c +++ b/src/route.c @@ -25,9 +25,9 @@ #include "route.h" #include "utils.h" -bool decrement_ttl = false; - static bool checklength(node_t *source, vpn_packet_t *packet, uint16_t length) { + assert(length); + if(packet->len < length) { logger(source->mesh, MESHLINK_WARNING, "Got too short packet from %s", source->name); return false; @@ -37,33 +37,33 @@ static bool checklength(node_t *source, vpn_packet_t *packet, uint16_t length) { } void route(meshlink_handle_t *mesh, node_t *source, vpn_packet_t *packet) { + assert(source); + // 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(mesh, (char *)hdr->destination); + node_t *dest = lookup_node(mesh, (char *)hdr->destination); logger(mesh, MESHLINK_DEBUG, "Routing packet from \"%s\" to \"%s\"\n", hdr->source, hdr->destination); - //Check Lenght + //Check Length if(!checklength(source, packet, sizeof(*hdr))) { return; } - if(owner == NULL) { + if(dest == NULL) { //Lookup failed - logger(mesh, MESHLINK_WARNING, "Cant lookup the owner of a packet in the route() function. This should never happen!\n"); + logger(mesh, MESHLINK_WARNING, "Can't lookup the destination of a packet in the route() function. This should never happen!\n"); logger(mesh, MESHLINK_WARNING, "Destination was: %s\n", hdr->destination); return; } - if(owner == mesh->self) { + if(dest == mesh->self) { const void *payload = packet->data + sizeof(*hdr); size_t len = packet->len - sizeof(*hdr); char hex[len * 2 + 1]; - if(mesh->log_level >= MESHLINK_DEBUG) { + if(mesh->log_level <= MESHLINK_DEBUG) { bin2hex(payload, hex, len); // don't do this unless it's going to be logged } @@ -76,19 +76,17 @@ void route(meshlink_handle_t *mesh, node_t *source, vpn_packet_t *packet) { return; } - if(!owner->status.reachable) { + if(!dest->status.reachable) { //TODO: check what to do here, not just print a warning - logger(mesh, MESHLINK_WARNING, "The owner of a packet in the route() function is unreachable. Dropping packet.\n"); + logger(mesh, MESHLINK_WARNING, "The destination of a packet in the route() function is unreachable. Dropping packet.\n"); return; } - via = (owner->via == mesh->self) ? owner->nexthop : owner->via; - - if(via == source) { + if(dest == source) { logger(mesh, MESHLINK_ERROR, "Routing loop for packet from %s!", source->name); return; } - send_packet(mesh, owner, packet); + send_packet(mesh, dest, packet); return; }