|
|
@ -128,13 +128,13 @@ void queue_loop(void *ignore) |
|
|
|
else flag = 1; |
|
|
|
} |
|
|
|
} |
|
|
|
else if ( time(NULL) > ptr->starttime+30 ) |
|
|
|
else if ( time(NULL) > ptr->starttime+10 ) |
|
|
|
{ |
|
|
|
LP_crc32find(&duplicate,-1,ptr->crc32); |
|
|
|
if ( duplicate > 0 ) |
|
|
|
{ |
|
|
|
LP_Qfound++; |
|
|
|
if ( (LP_Qenqueued % 10) == 0 ) |
|
|
|
//if ( (LP_Qenqueued % 10) == 0 )
|
|
|
|
printf("found.%u Q.%d err.%d match.%d\n",ptr->crc32,LP_Qenqueued,LP_Qerrors,LP_Qfound); |
|
|
|
flag = 1; |
|
|
|
} |
|
|
@ -255,7 +255,7 @@ void LP_broadcast_message(int32_t pubsock,char *base,char *rel,bits256 destpub25 |
|
|
|
msg = (void *)jprint(argjson,0); |
|
|
|
msglen = (int32_t)strlen((char *)msg) + 1; |
|
|
|
crc32 = calc_crc32(0,&msg[2],msglen - 2); |
|
|
|
printf("CRC32.%u (%s)\n",crc32,(char *)msg); |
|
|
|
//printf("CRC32.%u (%s)\n",crc32,(char *)msg);
|
|
|
|
//jdelete(argjson,"method");
|
|
|
|
//jaddstr(argjson,"method","broadcast");
|
|
|
|
//msg = (void *)jprint(argjson,0);
|
|
|
|