#include "utils.h"
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;
}
void route(meshlink_handle_t *mesh, node_t *source, vpn_packet_t *packet) {
+ assert(source);
+
// TODO: route on name or key
meshlink_packethdr_t *hdr = (meshlink_packethdr_t *) packet->data;
return;
}
+ size_t len = packet->len - sizeof(*hdr);
+
+ // Channel traffic accounting
+ if(source == mesh->self) {
+ dest->out_data += len + SPTPS_OVERHEAD;
+ }
+
if(dest == mesh->self) {
+ source->in_data += len + SPTPS_OVERHEAD;
const void *payload = packet->data + sizeof(*hdr);
- size_t len = packet->len - sizeof(*hdr);
char hex[len * 2 + 1];
logger(mesh, MESHLINK_DEBUG, "I received a packet for me with payload: %s\n", hex);
- if(mesh->receive_cb) {
+ if(source->utcp) {
+ channel_receive(mesh, (meshlink_node_t *)source, payload, len);
+ } else if(mesh->receive_cb) {
mesh->receive_cb(mesh, (meshlink_node_t *)source, payload, len);
}