X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Froute.c;h=91bd2f8227e158539e5798c6aaef535170f58f5c;hb=ec02aca3d7888f072c5c0d52ba6b5c37ed42b69e;hp=f451d8e35ebb8229d987746b970b17de4d55049c;hpb=01eaeb3c9fa60ae9c6e5b866acd9baef79622d99;p=meshlink diff --git a/src/route.c b/src/route.c index f451d8e3..91bd2f82 100644 --- a/src/route.c +++ b/src/route.c @@ -29,10 +29,11 @@ bool decrement_ttl = false; static bool checklength(node_t *source, vpn_packet_t *packet, uint16_t length) { if(packet->len < length) { - logger(source->mesh, MESHLINK_WARNING, "Got too short packet from %s (%s)", source->name, source->hostname); + logger(source->mesh, MESHLINK_WARNING, "Got too short packet from %s", source->name); return false; - } else + } else { return true; + } } void route(meshlink_handle_t *mesh, node_t *source, vpn_packet_t *packet) { @@ -44,21 +45,34 @@ void route(meshlink_handle_t *mesh, node_t *source, vpn_packet_t *packet) { owner = lookup_node(mesh, (char *)hdr->destination); logger(mesh, MESHLINK_DEBUG, "Routing packet from \"%s\" to \"%s\"\n", hdr->source, hdr->destination); - //Check Lenght - if(!checklength(source, packet, (sizeof(meshlink_packethdr_t)))) + //Check Length + if(!checklength(source, packet, sizeof(*hdr))) { return; + } if(owner == 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 owner 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) { - logger(mesh, MESHLINK_DEBUG, "I received a packet for me with payload: %s \n", packet->data + sizeof *hdr); - if(mesh->receive_cb) - mesh->receive_cb(mesh, (meshlink_node_t *)source, packet->data + sizeof *hdr, packet->len - sizeof *hdr); + 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) { + bin2hex(payload, hex, len); // don't do this unless it's going to be logged + } + + logger(mesh, MESHLINK_DEBUG, "I received a packet for me with payload: %s\n", hex); + + if(mesh->receive_cb) { + mesh->receive_cb(mesh, (meshlink_node_t *)source, payload, len); + } + return; } @@ -69,8 +83,9 @@ void route(meshlink_handle_t *mesh, node_t *source, vpn_packet_t *packet) { } via = (owner->via == mesh->self) ? owner->nexthop : owner->via; + if(via == source) { - logger(mesh, MESHLINK_ERROR, "Routing loop for packet from %s (%s)!", source->name, source->hostname); + logger(mesh, MESHLINK_ERROR, "Routing loop for packet from %s!", source->name); return; }