From 0da65da7b0ebaa0129f91fd797f30c4c022bbbbd Mon Sep 17 00:00:00 2001 From: jl777 Date: Tue, 7 Nov 2017 23:33:14 +0200 Subject: [PATCH] Test --- iguana/exchanges/LP_nativeDEX.c | 6 ++++++ iguana/exchanges/stats.c | 8 ++++---- 2 files changed, 10 insertions(+), 4 deletions(-) diff --git a/iguana/exchanges/LP_nativeDEX.c b/iguana/exchanges/LP_nativeDEX.c index 0ba43d0b2..76e348c68 100644 --- a/iguana/exchanges/LP_nativeDEX.c +++ b/iguana/exchanges/LP_nativeDEX.c @@ -1179,6 +1179,12 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,uint16_t mybu usleep(1000); else if ( IAMLP == 0 ) usleep(1000); + if ( (rand() % 10000) == 0 ) + { + printf("rpc port reset test\n"); + closesocket(LP_bindsock); + LP_bindsock = -1; + } } #endif } diff --git a/iguana/exchanges/stats.c b/iguana/exchanges/stats.c index cd1249c0b..24f78f5bf 100644 --- a/iguana/exchanges/stats.c +++ b/iguana/exchanges/stats.c @@ -743,7 +743,7 @@ extern int32_t IAMLP; int32_t LP_bindsock = -1; void stats_rpcloop(void *args) { - static uint32_t counter; + //static uint32_t counter; uint16_t port; int32_t retval,sock; socklen_t clilen; struct sockaddr_in cli_addr; uint32_t ipbits,localhostbits; struct rpcrequest_info *req,*req2,*rtmp; if ( (port= *(uint16_t *)args) == 0 ) port = 7779; @@ -755,7 +755,7 @@ void stats_rpcloop(void *args) { while ( (LP_bindsock= iguana_socket(1,"0.0.0.0",port)) < 0 ) usleep(10000); - if ( counter++ < 1 ) + //if ( counter++ < 1 ) printf(">>>>>>>>>> DEX stats 127.0.0.1:%d bind sock.%d DEX stats API enabled <<<<<<<<<\n",port,LP_bindsock); } clilen = sizeof(cli_addr); @@ -763,7 +763,7 @@ void stats_rpcloop(void *args) if ( sock < 0 ) { printf("iguana_rpcloop ERROR on accept usock.%d errno %d %s\n",sock,errno,strerror(errno)); - close(LP_bindsock); + closesocket(LP_bindsock); LP_bindsock = -1; continue; } @@ -776,7 +776,7 @@ continue; if ( (retval= OS_thread_create(&req->T,NULL,(void *)LP_rpc_processreq,req)) != 0 ) { printf("error launching rpc handler on port %d, retval.%d\n",port,retval); - close(LP_bindsock); + closesocket(LP_bindsock); LP_bindsock = -1; portable_mutex_lock(&LP_gcmutex); DL_FOREACH_SAFE(LP_garbage_collector,req2,rtmp)