108         memset(ts->samples,0,sizeof(ts->samples));  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()
169     ls->samples = 0;  in analyzeLatencyForEvent()
176         if (ts->samples[j].time == 0) continue;  in analyzeLatencyForEvent()
177         ls->samples++;  in analyzeLatencyForEvent()
178         if (ls->samples == 1) {  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()
196     if (ls->samples) {  in analyzeLatencyForEvent()
197         ls->avg = sum / ls->samples;  in analyzeLatencyForEvent()
207         if (ts->samples[j].time == 0) continue;  in analyzeLatencyForEvent()
208         delta = (int64_t)ls->avg - ts->samples[j].latency;  in analyzeLatencyForEvent()
212     if (ls->samples) ls->mad = sum / ls->samples;  in analyzeLatencyForEvent()
267             ls.samples,  in createLatencyReport()
270             (double) ls.period/ls.samples,  in createLatencyReport()
479     int samples = 0, j;  in latencyCommandReplyWithSamples()  local
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()
488         samples++;  in latencyCommandReplyWithSamples()
490     setDeferredMultiBulkLength(c,replylen,samples);  in latencyCommandReplyWithSamples()
508         addReplyLongLong(c,ts->samples[last].time);  in latencyCommandReplyWithLatestEvents()
509         addReplyLongLong(c,ts->samples[last].latency);  in latencyCommandReplyWithLatestEvents()
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()