|
|
@ -743,7 +743,7 @@ int32_t LP_swapwait(uint32_t requestid,uint32_t quoteid,int32_t duration,int32_t |
|
|
|
{ |
|
|
|
char *retstr; cJSON *retjson=0; uint32_t expiration = (uint32_t)(time(NULL) + duration); |
|
|
|
printf("wait %d:%d for SWAP.(r%u/q%u) to complete\n",duration,sleeptime,requestid,quoteid); |
|
|
|
sleep(10); |
|
|
|
sleep(sleeptime/3); |
|
|
|
//if ( sleeptime < divisor*60 )
|
|
|
|
// sleeptime = divisor * 60;
|
|
|
|
while ( time(NULL) < expiration ) |
|
|
@ -838,7 +838,7 @@ void LP_bobloop(void *_swap) |
|
|
|
if ( swap->N.pair >= 0 ) |
|
|
|
nn_close(swap->N.pair), swap->N.pair = -1; |
|
|
|
LP_swap_endcritical = (uint32_t)time(NULL); |
|
|
|
LP_swapwait(swap->I.req.requestid,swap->I.req.quoteid,LP_atomic_locktime(swap->I.bobstr,swap->I.alicestr)*2,30); |
|
|
|
LP_swapwait(swap->I.req.requestid,swap->I.req.quoteid,LP_atomic_locktime(swap->I.bobstr,swap->I.alicestr)*2,swap->I.aliceconfirms == 0 ? 3 : 30); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
@ -919,7 +919,7 @@ void LP_aliceloop(void *_swap) |
|
|
|
}*/ |
|
|
|
if ( swap->N.pair >= 0 ) |
|
|
|
nn_close(swap->N.pair), swap->N.pair = -1; |
|
|
|
LP_swapwait(swap->I.req.requestid,swap->I.req.quoteid,LP_atomic_locktime(swap->I.bobstr,swap->I.alicestr)*2,30); |
|
|
|
LP_swapwait(swap->I.req.requestid,swap->I.req.quoteid,LP_atomic_locktime(swap->I.bobstr,swap->I.alicestr)*2,swap->I.aliceconfirms == 0 ? 3 : 30); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|