fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-04-03 16:21:03 +00:00
Code Issues Projects Releases Wiki Activity

RESP3: latency.c updated.

Browse Source
This commit is contained in:
antirez 2018-11-30 17:10:51 +01:00
parent ddb98ad56f
commit 920611a419
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/latency.c
View File

@ -476,19 +476,19 @@ sds createLatencyReport(void) {
/* latencyCommand() helper to produce a time-delay reply for all the samples /* latencyCommand() helper to produce a time-delay reply for all the samples
* in memory for the specified time series. */ * in memory for the specified time series. */
void latencyCommandReplyWithSamples(client *c, struct latencyTimeSeries *ts) { void latencyCommandReplyWithSamples(client *c, struct latencyTimeSeries *ts) {
void *replylen = addDeferredMultiBulkLength(c); void *replylen = addReplyDeferredLen(c);
int samples = 0, j; int samples = 0, j;
for (j = 0; j < LATENCY_TS_LEN; j++) { for (j = 0; j < LATENCY_TS_LEN; j++) {
int i = (ts->idx + j) % LATENCY_TS_LEN; int i = (ts->idx + j) % LATENCY_TS_LEN;
if (ts->samples[i].time == 0) continue; if (ts->samples[i].time == 0) continue;
addReplyMultiBulkLen(c,2); addReplyArrayLen(c,2);
addReplyLongLong(c,ts->samples[i].time); addReplyLongLong(c,ts->samples[i].time);
addReplyLongLong(c,ts->samples[i].latency); addReplyLongLong(c,ts->samples[i].latency);
samples++; samples++;
} }
setDeferredMultiBulkLength(c,replylen,samples); setDeferredArrayLen(c,replylen,samples);
} }
/* latencyCommand() helper to produce the reply for the LATEST subcommand, /* latencyCommand() helper to produce the reply for the LATEST subcommand,
@ -497,14 +497,14 @@ void latencyCommandReplyWithLatestEvents(client *c) {
dictIterator *di; dictIterator *di;
dictEntry *de; dictEntry *de;
addReplyMultiBulkLen(c,dictSize(server.latency_events)); addReplyArrayLen(c,dictSize(server.latency_events));
di = dictGetIterator(server.latency_events); di = dictGetIterator(server.latency_events);
while((de = dictNext(di)) != NULL) { while((de = dictNext(di)) != NULL) {
char *event = dictGetKey(de); char *event = dictGetKey(de);
struct latencyTimeSeries *ts = dictGetVal(de); struct latencyTimeSeries *ts = dictGetVal(de);
int last = (ts->idx + LATENCY_TS_LEN - 1) % LATENCY_TS_LEN; int last = (ts->idx + LATENCY_TS_LEN - 1) % LATENCY_TS_LEN;
addReplyMultiBulkLen(c,4); addReplyArrayLen(c,4);
addReplyBulkCString(c,event); addReplyBulkCString(c,event);
addReplyLongLong(c,ts->samples[last].time); addReplyLongLong(c,ts->samples[last].time);
addReplyLongLong(c,ts->samples[last].latency); addReplyLongLong(c,ts->samples[last].latency);
@ -583,7 +583,7 @@ NULL
/* LATENCY HISTORY <event> */ /* LATENCY HISTORY <event> */
ts = dictFetchValue(server.latency_events,c->argv[2]->ptr); ts = dictFetchValue(server.latency_events,c->argv[2]->ptr);
if (ts == NULL) { if (ts == NULL) {
addReplyMultiBulkLen(c,0); addReplyArrayLen(c,0);
} else { } else {
latencyCommandReplyWithSamples(c,ts); latencyCommandReplyWithSamples(c,ts);
} }