|
|
@ -724,12 +724,12 @@ void LP_query(void *ctx,char *myipaddr,int32_t mypubsock,char *method,struct LP_ |
|
|
|
jaddnum(reqjson,"timestamp",time(NULL)); |
|
|
|
msg = jprint(reqjson,1); |
|
|
|
printf("QUERY.(%s)\n",msg); |
|
|
|
if ( bits256_nonz(qp->srchash) == 0 || strcmp(method,"request") != 0 ) |
|
|
|
//if ( bits256_nonz(qp->srchash) == 0 || strcmp(method,"request") != 0 )
|
|
|
|
{ |
|
|
|
memset(&zero,0,sizeof(zero)); |
|
|
|
LP_reserved_msg(1,qp->srccoin,qp->destcoin,qp->desthash,clonestr(msg)); |
|
|
|
LP_reserved_msg(1,qp->srccoin,qp->destcoin,zero,clonestr(msg)); |
|
|
|
LP_reserved_msg(0,qp->srccoin,qp->destcoin,zero,clonestr(msg)); |
|
|
|
//LP_reserved_msg(0,qp->srccoin,qp->destcoin,zero,clonestr(msg));
|
|
|
|
free(msg); |
|
|
|
/*portable_mutex_lock(&LP_reservedmutex);
|
|
|
|
if ( num_Reserved_msgs[1] < sizeof(Reserved_msgs[1])/sizeof(*Reserved_msgs[1])-2 ) |
|
|
@ -737,6 +737,6 @@ void LP_query(void *ctx,char *myipaddr,int32_t mypubsock,char *method,struct LP_ |
|
|
|
if ( num_Reserved_msgs[0] < sizeof(Reserved_msgs[0])/sizeof(*Reserved_msgs[0])-2 ) |
|
|
|
Reserved_msgs[0][num_Reserved_msgs[0]++] = msg2; |
|
|
|
portable_mutex_unlock(&LP_reservedmutex);*/ |
|
|
|
} else LP_broadcast_message(LP_mypubsock,qp->srccoin,qp->destcoin,qp->srchash,msg); |
|
|
|
} //else LP_broadcast_message(LP_mypubsock,qp->srccoin,qp->destcoin,qp->srchash,msg);
|
|
|
|
} |
|
|
|
|
|
|
|