Browse Source

Test

etomic
jl777 7 years ago
parent
commit
9fbb13ab5b
  1. 6
      iguana/exchanges/LP_swap.c

6
iguana/exchanges/LP_swap.c

@ -420,15 +420,15 @@ int32_t LP_waitfor(int32_t pairsock,struct basilisk_swap *swap,int32_t timeout,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 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; int32_t datalen,sendlen,retval = -1;
//printf("waitsend.%s\n",statename); printf("waitsend.%s\n",statename);
if ( LP_waitfor(pairsock,swap,timeout,verify) == 0 ) if ( LP_waitfor(pairsock,swap,timeout,verify) == 0 )
{ {
//printf("waited for %s\n",statename); printf("waited for %s\n",statename);
if ( (datalen= (*datagen)(swap,data,maxlen)) > 0 ) if ( (datalen= (*datagen)(swap,data,maxlen)) > 0 )
{ {
if ( (sendlen= nn_send(pairsock,data,datalen,0)) == datalen ) if ( (sendlen= nn_send(pairsock,data,datalen,0)) == datalen )
{ {
//printf("sent.%d after waitfor.%s\n",sendlen,statename); printf("sent.%d after waitfor.%s\n",sendlen,statename);
retval = 0; retval = 0;
} else printf("send %s error\n",statename); } else printf("send %s error\n",statename);
} else printf("%s datagen no data\n",statename); } else printf("%s datagen no data\n",statename);

Loading…
Cancel
Save