TSCH: add debug messages to track queued packet addresses

This commit is contained in:
Yasuyuki Tanaka 2017-02-10 16:56:14 +01:00
parent 8248f524f5
commit effdc6e212

View file

@ -202,6 +202,7 @@ tsch_queue_flush_nbr_queue(struct tsch_neighbor *n)
/* Free packet queuebuf */ /* Free packet queuebuf */
tsch_queue_free_packet(p); tsch_queue_free_packet(p);
} }
PRINTF("TSCH-queue: packet is deleted packet=%p\n", p);
} }
} }
/*---------------------------------------------------------------------------*/ /*---------------------------------------------------------------------------*/
@ -253,6 +254,8 @@ tsch_queue_add_packet(const linkaddr_t *addr, mac_callback_t sent, void *ptr)
/* Add to ringbuf (actual add committed through atomic operation) */ /* Add to ringbuf (actual add committed through atomic operation) */
n->tx_array[put_index] = p; n->tx_array[put_index] = p;
ringbufindex_put(&n->tx_ringbuf); ringbufindex_put(&n->tx_ringbuf);
PRINTF("TSCH-queue: packet is added put_index=%u, packet=%p\n",
put_index, p);
return p; return p;
} else { } else {
memb_free(&packet_memb, p); memb_free(&packet_memb, p);
@ -288,6 +291,7 @@ tsch_queue_remove_packet_from_queue(struct tsch_neighbor *n)
/* Get and remove packet from ringbuf (remove committed through an atomic operation */ /* Get and remove packet from ringbuf (remove committed through an atomic operation */
int16_t get_index = ringbufindex_get(&n->tx_ringbuf); int16_t get_index = ringbufindex_get(&n->tx_ringbuf);
if(get_index != -1) { if(get_index != -1) {
PRINTF("TSCH-queue: packet is removed, get_index=%u\n", get_index);
return n->tx_array[get_index]; return n->tx_array[get_index];
} else { } else {
return NULL; return NULL;