caleb-brown/redict
1
0
Fork 0
mirror of https://codeberg.org/redict/redict.git synced 2025-01-23 00:28:26 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

getting rid of duplicated code

Browse Source
This commit is contained in:
charsyam 2018-02-14 00:12:13 +09:00
parent ae29bcd8e2
commit 9d41436115
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/latency.c
View File

@ -109,19 +109,19 @@ void latencyAddSample(char *event, mstime_t latency) {
dictAdd(server.latency_events,zstrdup(event),ts); dictAdd(server.latency_events,zstrdup(event),ts);
} }
if (latency > ts->max) ts->max = latency;
/* If the previous sample is in the same second, we update our old sample /* If the previous sample is in the same second, we update our old sample
* if this latency is > of the old one, or just return. */ * if this latency is > of the old one, or just return. */
prev = (ts->idx + LATENCY_TS_LEN - 1) % LATENCY_TS_LEN; prev = (ts->idx + LATENCY_TS_LEN - 1) % LATENCY_TS_LEN;
if (ts->samples[prev].time == now) { if (ts->samples[prev].time == now) {
if (latency > ts->samples[prev].latency) if (latency > ts->samples[prev].latency)
ts->samples[prev].latency = latency; ts->samples[prev].latency = latency;
if (latency > ts->max) ts->max = latency;
return; return;
} }
ts->samples[ts->idx].time = time(NULL); ts->samples[ts->idx].time = time(NULL);
ts->samples[ts->idx].latency = latency; ts->samples[ts->idx].latency = latency;
if (latency > ts->max) ts->max = latency;
ts->idx++; ts->idx++;
if (ts->idx == LATENCY_TS_LEN) ts->idx = 0; if (ts->idx == LATENCY_TS_LEN) ts->idx = 0;