diff --git a/iguana/exchanges/LP_forwarding.c b/iguana/exchanges/LP_forwarding.c index 1a14965cd..5f935ba83 100644 --- a/iguana/exchanges/LP_forwarding.c +++ b/iguana/exchanges/LP_forwarding.c @@ -94,10 +94,10 @@ void LP_forwarding_register(bits256 pubkey,char *pushaddr,int32_t max) } HASH_ITER(hh,LP_peerinfos,peer,tmp) { - printf("register with (%s)\n",peer->ipaddr); + //printf("register with (%s)\n",peer->ipaddr); if ( (retstr= issue_LP_register(peer->ipaddr,peer->port,pubkey,pushaddr)) != 0 ) { - printf("[%s] LP_register.(%s) returned.(%s)\n",pushaddr,peer->ipaddr,retstr); + //printf("[%s] LP_register.(%s) returned.(%s)\n",pushaddr,peer->ipaddr,retstr); if ( (retjson= cJSON_Parse(retstr)) != 0 ) { if ( jint(retjson,"registered") != 0 && ++n >= max ) diff --git a/iguana/exchanges/LP_utxos.c b/iguana/exchanges/LP_utxos.c index a95cb65f7..0b06803db 100644 --- a/iguana/exchanges/LP_utxos.c +++ b/iguana/exchanges/LP_utxos.c @@ -433,7 +433,8 @@ struct LP_utxoinfo *LP_utxoaddjson(int32_t iambob,int32_t pubsock,cJSON *argjson int32_t LP_utxosparse(int32_t mypubsock,char *destipaddr,uint16_t destport,char *retstr,uint32_t now) { - struct LP_peerinfo *destpeer; uint32_t argipbits; char *argipaddr; uint16_t argport,pushport,subport; cJSON *array,*item; int32_t i,n=0; bits256 txid; struct LP_utxoinfo *utxo; + struct LP_peerinfo *destpeer,*peer; uint32_t argipbits; char *argipaddr; uint16_t argport,pushport,subport; cJSON *array,*item; int32_t i,n=0; bits256 txid; struct LP_utxoinfo *utxo; + printf("parse.(%s)\n",retstr); if ( (array= cJSON_Parse(retstr)) != 0 ) { if ( (n= cJSON_GetArraySize(array)) > 0 ) @@ -448,16 +449,16 @@ int32_t LP_utxosparse(int32_t mypubsock,char *destipaddr,uint16_t destport,char if ( (subport= juint(item,"sub")) == 0 ) subport = argport + 2; argipbits = (uint32_t)calc_ipbits(argipaddr); - //if ( (peer= LP_peerfind(argipbits,argport)) == 0 ) - // peer = LP_addpeer(mypeer,mypubsock,argipaddr,argport,pushport,subport,jdouble(item,"profit"),jint(item,"numpeers"),jint(item,"numutxos")); - if ( jobj(item,"txid") != 0 ) - { - txid = jbits256(item,"txid"); - printf("parse.(%s)\n",jprint(item,0)); - if ( (utxo= LP_utxoaddjson(1,mypubsock,item)) != 0 ) - utxo->T.lasttime = now; - } - } // else printf("skip.(%s)\n",jprint(item,0)); + if ( (peer= LP_peerfind(argipbits,argport)) == 0 ) + peer = LP_addpeer(LP_mypeer,mypubsock,argipaddr,argport,pushport,subport,jdouble(item,"profit"),jint(item,"numpeers"),jint(item,"numutxos")); + } + if ( jobj(item,"txid") != 0 ) + { + txid = jbits256(item,"txid"); + printf("parse.(%s)\n",jprint(item,0)); + if ( (utxo= LP_utxoaddjson(1,mypubsock,item)) != 0 ) + utxo->T.lasttime = now; + } } if ( (destpeer= LP_peerfind((uint32_t)calc_ipbits(destipaddr),destport)) != 0 ) {