diff --git a/iguana/exchanges/LP_ordermatch.c b/iguana/exchanges/LP_ordermatch.c index ce47a26eb..b5e54e96a 100644 --- a/iguana/exchanges/LP_ordermatch.c +++ b/iguana/exchanges/LP_ordermatch.c @@ -1035,7 +1035,7 @@ void LP_tradesloop(void *ctx) } nonz++; tp->firstprocessed = tp->lastprocessed = (uint32_t)time(NULL); - //printf("iambob.%d funcid.%d vs %d\n",tp->iambob,funcid,LP_REQUEST); + printf("iambob.%d funcid.%d vs %d\n",tp->iambob,funcid,LP_REQUEST); } continue; } @@ -1046,7 +1046,10 @@ void LP_tradesloop(void *ctx) //printf("finished dequeue %p funcid.%d aliceid.%llu iambob.%d\n",qtp,funcid,(long long)qtp->aliceid,qtp->iambob); free(qtp); if ( tp->negotiationdone != 0 ) + { + printf("iambob.%d negotiationdone.%u\n",tp->iambob,tp->negotiationdone); continue; + } flag = 0; if ( qtp->iambob == tp->iambob ) { @@ -1070,6 +1073,7 @@ void LP_tradesloop(void *ctx) { flag = 1; tp->negotiationdone = now; + printf("bob sets negotiationdone.%u\n",now); LP_trades_gotconnect(ctx,&tp->Q,&tp->Qs[LP_CONNECT],tp->pairstr); } } @@ -1078,7 +1082,7 @@ void LP_tradesloop(void *ctx) tp->lastprocessed = (uint32_t)time(NULL); nonz++; } - } + } else printf("qtp->iambob.%d vs tp->iambob.%d\n",qtp->iambob,tp->iambob); } HASH_ITER(hh,LP_trades,tp,tmp) {