|
|
@ -1362,7 +1362,7 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,uint16_t mybu |
|
|
|
printf("error launching LP_psockloop for (%s)\n",myipaddr); |
|
|
|
exit(-1); |
|
|
|
} |
|
|
|
if ( 0 && OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)LP_reserved_msgs,(void *)myipaddr) != 0 ) |
|
|
|
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)LP_reserved_msgs,(void *)myipaddr) != 0 ) |
|
|
|
{ |
|
|
|
printf("error launching LP_reserved_msgs for (%s)\n",myipaddr); |
|
|
|
exit(-1); |
|
|
@ -1377,7 +1377,7 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,uint16_t mybu |
|
|
|
printf("error launching command_rpcloop for ctx.%p\n",ctx); |
|
|
|
exit(-1); |
|
|
|
} |
|
|
|
if ( 0 && OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)queue_loop,ctx) != 0 ) |
|
|
|
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)queue_loop,ctx) != 0 ) |
|
|
|
{ |
|
|
|
printf("error launching queue_loop for ctx.%p\n",ctx); |
|
|
|
exit(-1); |
|
|
|