summaryrefslogtreecommitdiff
path: root/src/defrag.c
diff options
context:
space:
mode:
authorHuang Zw <huang_zhw@126.com>2021-02-09 01:29:32 +0800
committerGitHub <noreply@github.com>2021-02-08 09:29:32 -0800
commit8f9958dc24fa5992d3d10f6b9caf999e1beee4e5 (patch)
tree864db87d132a88429c5e6ed6b080581e67d255b1 /src/defrag.c
parentdbcc0a85d070f94f5c524a4bbdd3e492c32e845b (diff)
downloadredis-8f9958dc24fa5992d3d10f6b9caf999e1beee4e5.tar.gz
Fix typo and some out of date comments (#8449)
Fix typo and some out of date comments
Diffstat (limited to 'src/defrag.c')
-rw-r--r--src/defrag.c4
1 files changed, 2 insertions, 2 deletions
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 {