From 8f9958dc24fa5992d3d10f6b9caf999e1beee4e5 Mon Sep 17 00:00:00 2001 From: Huang Zw Date: Tue, 9 Feb 2021 01:29:32 +0800 Subject: Fix typo and some out of date comments (#8449) Fix typo and some out of date comments --- src/defrag.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'src/defrag.c') diff --git a/src/defrag.c b/src/defrag.c index db797711e..2b28d523d 100644 --- a/src/defrag.c +++ b/src/defrag.c @@ -638,7 +638,7 @@ int defragRaxNode(raxNode **noderef) { } /* returns 0 if no more work needs to be been done, and 1 if time is up and more work is needed. */ -int scanLaterStraemListpacks(robj *ob, unsigned long *cursor, long long endtime, long long *defragged) { +int scanLaterStreamListpacks(robj *ob, unsigned long *cursor, long long endtime, long long *defragged) { static unsigned char last[sizeof(streamID)]; raxIterator ri; long iterations = 0; @@ -958,7 +958,7 @@ int defragLaterItem(dictEntry *de, unsigned long *cursor, long long endtime) { } else if (ob->type == OBJ_HASH) { server.stat_active_defrag_hits += scanLaterHash(ob, cursor); } else if (ob->type == OBJ_STREAM) { - return scanLaterStraemListpacks(ob, cursor, endtime, &server.stat_active_defrag_hits); + return scanLaterStreamListpacks(ob, cursor, endtime, &server.stat_active_defrag_hits); } else if (ob->type == OBJ_MODULE) { return moduleLateDefrag(dictGetKey(de), ob, cursor, endtime, &server.stat_active_defrag_hits); } else { -- cgit v1.2.1