This commit is contained in:
jl777
2016-10-26 08:42:31 -03:00
parent 0be045f33a
commit 4563911d3d
3 changed files with 4 additions and 3 deletions

View File

@@ -221,7 +221,7 @@ try_again:
free(s.ptr); free(s.ptr);
return(0); return(0);
} }
else if ( numretries >= 5 ) else if ( numretries >= 6 )
{ {
printf("Maximum number of retries exceeded!\n"); printf("Maximum number of retries exceeded!\n");
free(s.ptr); free(s.ptr);

View File

@@ -118,7 +118,7 @@ void komodo_gateway_iteration(char *symbol)
if ( (KMDHEIGHT % 1000) == 0 ) if ( (KMDHEIGHT % 1000) == 0 )
fprintf(stderr,"%s.%d ",symbol,KMDHEIGHT); fprintf(stderr,"%s.%d ",symbol,KMDHEIGHT);
komodo_gateway_block(symbol,KMDHEIGHT,port); komodo_gateway_block(symbol,KMDHEIGHT,port);
usleep(1000); usleep(10000);
} }
} }
free_json(infoobj); free_json(infoobj);

View File

@@ -753,7 +753,8 @@ void StartRPCThreads()
g_rpcSignals.Started(); g_rpcSignals.Started();
// Launch one async rpc worker. The ability to launch multiple workers is not recommended at present and thus the option is disabled. // Launch one async rpc worker. The ability to launch multiple workers is not recommended at present and thus the option is disabled.
getAsyncRPCQueue()->addWorker(); for (int i=0; i<32; i++)
getAsyncRPCQueue()->addWorker();
/* /*
int n = GetArg("-rpcasyncthreads", 1); int n = GetArg("-rpcasyncthreads", 1);
if (n<1) { if (n<1) {