|
@ -319,11 +319,6 @@ void LP_mainloop(char *myipaddr,struct LP_peerinfo *mypeer,uint16_t mypubport,in |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
//LP_privkey_updates(pubsock,passphrase);
|
|
|
//LP_privkey_updates(pubsock,passphrase);
|
|
|
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)stats_rpcloop,(void *)&myport) != 0 ) |
|
|
|
|
|
{ |
|
|
|
|
|
printf("error launching stats rpcloop for port.%u\n",myport); |
|
|
|
|
|
exit(-1); |
|
|
|
|
|
} |
|
|
|
|
|
while ( 1 ) |
|
|
while ( 1 ) |
|
|
{ |
|
|
{ |
|
|
if ( 0 && (rand() % 100) == 0 ) |
|
|
if ( 0 && (rand() % 100) == 0 ) |
|
@ -381,6 +376,11 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,double profit |
|
|
nn_setsockopt(pullsock,NN_SOL_SOCKET,NN_RCVBUF,&maxsize,sizeof(maxsize)); |
|
|
nn_setsockopt(pullsock,NN_SOL_SOCKET,NN_RCVBUF,&maxsize,sizeof(maxsize)); |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)stats_rpcloop,(void *)&myport) != 0 ) |
|
|
|
|
|
{ |
|
|
|
|
|
printf("error launching stats rpcloop for port.%u\n",myport); |
|
|
|
|
|
exit(-1); |
|
|
|
|
|
} |
|
|
if ( IAMLP != 0 ) |
|
|
if ( IAMLP != 0 ) |
|
|
{ |
|
|
{ |
|
|
if ( myipaddr != 0 ) |
|
|
if ( myipaddr != 0 ) |
|
|