Browse Source

Test

etomic
jl777 8 years ago
parent
commit
eb2ffdece9
  1. 2
      iguana/exchanges/LP_commands.c
  2. 2
      iguana/exchanges/LP_ordermatch.c
  3. 4
      iguana/exchanges/LP_swap.c

2
iguana/exchanges/LP_commands.c

@ -84,9 +84,9 @@ char *stats_JSON(void *ctx,char *myipaddr,int32_t pubsock,cJSON *argjson,char *r
if ( laststr != 0 )
free(laststr);
laststr = newstr;
retstr = laststr;
}
}
return(0);
}
//else if ( strcmp(method,"nn_tests") == 0 )
// return(clonestr("{\"result\":\"success\"}"));

2
iguana/exchanges/LP_ordermatch.c

@ -365,7 +365,7 @@ int32_t LP_nanobind(void *ctx,char *pairstr)
nanomsg_transportname(1,bindaddr,LP_myipaddr,r);
if ( nn_bind(pairsock,bindaddr) >= 0 )
{
timeout = 100;
timeout = 1;
nn_setsockopt(pairsock,NN_SOL_SOCKET,NN_SNDTIMEO,&timeout,sizeof(timeout));
nn_setsockopt(pairsock,NN_SOL_SOCKET,NN_RCVTIMEO,&timeout,sizeof(timeout));
printf("nanobind %s to %d\n",pairstr,pairsock);

4
iguana/exchanges/LP_swap.c

@ -435,7 +435,7 @@ int32_t swap_nn_send(int32_t sock,uint8_t *data,int32_t datalen,uint32_t flags,i
int32_t LP_waitsend(char *statename,int32_t timeout,int32_t pairsock,struct basilisk_swap *swap,uint8_t *data,int32_t maxlen,int32_t (*verify)(struct basilisk_swap *swap,uint8_t *data,int32_t datalen),int32_t (*datagen)(struct basilisk_swap *swap,uint8_t *data,int32_t maxlen))
{
int32_t datalen,sendlen,retval = -1;
printf("waitsend.%s\n",statename);
printf("waitsend.%s timeout.%d\n",statename,timeout);
if ( LP_waitfor(pairsock,swap,timeout,verify) == 0 )
{
printf("waited for %s\n",statename);
@ -457,7 +457,7 @@ int32_t LP_sendwait(char *statename,int32_t timeout,int32_t pairsock,struct basi
printf("sendwait.%s\n",statename);
if ( (datalen= (*datagen)(swap,data,maxlen)) > 0 )
{
printf("generated %d for %s\n",datalen,statename);
printf("generated %d for %s, timeout.%d\n",datalen,statename,timeout);
if ( (sendlen= swap_nn_send(pairsock,data,datalen,0,timeout)) == datalen )
{
printf("sendwait.%s sent %d\n",statename,sendlen);

Loading…
Cancel
Save