jl777 7 years ago
parent
commit
99f4152c5d
  1. 4
      iguana/exchanges/LP_nativeDEX.c

4
iguana/exchanges/LP_nativeDEX.c

@ -315,7 +315,7 @@ int32_t LP_nanomsg_recvs(void *ctx)
//printf("check %s pubsock.%d\n",peer->ipaddr,peer->subsock); //printf("check %s pubsock.%d\n",peer->ipaddr,peer->subsock);
milli = OS_milliseconds(); milli = OS_milliseconds();
nonz += LP_sock_check("PULL",ctx,origipaddr,LP_mypubsock,peer->subsock,peer->ipaddr,1); nonz += LP_sock_check("PULL",ctx,origipaddr,LP_mypubsock,peer->subsock,peer->ipaddr,1);
if ( lastmilli > 0. && milli > lastmilli+1000 ) if ( lastmilli > 0. && milli > lastmilli+100 )
fprintf(stderr,">>>>>>>>>>>>>>>>> BIG latency lag %.3f milliseconds: (%s)\n",milli-lastmilli,LP_lastcommand!=0?LP_lastcommand:""); fprintf(stderr,">>>>>>>>>>>>>>>>> BIG latency lag %.3f milliseconds: (%s)\n",milli-lastmilli,LP_lastcommand!=0?LP_lastcommand:"");
lastmilli = milli; lastmilli = milli;
} }
@ -330,7 +330,7 @@ int32_t LP_nanomsg_recvs(void *ctx)
{ {
milli = OS_milliseconds(); milli = OS_milliseconds();
nonz += LP_sock_check("SUB",ctx,origipaddr,-1,LP_mypullsock,"127.0.0.1",1); nonz += LP_sock_check("SUB",ctx,origipaddr,-1,LP_mypullsock,"127.0.0.1",1);
if ( lastmilli > 0. && milli > lastmilli+1000 ) if ( lastmilli > 0. && milli > lastmilli+100 )
fprintf(stderr,">>>>>>>>>>>>>>>>> BIG latency lag %.3f milliseconds: (%s)\n",milli-lastmilli,LP_lastcommand!=0?LP_lastcommand:""); fprintf(stderr,">>>>>>>>>>>>>>>>> BIG latency lag %.3f milliseconds: (%s)\n",milli-lastmilli,LP_lastcommand!=0?LP_lastcommand:"");
lastmilli = milli; lastmilli = milli;
} }

Loading…
Cancel
Save