|
@ -1050,18 +1050,18 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,uint16_t mybu |
|
|
printf("error launching LP_reserved_msgs for (%s)\n",myipaddr); |
|
|
printf("error launching LP_reserved_msgs for (%s)\n",myipaddr); |
|
|
exit(-1); |
|
|
exit(-1); |
|
|
} |
|
|
} |
|
|
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)utxosQ_loop,(void *)myipaddr) != 0 ) |
|
|
if ( 0 && OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)utxosQ_loop,(void *)myipaddr) != 0 ) |
|
|
{ |
|
|
{ |
|
|
printf("error launching utxosQ_loop for (%s)\n",myipaddr); |
|
|
printf("error launching utxosQ_loop for (%s)\n",myipaddr); |
|
|
exit(-1); |
|
|
exit(-1); |
|
|
} |
|
|
} |
|
|
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)stats_rpcloop,(void *)&myport) != 0 ) |
|
|
if ( 0 && OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)stats_rpcloop,(void *)&myport) != 0 ) |
|
|
{ |
|
|
{ |
|
|
printf("error launching stats rpcloop for port.%u\n",myport); |
|
|
printf("error launching stats rpcloop for port.%u\n",myport); |
|
|
exit(-1); |
|
|
exit(-1); |
|
|
} |
|
|
} |
|
|
uint16_t myport2 = myport-1; |
|
|
uint16_t myport2 = myport-1; |
|
|
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)stats_rpcloop,(void *)&myport2) != 0 ) |
|
|
if ( 0 && OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)stats_rpcloop,(void *)&myport2) != 0 ) |
|
|
{ |
|
|
{ |
|
|
printf("error launching stats rpcloop for port.%u\n",myport); |
|
|
printf("error launching stats rpcloop for port.%u\n",myport); |
|
|
exit(-1); |
|
|
exit(-1); |
|
@ -1076,7 +1076,7 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,uint16_t mybu |
|
|
printf("error launching queue_loop for port.%u\n",myport); |
|
|
printf("error launching queue_loop for port.%u\n",myport); |
|
|
exit(-1); |
|
|
exit(-1); |
|
|
} |
|
|
} |
|
|
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)gc_loop,(void *)myipaddr) != 0 ) |
|
|
if ( 0 && OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)gc_loop,(void *)myipaddr) != 0 ) |
|
|
{ |
|
|
{ |
|
|
printf("error launching gc_loop for port.%u\n",myport); |
|
|
printf("error launching gc_loop for port.%u\n",myport); |
|
|
exit(-1); |
|
|
exit(-1); |
|
@ -1086,17 +1086,17 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,uint16_t mybu |
|
|
printf("error launching prices_loop for port.%u\n",myport); |
|
|
printf("error launching prices_loop for port.%u\n",myport); |
|
|
exit(-1); |
|
|
exit(-1); |
|
|
} |
|
|
} |
|
|
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)LP_coinsloop,(void *)"") != 0 ) |
|
|
if ( 0 && OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)LP_coinsloop,(void *)"") != 0 ) |
|
|
{ |
|
|
{ |
|
|
printf("error launching LP_coinsloop for port.%u\n",myport); |
|
|
printf("error launching LP_coinsloop for port.%u\n",myport); |
|
|
exit(-1); |
|
|
exit(-1); |
|
|
} |
|
|
} |
|
|
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)LP_coinsloop,(void *)"BTC") != 0 ) |
|
|
if ( 0 && OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)LP_coinsloop,(void *)"BTC") != 0 ) |
|
|
{ |
|
|
{ |
|
|
printf("error launching BTC LP_coinsloop for port.%u\n",myport); |
|
|
printf("error launching BTC LP_coinsloop for port.%u\n",myport); |
|
|
exit(-1); |
|
|
exit(-1); |
|
|
} |
|
|
} |
|
|
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)LP_coinsloop,(void *)"KMD") != 0 ) |
|
|
if ( 0 && OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)LP_coinsloop,(void *)"KMD") != 0 ) |
|
|
{ |
|
|
{ |
|
|
printf("error launching KMD LP_coinsloop for port.%u\n",myport); |
|
|
printf("error launching KMD LP_coinsloop for port.%u\n",myport); |
|
|
exit(-1); |
|
|
exit(-1); |
|
|