99     struct latencyTimeSeries *ts = dictFetchValue(server.latency_events,event);  in latencyAddSample()  local
104     if (ts == NULL) {  in latencyAddSample()
105         ts = zmalloc(sizeof(*ts));  in latencyAddSample()
106         ts->idx = 0;  in latencyAddSample()
107         ts->max = 0;  in latencyAddSample()
108         memset(ts->samples,0,sizeof(ts->samples));  in latencyAddSample()
109         dictAdd(server.latency_events,zstrdup(event),ts);  in latencyAddSample()
114     prev = (ts->idx + LATENCY_TS_LEN - 1) % LATENCY_TS_LEN;  in latencyAddSample()
115     if (ts->samples[prev].time == now) {  in latencyAddSample()
116         if (latency > ts->samples[prev].latency)  in latencyAddSample()
117             ts->samples[prev].latency = latency;  in latencyAddSample()
121     ts->samples[ts->idx].time = time(NULL);  in latencyAddSample()
122     ts->samples[ts->idx].latency = latency;  in latencyAddSample()
123     if (latency > ts->max) ts->max = latency;  in latencyAddSample()
125     ts->idx++;  in latencyAddSample()
126     if (ts->idx == LATENCY_TS_LEN) ts->idx = 0;  in latencyAddSample()
160     struct latencyTimeSeries *ts = dictFetchValue(server.latency_events,event);  in analyzeLatencyForEvent()  local
164     ls->all_time_high = ts ? ts->max : 0;  in analyzeLatencyForEvent()
171     if (!ts) return;  in analyzeLatencyForEvent()
176         if (ts->samples[j].time == 0) continue;  in analyzeLatencyForEvent()
179             ls->min = ls->max = ts->samples[j].latency;  in analyzeLatencyForEvent()
181             if (ls->min > ts->samples[j].latency)  in analyzeLatencyForEvent()
182                 ls->min = ts->samples[j].latency;  in analyzeLatencyForEvent()
183             if (ls->max < ts->samples[j].latency)  in analyzeLatencyForEvent()
184                 ls->max = ts->samples[j].latency;  in analyzeLatencyForEvent()
186         sum += ts->samples[j].latency;  in analyzeLatencyForEvent()
189         if (ls->period == 0 || ts->samples[j].time < ls->period)  in analyzeLatencyForEvent()
190             ls->period = ts->samples[j].time;  in analyzeLatencyForEvent()
207         if (ts->samples[j].time == 0) continue;  in analyzeLatencyForEvent()
208         delta = (int64_t)ls->avg - ts->samples[j].latency;  in analyzeLatencyForEvent()
254         struct latencyTimeSeries *ts = dictGetVal(de);  in createLatencyReport()  local
257         if (ts == NULL) continue;  in createLatencyReport()
271             (unsigned long) ts->max);  in createLatencyReport()
477 void latencyCommandReplyWithSamples(client *c, struct latencyTimeSeries *ts) {  in latencyCommandReplyWithSamples()  argument
482         int i = (ts->idx + j) % LATENCY_TS_LEN;  in latencyCommandReplyWithSamples()
484         if (ts->samples[i].time == 0) continue;  in latencyCommandReplyWithSamples()
486         addReplyLongLong(c,ts->samples[i].time);  in latencyCommandReplyWithSamples()
487         addReplyLongLong(c,ts->samples[i].latency);  in latencyCommandReplyWithSamples()
503         struct latencyTimeSeries *ts = dictGetVal(de);  in latencyCommandReplyWithLatestEvents()  local
504         int last = (ts->idx + LATENCY_TS_LEN - 1) % LATENCY_TS_LEN;  in latencyCommandReplyWithLatestEvents()
508         addReplyLongLong(c,ts->samples[last].time);  in latencyCommandReplyWithLatestEvents()
509         addReplyLongLong(c,ts->samples[last].latency);  in latencyCommandReplyWithLatestEvents()
510         addReplyLongLong(c,ts->max);  in latencyCommandReplyWithLatestEvents()
516 sds latencyCommandGenSparkeline(char *event, struct latencyTimeSeries *ts) {  in latencyCommandGenSparkeline()  argument
523         int i = (ts->idx + j) % LATENCY_TS_LEN;  in latencyCommandGenSparkeline()
527         if (ts->samples[i].time == 0) continue;  in latencyCommandGenSparkeline()
530             min = max = ts->samples[i].latency;  in latencyCommandGenSparkeline()
532             if (ts->samples[i].latency > max) max = ts->samples[i].latency;  in latencyCommandGenSparkeline()
533             if (ts->samples[i].latency < min) min = ts->samples[i].latency;  in latencyCommandGenSparkeline()
537         elapsed = time(NULL) - ts->samples[i].time;  in latencyCommandGenSparkeline()
546         sparklineSequenceAddSample(seq,ts->samples[i].latency,buf);  in latencyCommandGenSparkeline()
551         (unsigned long) max, (unsigned long) min, (unsigned long) ts->max);  in latencyCommandGenSparkeline()
568     struct latencyTimeSeries *ts;  in latencyCommand()  local
572         ts = dictFetchValue(server.latency_events,c->argv[2]->ptr);  in latencyCommand()
573         if (ts == NULL) {  in latencyCommand()
576             latencyCommandReplyWithSamples(c,ts);  in latencyCommand()
586         ts = dictGetVal(de);  in latencyCommand()
589         graph = latencyCommandGenSparkeline(event,ts);  in latencyCommand()