make some functions happy

Signed-off-by: hwware <wen.hui.ware@gmail.com>

Author: hwware

src/Makefile

@@ -423,7 +423,7 @@ ENGINE_NAME=valkey
 SERVER_NAME=$(ENGINE_NAME)-server$(PROG_SUFFIX)
 ENGINE_SENTINEL_NAME=$(ENGINE_NAME)-sentinel$(PROG_SUFFIX)
 ENGINE_TRACE_OBJ=trace/trace.o trace/trace_commands.o trace/trace_db.o trace/trace_cluster.o trace/trace_server.o trace/trace_rdb.o trace/trace_aof.o
-ENGINE_SERVER_OBJ=threads_mngr.o adlist.o vector.o quicklist.o ae.o anet.o dict.o hashtable.o kvstore.o server.o sds.o zmalloc.o lzf_c.o lzf_d.o pqsort.o zipmap.o sha1.o ziplist.o release.o memory_prefetch.o io_threads.o networking.o util.o object.o db.o replication.o rdb.o t_string.o t_list.o t_set.o t_zset.o t_hash.o config.o aof.o pubsub.o multi.o debug.o sort.o intset.o syncio.o cluster.o cluster_legacy.o cluster_slot_stats.o crc16.o cluster_migrateslots.o endianconv.o commandlog.o keyinfo.o eval.o bio.o rio.o rand.o memtest.o syscheck.o crcspeed.o crccombine.o crc64.o bitops.o sentinel.o notify.o setproctitle.o blocked.o hyperloglog.o latency.o sparkline.o valkey-check-rdb.o valkey-check-aof.o geo.o lazyfree.o module.o evict.o expire.o geohash.o geohash_helper.o childinfo.o allocator_defrag.o defrag.o siphash.o rax.o t_stream.o listpack.o localtime.o lolwut.o lolwut5.o lolwut6.o lolwut9.o acl.o tracking.o socket.o tls.o sha256.o timeout.o setcpuaffinity.o monotonic.o mt19937-64.o resp_parser.o call_reply.o script.o functions.o commands.o strl.o connection.o unix.o logreqres.o rdma.o scripting_engine.o entry.o vset.o lua/script_lua.o lua/function_lua.o lua/engine_lua.o lua/debug_lua.o
+ENGINE_SERVER_OBJ=threads_mngr.o adlist.o vector.o quicklist.o ae.o anet.o dict.o hashtable.o kvstore.o server.o sds.o zmalloc.o lzf_c.o lzf_d.o pqsort.o zipmap.o sha1.o ziplist.o release.o memory_prefetch.o io_threads.o networking.o util.o object.o db.o replication.o rdb.o t_string.o t_list.o t_set.o t_zset.o t_hash.o config.o aof.o pubsub.o multi.o debug.o sort.o intset.o syncio.o cluster.o cluster_legacy.o cluster_slot_stats.o crc16.o cluster_migrateslots.o endianconv.o commandlog.o eval.o bio.o rio.o rand.o memtest.o syscheck.o crcspeed.o crccombine.o crc64.o bitops.o sentinel.o notify.o setproctitle.o blocked.o hyperloglog.o latency.o sparkline.o valkey-check-rdb.o valkey-check-aof.o geo.o lazyfree.o module.o evict.o expire.o geohash.o geohash_helper.o childinfo.o allocator_defrag.o defrag.o siphash.o rax.o t_stream.o listpack.o localtime.o lolwut.o lolwut5.o lolwut6.o lolwut9.o acl.o tracking.o socket.o tls.o sha256.o timeout.o setcpuaffinity.o monotonic.o mt19937-64.o resp_parser.o call_reply.o script.o functions.o commands.o strl.o connection.o unix.o logreqres.o rdma.o scripting_engine.o entry.o vset.o lua/script_lua.o lua/function_lua.o lua/engine_lua.o lua/debug_lua.o
 ENGINE_SERVER_OBJ+=$(ENGINE_TRACE_OBJ)
 ENGINE_CLI_NAME=$(ENGINE_NAME)-cli$(PROG_SUFFIX)
 ENGINE_CLI_OBJ=anet.o adlist.o dict.o valkey-cli.o zmalloc.o release.o ae.o serverassert.o crcspeed.o crccombine.o crc64.o siphash.o crc16.o monotonic.o cli_common.o mt19937-64.o strl.o cli_commands.o sds.o util.o sha256.o

src/commandlog.c

@@ -169,6 +169,147 @@ void commandlogPushCurrentCommand(client *c, struct serverCommand *cmd) {
     commandlogPushEntryIfNeeded(c, argv, argc, net_output_bytes_curr_cmd, COMMANDLOG_TYPE_LARGE_REPLY);
 }
 
