Browse Source

test

release/v0.1
jl777 8 years ago
parent
commit
a85803d687
  1. 8
      basilisk/basilisk.c
  2. 5
      basilisk/basilisk_MSG.c

8
basilisk/basilisk.c

@ -765,7 +765,7 @@ void basilisk_requests_poll(struct supernet_info *myinfo)
memset(&issueR,0,sizeof(issueR)); memset(&issueR,0,sizeof(issueR));
if ( (retstr= InstantDEX_incoming(myinfo,0,0,0,0)) != 0 ) if ( (retstr= InstantDEX_incoming(myinfo,0,0,0,0)) != 0 )
{ {
printf("poll.(%s)\n",retstr); //printf("poll.(%s)\n",retstr);
if ( (outerarray= cJSON_Parse(retstr)) != 0 ) if ( (outerarray= cJSON_Parse(retstr)) != 0 )
{ {
if ( is_cJSON_Array(outerarray) != 0 ) if ( is_cJSON_Array(outerarray) != 0 )
@ -777,7 +777,7 @@ void basilisk_requests_poll(struct supernet_info *myinfo)
free_json(outerarray); free_json(outerarray);
} }
free(retstr); free(retstr);
} } else printf("null incoming\n");
if ( hwm > 0. ) if ( hwm > 0. )
{ {
if ( bits256_cmp(myinfo->myaddr.persistent,issueR.hash) == 0 ) // my request if ( bits256_cmp(myinfo->myaddr.persistent,issueR.hash) == 0 ) // my request
@ -841,9 +841,10 @@ void basilisks_loop(void *arg)
//printf(">>>>>>>>>>>>> update\n"); //printf(">>>>>>>>>>>>> update\n");
basilisk_unspents_update(myinfo,coin); basilisk_unspents_update(myinfo,coin);
coin->lastunspentsupdate = (uint32_t)time(NULL); coin->lastunspentsupdate = (uint32_t)time(NULL);
//printf(">>>>>>>>>>>>> update finished\n");
} }
} }
if ( RELAYID < 0 && myinfo->expiration != 0 ) if ( 0 && RELAYID < 0 && myinfo->expiration != 0 )
basilisk_requests_poll(myinfo); basilisk_requests_poll(myinfo);
now = (uint32_t)time(NULL); now = (uint32_t)time(NULL);
portable_mutex_lock(&myinfo->messagemutex); portable_mutex_lock(&myinfo->messagemutex);
@ -914,6 +915,7 @@ HASH_ARRAY_STRING(basilisk,balances,hash,vals,hexstr)
ptr->finished = (uint32_t)time(NULL); ptr->finished = (uint32_t)time(NULL);
return(retstr); return(retstr);
} }
return(clonestr("{\"error\":\"no result\"}"));
} else printf("no coin\n"); } else printf("no coin\n");
return(basilisk_standardservice("BAL",myinfo,0,hash,vals,hexstr,1)); return(basilisk_standardservice("BAL",myinfo,0,hash,vals,hexstr,1));
} }

5
basilisk/basilisk_MSG.c

@ -240,11 +240,12 @@ cJSON *basilisk_channelget(struct supernet_info *myinfo,bits256 hash,uint32_t ch
msgid = (uint32_t)time(NULL); msgid = (uint32_t)time(NULL);
jaddnum(valsobj,"msgid",msgid); jaddnum(valsobj,"msgid",msgid);
jaddnum(valsobj,"width",width); jaddnum(valsobj,"width",width);
jaddnum(valsobj,"timeout",1000);
jaddnum(valsobj,"fanout",(int32_t)sqrt(NUMRELAYS)+1); jaddnum(valsobj,"fanout",(int32_t)sqrt(NUMRELAYS)+1);
jaddnum(valsobj,"minresults",2); jaddnum(valsobj,"minresults",1);
if ( (retstr= basilisk_getmessage(myinfo,0,0,0,hash,valsobj,0)) != 0 ) if ( (retstr= basilisk_getmessage(myinfo,0,0,0,hash,valsobj,0)) != 0 )
{ {
printf("channel.%u msgid.%u gotmessage.(%s)\n",channel,msgid,retstr); //printf("channel.%u msgid.%u gotmessage.(%s)\n",channel,msgid,retstr);
if ( (retarray= cJSON_Parse(retstr)) != 0 ) if ( (retarray= cJSON_Parse(retstr)) != 0 )
{ {
if ( is_cJSON_Array(retarray) == 0 ) if ( is_cJSON_Array(retarray) == 0 )

Loading…
Cancel
Save