|
|
@ -430,12 +430,12 @@ cJSON *electrum_submit(char *symbol,struct electrum_info *ep,cJSON **retjsonp,ch |
|
|
|
sitem->expiration = timeout; |
|
|
|
sitem->DL.type = ep->stratumid++; |
|
|
|
sitem->retptrp = (void **)retjsonp;*/ |
|
|
|
portable_mutex_lock(&ep->mutex); |
|
|
|
//portable_mutex_lock(&ep->mutex);
|
|
|
|
//queue_enqueue("sendQ",&ep->sendQ,&sitem->DL);
|
|
|
|
expiration = (uint32_t)time(NULL) + timeout + 1; |
|
|
|
while ( *retjsonp == 0 && time(NULL) <= expiration ) |
|
|
|
usleep(5000); |
|
|
|
portable_mutex_unlock(&ep->mutex); |
|
|
|
//portable_mutex_unlock(&ep->mutex);
|
|
|
|
if ( *retjsonp == 0 || jobj(*retjsonp,"error") != 0 ) |
|
|
|
{ |
|
|
|
if ( ++ep->numerrors >= LP_ELECTRUM_MAXERRORS ) |
|
|
|