108         memset(ts->samples,0,sizeof(ts->samples));  in latencyAddSample()
117     if (ts->samples[prev].time == now) {  in latencyAddSample()
118         if (latency > ts->samples[prev].latency)  in latencyAddSample()
119             ts->samples[prev].latency = latency;  in latencyAddSample()
123     ts->samples[ts->idx].time = time(NULL);  in latencyAddSample()
124     ts->samples[ts->idx].latency = latency;  in latencyAddSample()
170     ls->samples = 0;  in analyzeLatencyForEvent()
177         if (ts->samples[j].time == 0) continue;  in analyzeLatencyForEvent()
178         ls->samples++;  in analyzeLatencyForEvent()
179         if (ls->samples == 1) {  in analyzeLatencyForEvent()
180             ls->min = ls->max = ts->samples[j].latency;  in analyzeLatencyForEvent()
182             if (ls->min > ts->samples[j].latency)  in analyzeLatencyForEvent()
183                 ls->min = ts->samples[j].latency;  in analyzeLatencyForEvent()
184             if (ls->max < ts->samples[j].latency)  in analyzeLatencyForEvent()
185                 ls->max = ts->samples[j].latency;  in analyzeLatencyForEvent()
187         sum += ts->samples[j].latency;  in analyzeLatencyForEvent()
190         if (ls->period == 0 || ts->samples[j].time < ls->period)  in analyzeLatencyForEvent()
191             ls->period = ts->samples[j].time;  in analyzeLatencyForEvent()
197     if (ls->samples) {  in analyzeLatencyForEvent()
198         ls->avg = sum / ls->samples;  in analyzeLatencyForEvent()
208         if (ts->samples[j].time == 0) continue;  in analyzeLatencyForEvent()
209         delta = (int64_t)ls->avg - ts->samples[j].latency;  in analyzeLatencyForEvent()
213     if (ls->samples) ls->mad = sum / ls->samples;  in analyzeLatencyForEvent()
268             ls.samples,  in createLatencyReport()
271             (double) ls.period/ls.samples,  in createLatencyReport()
480     int samples = 0, j;  in latencyCommandReplyWithSamples()  local
485         if (ts->samples[i].time == 0) continue;  in latencyCommandReplyWithSamples()
487         addReplyLongLong(c,ts->samples[i].time);  in latencyCommandReplyWithSamples()
488         addReplyLongLong(c,ts->samples[i].latency);  in latencyCommandReplyWithSamples()
489         samples++;  in latencyCommandReplyWithSamples()
491     setDeferredMultiBulkLength(c,replylen,samples);  in latencyCommandReplyWithSamples()
509         addReplyLongLong(c,ts->samples[last].time);  in latencyCommandReplyWithLatestEvents()
510         addReplyLongLong(c,ts->samples[last].latency);  in latencyCommandReplyWithLatestEvents()
528         if (ts->samples[i].time == 0) continue;  in latencyCommandGenSparkeline()
531             min = max = ts->samples[i].latency;  in latencyCommandGenSparkeline()
533             if (ts->samples[i].latency > max) max = ts->samples[i].latency;  in latencyCommandGenSparkeline()
534             if (ts->samples[i].latency < min) min = ts->samples[i].latency;  in latencyCommandGenSparkeline()
538         elapsed = time(NULL) - ts->samples[i].time;  in latencyCommandGenSparkeline()
547         sparklineSequenceAddSample(seq,ts->samples[i].latency,buf);  in latencyCommandGenSparkeline()