jl777 7 years ago
parent
commit
0b02309a32
  1. 10
      iguana/exchanges/LP_stats.c

10
iguana/exchanges/LP_stats.c

@ -39,9 +39,9 @@ void LP_tradecommand_log(cJSON *argjson)
} }
uint32_t LP_requests,LP_reserveds,LP_connects,LP_connecteds,LP_tradestatuses,LP_parse_errors,LP_unknowns,LP_duplicates,LP_numridqids; uint32_t LP_requests,LP_reserveds,LP_connects,LP_connecteds,LP_tradestatuses,LP_parse_errors,LP_unknowns,LP_duplicates,LP_numridqids;
uint64_t Ridqids[128]; uint64_t Ridqids[16];
int32_t LP_statslog_parsequote(cJSON *lineobj) int32_t LP_statslog_parsequote(char *method,cJSON *lineobj)
{ {
int32_t i,duplicate=0; struct LP_quoteinfo Q; uint64_t ridqid; int32_t i,duplicate=0; struct LP_quoteinfo Q; uint64_t ridqid;
memset(&Q,0,sizeof(Q)); memset(&Q,0,sizeof(Q));
@ -66,7 +66,7 @@ int32_t LP_statslog_parsequote(cJSON *lineobj)
{ {
Ridqids[LP_numridqids % (sizeof(Ridqids)/sizeof(*Ridqids))] = ridqid; Ridqids[LP_numridqids % (sizeof(Ridqids)/sizeof(*Ridqids))] = ridqid;
LP_numridqids++; LP_numridqids++;
printf("connected requestid.%u quoteid.%u -> %d\n",Q.R.requestid,Q.R.quoteid,(int32_t)(LP_numridqids % (sizeof(Ridqids)/sizeof(*Ridqids)))); printf("%10s requestid.%-10u quoteid.%-10u -> %d\n",method,Q.R.requestid,Q.R.quoteid,(int32_t)(LP_numridqids % (sizeof(Ridqids)/sizeof(*Ridqids))));
} }
} }
return(duplicate == 0); return(duplicate == 0);
@ -83,12 +83,12 @@ void LP_statslog_parseline(cJSON *lineobj)
LP_reserveds++; LP_reserveds++;
else if ( strcmp(method,"connect") == 0 ) else if ( strcmp(method,"connect") == 0 )
{ {
LP_statslog_parsequote(lineobj); LP_statslog_parsequote(method,lineobj);
LP_connects++; LP_connects++;
} }
else if ( strcmp(method,"connected") == 0 ) else if ( strcmp(method,"connected") == 0 )
{ {
LP_statslog_parsequote(lineobj); LP_statslog_parsequote(method,lineobj);
LP_connecteds++; LP_connecteds++;
} }
else if ( strcmp(method,"tradestatus") == 0 ) else if ( strcmp(method,"tradestatus") == 0 )

Loading…
Cancel
Save