diff --git a/iguana/exchanges/LP_network.c b/iguana/exchanges/LP_network.c index 38fa4d6f2..04fb91f19 100644 --- a/iguana/exchanges/LP_network.c +++ b/iguana/exchanges/LP_network.c @@ -100,7 +100,7 @@ void _LP_sendqueueadd(int32_t sock,uint8_t *msg,int32_t msglen,int32_t peerind) memcpy(ptr->msg,msg,msglen); DL_APPEND(LP_Q,ptr); LP_Qenqueued++; - printf("Q.%p\n",ptr); + printf("Q.%p: peerind.%d msglen.%d\n",ptr,peerind,msglen); } void queue_loop(void *ignore) @@ -110,6 +110,7 @@ void queue_loop(void *ignore) { nonz = 0; portable_mutex_lock(&LP_networkmutex); + printf("LP_Q next.%p prev.%p\n",LP_Q->next,LP_Q->prev); DL_FOREACH(LP_Q,ptr) { DL_DELETE(LP_Q,ptr); @@ -146,7 +147,7 @@ void queue_loop(void *ignore) ptr->peerind++; if ( (ptr->sock= LP_peerindsock(&ptr->peerind)) < 0 ) { - printf("no more peers to try at peerind.%d\n",ptr->peerind); + printf("no more peers to try at peerind.%d %p\n",ptr->peerind,ptr); free(ptr); ptr = 0; } @@ -154,9 +155,9 @@ void queue_loop(void *ignore) } if ( ptr != 0 ) { - printf("reQ.%p: %u msglen.%d (+%d, -%d) -> %d\n",ptr,ptr->crc32,ptr->msglen,LP_Qenqueued,LP_Qdequeued,LP_Qenqueued-LP_Qdequeued); DL_APPEND(LP_Q,ptr); LP_Qenqueued++; + printf("reQ.%p: %u msglen.%d (+%d, -%d) -> %d\n",ptr,ptr->crc32,ptr->msglen,LP_Qenqueued,LP_Qdequeued,LP_Qenqueued-LP_Qdequeued); } } portable_mutex_unlock(&LP_networkmutex);