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);
}