+// bigKeyInfo [string | set | hash | list | zset | xstream | all]
+void bigkeyInfoCommand(client *c) {
+    bool isDisplayAll = 0;
+    bool isDisplayString = 0;
+    bool isDisplaySet = 0;
+    bool isDisplayHash = 0;
+    bool isDisplayList = 0;
+    bool isDisplayZset = 0;
+    long totalLine = 0;
+
+    long count_string = listLength(server.string_bigkey_info);
+    long count_list = listLength(server.list_bigkey_info);
+    long count_hash = listLength(server.hash_bigkey_info);
+    long count_set = listLength(server.set_bigkey_info);
+    long count_zset = listLength(server.zset_bigkey_info);
+
+    if (c->argc == 1) {
+        isDisplayAll = 1;
+    } else {
+        int j = 1;
+        while (j < c->argc) {
+            char *opt = c->argv[j]->ptr;
+            if (!strcasecmp(opt, "string")) {
+                isDisplayString = 1;
+            } else if (!strcasecmp(opt, "set")) {
+                isDisplaySet = 1;
+            } else if (!strcasecmp(opt, "hash")) {
+                isDisplayHash = 1;
+            } else if (!strcasecmp(opt, "list")) {
+                isDisplayList = 1;
+            } else if (!strcasecmp(opt, "zset")) {
+                isDisplayZset = 1;
+            } else if (!strcasecmp(opt, "all")) {
+                isDisplayAll = 1;
+                break;
+            } else {
+                addReplyErrorFormat(c, "Unsupported option %s", opt);
+                return;
+            }
+            j++;
+        }
+    }
+
+    if (server.big_key_output < count_string) {
+        count_string = server.big_key_output;
+    }
+    if (server.big_key_output < count_list) {
+        count_list = server.big_key_output;
+    }
+    if (server.big_key_output < count_hash) {
+        count_hash = server.big_key_output;
+    }
+    if (server.big_key_output < count_set) {
+        count_set = server.big_key_output;
+    }
+    if (server.big_key_output < count_zset) {
+        count_zset = server.big_key_output;
+    }
+
+    if (isDisplayAll | isDisplayString) {
+        totalLine += count_string;
+    }
+    if (isDisplayAll | isDisplaySet) {
+        totalLine += count_set;
+    }
+    if (isDisplayAll | isDisplayHash) {
+        totalLine += count_hash;
+    }
+    if (isDisplayAll | isDisplayList) {
+        totalLine += count_list;
+    }
+    if (isDisplayAll | isDisplayZset) {
+        totalLine += count_zset;
+    }
+
+    addReplyArrayLen(c, totalLine);
+
+    listIter li;
+    listNode *ln;
+
+    if (isDisplayAll | isDisplayString) {
+        listRewindTail(server.string_bigkey_info, &li);
+        while (count_string--) {
+            ln = listNext(&li);
+            bigkeyEntry *bke = ln->value;
+            addReplyArrayLen(c, 3);
+            addReplyLongLong(c, bke->value);
+            addReplyBulkCBuffer(c, bke->key->ptr, sdslen(bke->key->ptr));
+            addReplyBulkCString(c, "string");
+        }
+    }
+
+    if (isDisplayAll | isDisplayList) {
+        listRewindTail(server.list_bigkey_info, &li);
+        while (count_list--) {
+            ln = listNext(&li);
+            bigkeyEntry *bke = ln->value;
+            addReplyArrayLen(c, 3);
+            addReplyLongLong(c, bke->value);
+            addReplyBulkCBuffer(c, bke->key->ptr, sdslen(bke->key->ptr));
+            addReplyBulkCString(c, "list");
+        }
+    }
+
+    if (isDisplayAll | isDisplayHash) {
+        listRewindTail(server.hash_bigkey_info, &li);
+        while (count_hash--) {
+            ln = listNext(&li);
+            bigkeyEntry *bke = ln->value;
+            addReplyArrayLen(c, 3);
+            addReplyLongLong(c, bke->value);
+            addReplyBulkCBuffer(c, bke->key->ptr, sdslen(bke->key->ptr));
+            addReplyBulkCString(c, "hash");
+        }
+    }
+
+    if (isDisplayAll | isDisplaySet) {
+        listRewindTail(server.set_bigkey_info, &li);
+        while (count_set--) {
+            ln = listNext(&li);
+            bigkeyEntry *bke = ln->value;
+            addReplyArrayLen(c, 3);
+            addReplyLongLong(c, bke->value);
+            addReplyBulkCBuffer(c, bke->key->ptr, sdslen(bke->key->ptr));
+            addReplyBulkCString(c, "set");
+        }
+    }
+
+    if (isDisplayAll | isDisplayZset) {
+        listRewindTail(server.list_bigkey_info, &li);
+        while (count_zset--) {
+            ln = listNext(&li);
+            bigkeyEntry *bke = ln->value;
+            addReplyArrayLen(c, 3);
+            addReplyLongLong(c, bke->value);
+            addReplyBulkCBuffer(c, bke->key->ptr, sdslen(bke->key->ptr));
+            addReplyBulkCString(c, "Sorted Set");
+        }
+    }
+}
+
 /* The SLOWLOG command. Implements all the subcommands needed to handle the
  * slow log. */
 void slowlogCommand(client *c) {