diff options
Diffstat (limited to 'examples/redis-unstable/src/debug.c')
| -rw-r--r-- | examples/redis-unstable/src/debug.c | 2849 |
1 files changed, 0 insertions, 2849 deletions
diff --git a/examples/redis-unstable/src/debug.c b/examples/redis-unstable/src/debug.c deleted file mode 100644 index c239bba..0000000 --- a/examples/redis-unstable/src/debug.c +++ /dev/null @@ -1,2849 +0,0 @@ -/* - * Copyright (c) 2009-Present, Redis Ltd. - * All rights reserved. - * - * Copyright (c) 2024-present, Valkey contributors. - * All rights reserved. - * - * Licensed under your choice of (a) the Redis Source Available License 2.0 - * (RSALv2); or (b) the Server Side Public License v1 (SSPLv1); or (c) the - * GNU Affero General Public License v3 (AGPLv3). - * - * Portions of this file are available under BSD3 terms; see REDISCONTRIBUTIONS for more information. - */ - -#include "server.h" -#include "util.h" -#include "sha1.h" /* SHA1 is used for DEBUG DIGEST */ -#include "crc64.h" -#include "bio.h" -#include "quicklist.h" -#include "fpconv_dtoa.h" -#include "fast_float_strtod.h" -#include "cluster.h" -#include "threads_mngr.h" -#include "script.h" -#include "cluster_asm.h" - -#include <arpa/inet.h> -#include <signal.h> -#include <dlfcn.h> -#include <fcntl.h> -#include <sys/mman.h> -#include <unistd.h> - -#ifdef HAVE_BACKTRACE -#include <execinfo.h> -#ifndef __OpenBSD__ -#include <ucontext.h> -#else -typedef ucontext_t sigcontext_t; -#endif -#endif /* HAVE_BACKTRACE */ - -#ifdef __CYGWIN__ -#ifndef SA_ONSTACK -#define SA_ONSTACK 0x08000000 -#endif -#endif - -#if defined(__APPLE__) && defined(__arm64__) -#include <mach/mach.h> -#endif - -/* Globals */ -static int bug_report_start = 0; /* True if bug report header was already logged. */ -static pthread_mutex_t bug_report_start_mutex; -static pthread_mutexattr_t bug_report_start_attr; - -/* Mutex for a case when two threads crash at the same time. */ -static pthread_mutex_t signal_handler_lock; -static pthread_mutexattr_t signal_handler_lock_attr; -static volatile int signal_handler_lock_initialized = 0; -/* Forward declarations */ -int bugReportStart(void); -void printCrashReport(void); -void bugReportEnd(int killViaSignal, int sig); -void logStackTrace(void *eip, int uplevel, int current_thread); -void sigalrmSignalHandler(int sig, siginfo_t *info, void *secret); - -/* ================================= Debugging ============================== */ - -/* Compute the sha1 of string at 's' with 'len' bytes long. - * The SHA1 is then xored against the string pointed by digest. - * Since xor is commutative, this operation is used in order to - * "add" digests relative to unordered elements. - * - * So digest(a,b,c,d) will be the same of digest(b,a,c,d) */ -void xorDigest(unsigned char *digest, const void *ptr, size_t len) { - SHA1_CTX ctx; - unsigned char hash[20]; - int j; - - SHA1Init(&ctx); - SHA1Update(&ctx,ptr,len); - SHA1Final(hash,&ctx); - - for (j = 0; j < 20; j++) - digest[j] ^= hash[j]; -} - -void xorStringObjectDigest(unsigned char *digest, robj *o) { - o = getDecodedObject(o); - xorDigest(digest,o->ptr,sdslen(o->ptr)); - decrRefCount(o); -} - -/* This function instead of just computing the SHA1 and xoring it - * against digest, also perform the digest of "digest" itself and - * replace the old value with the new one. - * - * So the final digest will be: - * - * digest = SHA1(digest xor SHA1(data)) - * - * This function is used every time we want to preserve the order so - * that digest(a,b,c,d) will be different than digest(b,c,d,a) - * - * Also note that mixdigest("foo") followed by mixdigest("bar") - * will lead to a different digest compared to "fo", "obar". - */ -void mixDigest(unsigned char *digest, const void *ptr, size_t len) { - SHA1_CTX ctx; - - xorDigest(digest,ptr,len); - SHA1Init(&ctx); - SHA1Update(&ctx,digest,20); - SHA1Final(digest,&ctx); -} - -void mixStringObjectDigest(unsigned char *digest, robj *o) { - o = getDecodedObject(o); - mixDigest(digest,o->ptr,sdslen(o->ptr)); - decrRefCount(o); -} - -/* This function computes the digest of a data structure stored in the - * object 'o'. It is the core of the DEBUG DIGEST command: when taking the - * digest of a whole dataset, we take the digest of the key and the value - * pair, and xor all those together. - * - * Note that this function does not reset the initial 'digest' passed, it - * will continue mixing this object digest to anything that was already - * present. */ -void xorObjectDigest(redisDb *db, robj *keyobj, unsigned char *digest, robj *o) { - uint32_t aux = htonl(o->type); - mixDigest(digest,&aux,sizeof(aux)); - long long expiretime = getExpire(db, keyobj->ptr, NULL); - char buf[128]; - - /* Save the key and associated value */ - if (o->type == OBJ_STRING) { - mixStringObjectDigest(digest,o); - } else if (o->type == OBJ_LIST) { - listTypeIterator li; - listTypeEntry entry; - listTypeInitIterator(&li, o, 0, LIST_TAIL); - while(listTypeNext(&li, &entry)) { - robj *eleobj = listTypeGet(&entry); - mixStringObjectDigest(digest,eleobj); - decrRefCount(eleobj); - } - listTypeResetIterator(&li); - } else if (o->type == OBJ_SET) { - setTypeIterator si; - sds sdsele; - setTypeInitIterator(&si, o); - while((sdsele = setTypeNextObject(&si)) != NULL) { - xorDigest(digest,sdsele,sdslen(sdsele)); - sdsfree(sdsele); - } - setTypeResetIterator(&si); - } else if (o->type == OBJ_ZSET) { - unsigned char eledigest[20]; - - if (o->encoding == OBJ_ENCODING_LISTPACK) { - unsigned char *zl = o->ptr; - unsigned char *eptr, *sptr; - unsigned char *vstr; - unsigned int vlen; - long long vll; - double score; - - eptr = lpSeek(zl,0); - serverAssert(eptr != NULL); - sptr = lpNext(zl,eptr); - serverAssert(sptr != NULL); - - while (eptr != NULL) { - vstr = lpGetValue(eptr,&vlen,&vll); - score = zzlGetScore(sptr); - - memset(eledigest,0,20); - if (vstr != NULL) { - mixDigest(eledigest,vstr,vlen); - } else { - ll2string(buf,sizeof(buf),vll); - mixDigest(eledigest,buf,strlen(buf)); - } - const int len = fpconv_dtoa(score, buf); - buf[len] = '\0'; - mixDigest(eledigest,buf,strlen(buf)); - xorDigest(digest,eledigest,20); - zzlNext(zl,&eptr,&sptr); - } - } else if (o->encoding == OBJ_ENCODING_SKIPLIST) { - zset *zs = o->ptr; - dictIterator di; - dictEntry *de; - - dictInitIterator(&di, zs->dict); - while((de = dictNext(&di)) != NULL) { - zskiplistNode *znode = dictGetKey(de); - sds sdsele = zslGetNodeElement(znode); - const int len = fpconv_dtoa(znode->score, buf); - buf[len] = '\0'; - memset(eledigest,0,20); - mixDigest(eledigest,sdsele,sdslen(sdsele)); - mixDigest(eledigest,buf,strlen(buf)); - xorDigest(digest,eledigest,20); - } - dictResetIterator(&di); - } else { - serverPanic("Unknown sorted set encoding"); - } - } else if (o->type == OBJ_HASH) { - hashTypeIterator hi; - hashTypeInitIterator(&hi, o); - while (hashTypeNext(&hi, 0) != C_ERR) { - unsigned char eledigest[20]; - sds sdsele; - - /* field */ - memset(eledigest,0,20); - sdsele = hashTypeCurrentObjectNewSds(&hi,OBJ_HASH_KEY); - mixDigest(eledigest,sdsele,sdslen(sdsele)); - sdsfree(sdsele); - /* val */ - sdsele = hashTypeCurrentObjectNewSds(&hi,OBJ_HASH_VALUE); - mixDigest(eledigest,sdsele,sdslen(sdsele)); - sdsfree(sdsele); - /* hash-field expiration (HFE) */ - if (hi.expire_time != EB_EXPIRE_TIME_INVALID) - xorDigest(eledigest,"!!hexpire!!",11); - xorDigest(digest,eledigest,20); - } - hashTypeResetIterator(&hi); - } else if (o->type == OBJ_STREAM) { - streamIterator si; - streamIteratorStart(&si,o->ptr,NULL,NULL,0); - streamID id; - int64_t numfields; - - while(streamIteratorGetID(&si,&id,&numfields)) { - sds itemid = sdscatfmt(sdsempty(),"%U.%U",id.ms,id.seq); - mixDigest(digest,itemid,sdslen(itemid)); - sdsfree(itemid); - - while(numfields--) { - unsigned char *field, *value; - int64_t field_len, value_len; - streamIteratorGetField(&si,&field,&value, - &field_len,&value_len); - mixDigest(digest,field,field_len); - mixDigest(digest,value,value_len); - } - } - streamIteratorStop(&si); - } else if (o->type == OBJ_MODULE) { - RedisModuleDigest md = {{0},{0},keyobj,db->id}; - moduleValue *mv = o->ptr; - moduleType *mt = mv->type; - moduleInitDigestContext(md); - if (mt->digest) { - mt->digest(&md,mv->value); - xorDigest(digest,md.x,sizeof(md.x)); - } - } else { - serverPanic("Unknown object type"); - } - /* If the key has an expire, add it to the mix */ - if (expiretime != -1) xorDigest(digest,"!!expire!!",10); -} - -/* Compute the dataset digest. Since keys, sets elements, hashes elements - * are not ordered, we use a trick: every aggregate digest is the xor - * of the digests of their elements. This way the order will not change - * the result. For list instead we use a feedback entering the output digest - * as input in order to ensure that a different ordered list will result in - * a different digest. */ -void computeDatasetDigest(unsigned char *final) { - unsigned char digest[20]; - dictEntry *de; - int j; - uint32_t aux; - - memset(final,0,20); /* Start with a clean result */ - - for (j = 0; j < server.dbnum; j++) { - redisDb *db = server.db+j; - if (kvstoreSize(db->keys) == 0) - continue; - - /* hash the DB id, so the same dataset moved in a different DB will lead to a different digest */ - aux = htonl(j); - mixDigest(final,&aux,sizeof(aux)); - - /* Iterate this DB writing every entry */ - kvstoreIterator kvs_it; - kvstoreIteratorInit(&kvs_it, db->keys); - while((de = kvstoreIteratorNext(&kvs_it)) != NULL) { - robj *keyobj; - - memset(digest,0,20); /* This key-val digest */ - kvobj *kv = dictGetKV(de); - sds key = kvobjGetKey(kv); - keyobj = createStringObject(key,sdslen(key)); - - mixDigest(digest,key,sdslen(key)); - - xorObjectDigest(db, keyobj, digest, kv); - - /* We can finally xor the key-val digest to the final digest */ - xorDigest(final,digest,20); - decrRefCount(keyobj); - } - kvstoreIteratorReset(&kvs_it); - } -} - -#ifdef USE_JEMALLOC -void mallctl_int(client *c, robj **argv, int argc) { - int ret; - /* start with the biggest size (int64), and if that fails, try smaller sizes (int32, bool) */ - int64_t old = 0, val; - if (argc > 1) { - long long ll; - if (getLongLongFromObjectOrReply(c, argv[1], &ll, NULL) != C_OK) - return; - val = ll; - } - size_t sz = sizeof(old); - while (sz > 0) { - size_t zz = sz; - if ((ret=je_mallctl(argv[0]->ptr, &old, &zz, argc > 1? &val: NULL, argc > 1?sz: 0))) { - if (ret == EPERM && argc > 1) { - /* if this option is write only, try just writing to it. */ - if (!(ret=je_mallctl(argv[0]->ptr, NULL, 0, &val, sz))) { - addReply(c, shared.ok); - return; - } - } - if (ret==EINVAL) { - /* size might be wrong, try a smaller one */ - sz /= 2; -#if BYTE_ORDER == BIG_ENDIAN - val <<= 8*sz; -#endif - continue; - } - addReplyErrorFormat(c,"%s", strerror(ret)); - return; - } else { -#if BYTE_ORDER == BIG_ENDIAN - old >>= 64 - 8*sz; -#endif - addReplyLongLong(c, old); - return; - } - } - addReplyErrorFormat(c,"%s", strerror(EINVAL)); -} - -void mallctl_string(client *c, robj **argv, int argc) { - int rret, wret; - char *old; - size_t sz = sizeof(old); - /* for strings, it seems we need to first get the old value, before overriding it. */ - if ((rret=je_mallctl(argv[0]->ptr, &old, &sz, NULL, 0))) { - /* return error unless this option is write only. */ - if (!(rret == EPERM && argc > 1)) { - addReplyErrorFormat(c,"%s", strerror(rret)); - return; - } - } - if(argc > 1) { - char *val = argv[1]->ptr; - char **valref = &val; - if ((!strcmp(val,"VOID"))) - valref = NULL, sz = 0; - wret = je_mallctl(argv[0]->ptr, NULL, 0, valref, sz); - } - if (!rret) - addReplyBulkCString(c, old); - else if (wret) - addReplyErrorFormat(c,"%s", strerror(wret)); - else - addReply(c, shared.ok); -} -#endif - -void debugCommand(client *c) { - if (c->argc == 2 && !strcasecmp(c->argv[1]->ptr,"help")) { - const char *help[] = { -"AOF-FLUSH-SLEEP <microsec>", -" Server will sleep before flushing the AOF, this is used for testing.", -"ASSERT", -" Crash by assertion failed.", -"CHANGE-REPL-ID", -" Change the replication IDs of the instance.", -" Dangerous: should be used only for testing the replication subsystem.", -"CONFIG-REWRITE-FORCE-ALL", -" Like CONFIG REWRITE but writes all configuration options, including", -" keywords not listed in original configuration file or default values.", -"CRASH-AND-RECOVER [<milliseconds>]", -" Hard crash and restart after a <milliseconds> delay (default 0).", -"DIGEST", -" Output a hex signature representing the current DB content.", -"INTERNAL_SECRET", -" Return the cluster internal secret (hashed with crc16) or error if not in cluster mode.", -"DIGEST-VALUE <key> [<key> ...]", -" Output a hex signature of the values of all the specified keys.", -"ERROR <string>", -" Return a Redis protocol error with <string> as message. Useful for clients", -" unit tests to simulate Redis errors.", -"LEAK <string>", -" Create a memory leak of the input string.", -"LOG <message>", -" Write <message> to the server log.", -"HTSTATS <dbid> [full]", -" Return hash table statistics of the specified Redis database.", -"HTSTATS-KEY <key> [full]", -" Like HTSTATS but for the hash table stored at <key>'s value.", -"KEYSIZES-HIST-ASSERT <0|1>", -" Enable/disable keysizes histogram assertion after each command.", -"LOADAOF", -" Flush the AOF buffers on disk and reload the AOF in memory.", -"REPLICATE <string>", -" Replicates the provided string to replicas, allowing data divergence.", -#ifdef USE_JEMALLOC -"MALLCTL <key> [<val>]", -" Get or set a malloc tuning integer.", -"MALLCTL-STR <key> [<val>]", -" Get or set a malloc tuning string.", -#endif -"OBJECT <key>", -" Show low level info about `key` and associated value.", -"DROP-CLUSTER-PACKET-FILTER <packet-type>", -" Drop all packets that match the filtered type. Set to -1 allow all packets.", -"OOM", -" Crash the server simulating an out-of-memory error.", -"PANIC", -" Crash the server simulating a panic.", -"POPULATE <count> [<prefix>] [<size>]", -" Create <count> string keys named key:<num>. If <prefix> is specified then", -" it is used instead of the 'key' prefix. These are not propagated to", -" replicas. Cluster slots are not respected so keys not belonging to the", -" current node can be created in cluster mode.", -"PROTOCOL <type>", -" Reply with a test value of the specified type. <type> can be: string,", -" integer, double, bignum, null, array, set, map, attrib, push, verbatim,", -" true, false.", -"RELOAD [option ...]", -" Save the RDB on disk and reload it back to memory. Valid <option> values:", -" * MERGE: conflicting keys will be loaded from RDB.", -" * NOFLUSH: the existing database will not be removed before load, but", -" conflicting keys will generate an exception and kill the server.", -" * NOSAVE: the database will be loaded from an existing RDB file.", -" Examples:", -" * DEBUG RELOAD: verify that the server is able to persist, flush and reload", -" the database.", -" * DEBUG RELOAD NOSAVE: replace the current database with the contents of an", -" existing RDB file.", -" * DEBUG RELOAD NOSAVE NOFLUSH MERGE: add the contents of an existing RDB", -" file to the database.", -"RESTART [<milliseconds>]", -" Graceful restart: save config, db, restart after a <milliseconds> delay (default 0).", -"SDSLEN <key>", -" Show low level SDS string info representing `key` and value.", -"SEGFAULT", -" Crash the server with sigsegv.", -"SET-ACTIVE-EXPIRE <0|1>", -" Setting it to 0 disables expiring keys (and hash-fields) in background ", -" when they are not accessed (otherwise the Redis behavior). Setting it", -" to 1 reenables back the default.", -"SET-ALLOW-ACCESS-EXPIRED <0|1>", -" Setting it to 0 prevents access to expired keys (and hash-fields),", -" simulating the standard Redis behavior. Setting it to 1 allows", -" access to expired keys (and hash-fields) without triggering deletion.", -"QUICKLIST-PACKED-THRESHOLD <size>", -" Sets the threshold for elements to be inserted as plain vs packed nodes", -" Default value is 1GB, allows values up to 4GB. Setting to 0 restores to default.", -"SET-SKIP-CHECKSUM-VALIDATION <0|1>", -" Enables or disables checksum checks for RDB files and RESTORE's payload.", -"SLEEP <seconds>", -" Stop the server for <seconds>. Decimals allowed.", -"STRINGMATCH-TEST", -" Run a fuzz tester against the stringmatchlen() function.", -"STRUCTSIZE", -" Return the size of different Redis core C structures.", -"LISTPACK <key>", -" Show low level info about the listpack encoding of <key>.", -"QUICKLIST <key> [<0|1>]", -" Show low level info about the quicklist encoding of <key>.", -" The optional argument (0 by default) sets the level of detail", -"CLIENT-EVICTION", -" Show low level client eviction pools info (maxmemory-clients).", -"PAUSE-CRON <0|1>", -" Stop periodic cron job processing.", -"REPLYBUFFER PEAK-RESET-TIME <NEVER||RESET|time>", -" Sets the time (in milliseconds) to wait between client reply buffer peak resets.", -" In case NEVER is provided the last observed peak will never be reset", -" In case RESET is provided the peak reset time will be restored to the default value", -"REPLYBUFFER RESIZING <0|1>", -" Enable or disable the reply buffer resize cron job", -"REPLY-COPY-AVOIDANCE <0|1>", -" Enable/disable reply copy avoidance optimization.", -"REPL-PAUSE <clear|after-fork|before-rdb-channel|on-streaming-repl-buf>", -" Pause the server's main process during various replication steps.", -"DICT-RESIZING <0|1>", -" Enable or disable the main dict and expire dict resizing.", -"SCRIPT <LIST|<sha>>", -" Output SHA and content of all scripts or of a specific script with its SHA.", -"MARK-INTERNAL-CLIENT [UNMARK]", -" Promote the current connection to an internal connection.", -"ASM-FAILPOINT <channel> <state>", -" Set a fail point for the specified channel and state for cluster atomic slot migration.", -"ASM-TRIM-METHOD <default|none|active|bg> <active-trim-delay> ", -" Disable trimming or force active/background trimming for cluster atomic slot migration.", -" Active trim delay is used only when method is 'active'. If it is negative,", -" active trim is disabled.", -NULL - }; - addExtendedReplyHelp(c, help, clusterDebugCommandExtendedHelp()); - } else if (!strcasecmp(c->argv[1]->ptr,"segfault")) { - /* Compiler gives warnings about writing to a random address - * e.g "*((char*)-1) = 'x';". As a workaround, we map a read-only area - * and try to write there to trigger segmentation fault. */ - char* p = mmap(NULL, 4096, PROT_READ, MAP_PRIVATE | MAP_ANON, -1, 0); - *p = 'x'; - } else if (!strcasecmp(c->argv[1]->ptr,"panic")) { - serverPanic("DEBUG PANIC called at Unix time %lld", (long long)time(NULL)); - } else if (!strcasecmp(c->argv[1]->ptr,"restart") || - !strcasecmp(c->argv[1]->ptr,"crash-and-recover")) - { - long long delay = 0; - if (c->argc >= 3) { - if (getLongLongFromObjectOrReply(c, c->argv[2], &delay, NULL) - != C_OK) return; - if (delay < 0) delay = 0; - } - int flags = !strcasecmp(c->argv[1]->ptr,"restart") ? - (RESTART_SERVER_GRACEFULLY|RESTART_SERVER_CONFIG_REWRITE) : - RESTART_SERVER_NONE; - restartServer(flags,delay); - addReplyError(c,"failed to restart the server. Check server logs."); - } else if (!strcasecmp(c->argv[1]->ptr,"oom")) { - void *ptr = zmalloc(SIZE_MAX/2); /* Should trigger an out of memory. */ - zfree(ptr); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"assert")) { - serverAssertWithInfo(c,c->argv[0],1 == 2); - } else if (!strcasecmp(c->argv[1]->ptr,"KEYSIZES-HIST-ASSERT") && c->argc == 3) { - long long flag; - if (getLongLongFromObjectOrReply(c, c->argv[2], &flag, NULL) != C_OK) - return; - server.dbg_assert_keysizes = (flag != 0); - addReply(c, shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"ALLOCSIZE-SLOTS-ASSERT") && c->argc == 3) { - long long flag; - if (getLongLongFromObjectOrReply(c, c->argv[2], &flag, NULL) != C_OK) - return; - server.dbg_assert_alloc_per_slot = (flag != 0); - addReply(c, shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"log") && c->argc == 3) { - serverLog(LL_WARNING, "DEBUG LOG: %s", (char*)c->argv[2]->ptr); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"leak") && c->argc == 3) { - sdsdup(c->argv[2]->ptr); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"reload")) { - int flush = 1, save = 1; - int flags = RDBFLAGS_NONE; - - /* Parse the additional options that modify the RELOAD - * behavior. */ - for (int j = 2; j < c->argc; j++) { - char *opt = c->argv[j]->ptr; - if (!strcasecmp(opt,"MERGE")) { - flags |= RDBFLAGS_ALLOW_DUP; - } else if (!strcasecmp(opt,"NOFLUSH")) { - flush = 0; - } else if (!strcasecmp(opt,"NOSAVE")) { - save = 0; - } else { - addReplyError(c,"DEBUG RELOAD only supports the " - "MERGE, NOFLUSH and NOSAVE options."); - return; - } - } - - /* The default behavior is to save the RDB file before loading - * it back. */ - if (save) { - rdbSaveInfo rsi, *rsiptr; - rsiptr = rdbPopulateSaveInfo(&rsi); - if (rdbSave(SLAVE_REQ_NONE,server.rdb_filename,rsiptr,RDBFLAGS_NONE) != C_OK) { - addReplyErrorObject(c,shared.err); - return; - } - } - - /* The default behavior is to remove the current dataset from - * memory before loading the RDB file, however when MERGE is - * used together with NOFLUSH, we are able to merge two datasets. */ - if (flush) emptyData(-1,EMPTYDB_NO_FLAGS,NULL); - - protectClient(c); - int ret = rdbLoad(server.rdb_filename,NULL,flags); - unprotectClient(c); - if (ret != RDB_OK) { - addReplyError(c,"Error trying to load the RDB dump, check server logs."); - return; - } - applyAppendOnlyConfig(); /* Check if AOF config was changed while loading */ - serverLog(LL_NOTICE,"DB reloaded by DEBUG RELOAD"); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"loadaof")) { - if (server.aof_state != AOF_OFF) flushAppendOnlyFile(1); - emptyData(-1,EMPTYDB_NO_FLAGS,NULL); - protectClient(c); - if (server.aof_manifest) aofManifestFree(server.aof_manifest); - aofLoadManifestFromDisk(); - aofDelHistoryFiles(); - int ret = loadAppendOnlyFiles(server.aof_manifest); - unprotectClient(c); - if (ret != AOF_OK && ret != AOF_EMPTY) { - addReplyError(c, "Error trying to load the AOF files, check server logs."); - return; - } - applyAppendOnlyConfig(); /* Check if AOF config was changed while loading */ - server.dirty = 0; /* Prevent AOF / replication */ - serverLog(LL_NOTICE,"Append Only File loaded by DEBUG LOADAOF"); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"drop-cluster-packet-filter") && c->argc == 3) { - long packet_type; - if (getLongFromObjectOrReply(c, c->argv[2], &packet_type, NULL) != C_OK) - return; - server.cluster_drop_packet_filter = packet_type; - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"object") && c->argc == 3) { - kvobj *kv; - char *strenc; - - if ((kv = dbFind(c->db, c->argv[2]->ptr)) == NULL) { - addReplyErrorObject(c,shared.nokeyerr); - return; - } - - strenc = strEncoding(kv->encoding); - - char extra[138] = {0}; - if (kv->encoding == OBJ_ENCODING_QUICKLIST) { - char *nextra = extra; - int remaining = sizeof(extra); - quicklist *ql = kv->ptr; - /* Add number of quicklist nodes */ - int used = snprintf(nextra, remaining, " ql_nodes:%lu", ql->len); - nextra += used; - remaining -= used; - /* Add average quicklist fill factor */ - double avg = (double)ql->count/ql->len; - used = snprintf(nextra, remaining, " ql_avg_node:%.2f", avg); - nextra += used; - remaining -= used; - /* Add quicklist fill level / max listpack size */ - used = snprintf(nextra, remaining, " ql_listpack_max:%d", ql->fill); - nextra += used; - remaining -= used; - /* Add isCompressed? */ - int compressed = ql->compress != 0; - used = snprintf(nextra, remaining, " ql_compressed:%d", compressed); - nextra += used; - remaining -= used; - /* Add total uncompressed size */ - unsigned long sz = 0; - for (quicklistNode *node = ql->head; node; node = node->next) { - sz += node->sz; - } - used = snprintf(nextra, remaining, " ql_uncompressed_size:%lu", sz); - nextra += used; - remaining -= used; - } - - addReplyStatusFormat(c, - "Value at:%p refcount:%d " - "encoding:%s serializedlength:%zu " - "lru:%d lru_seconds_idle:%llu%s", - (void*)kv, kv->refcount, - strenc, rdbSavedObjectLen(kv, c->argv[2], c->db->id), - kv->lru, estimateObjectIdleTime(kv)/1000, extra); - } else if (!strcasecmp(c->argv[1]->ptr,"sdslen") && c->argc == 3) { - robj *val; - sds key; - kvobj *kv; - - if ((kv = dbFind(c->db, c->argv[2]->ptr)) == NULL) { - addReplyErrorObject(c,shared.nokeyerr); - return; - } - - val = kv; - key = kvobjGetKey(kv); - if (kv->type != OBJ_STRING || !sdsEncodedObject(val)) { - addReplyError(c,"Not an sds encoded string."); - } else { - /* The key's allocation size reflects the entire robj allocation. - * For embedded values, report an allocation size of 0. */ - size_t obj_alloc = zmalloc_usable_size(val); - size_t val_alloc = val->encoding == OBJ_ENCODING_RAW ? sdsAllocSize(val->ptr) : 0; - addReplyStatusFormat(c, - "key_sds_len:%lld, key_sds_avail:%lld, key_zmalloc: %lld, " - "val_sds_len:%lld, val_sds_avail:%lld, val_zmalloc: %lld", - (long long) sdslen(key), - (long long) sdsavail(key), - (long long) obj_alloc, - (long long) sdslen(val->ptr), - (long long) sdsavail(val->ptr), - (long long) val_alloc); - } - } else if (!strcasecmp(c->argv[1]->ptr,"listpack") && c->argc == 3) { - kvobj *o; - - if ((o = kvobjCommandLookupOrReply(c, c->argv[2], shared.nokeyerr)) - == NULL) return; - - if (o->encoding != OBJ_ENCODING_LISTPACK && o->encoding != OBJ_ENCODING_LISTPACK_EX) { - addReplyError(c,"Not a listpack encoded object."); - } else { - if (o->encoding == OBJ_ENCODING_LISTPACK) - lpRepr(o->ptr); - else if (o->encoding == OBJ_ENCODING_LISTPACK_EX) - lpRepr(((listpackEx*)o->ptr)->lp); - - addReplyStatus(c,"Listpack structure printed on stdout"); - } - } else if (!strcasecmp(c->argv[1]->ptr,"quicklist") && (c->argc == 3 || c->argc == 4)) { - kvobj *o; - - if ((o = kvobjCommandLookupOrReply(c, c->argv[2], shared.nokeyerr)) - == NULL) return; - - int full = 0; - if (c->argc == 4) - full = atoi(c->argv[3]->ptr); - if (o->encoding != OBJ_ENCODING_QUICKLIST) { - addReplyError(c,"Not a quicklist encoded object."); - } else { - quicklistRepr(o->ptr, full); - addReplyStatus(c,"Quicklist structure printed on stdout"); - } - } else if (!strcasecmp(c->argv[1]->ptr,"populate") && - c->argc >= 3 && c->argc <= 5) { - long keys, j; - robj *key, *val; - char buf[128]; - - if (getPositiveLongFromObjectOrReply(c, c->argv[2], &keys, NULL) != C_OK) - return; - - if (server.loading || server.async_loading) { - addReplyErrorObject(c, shared.loadingerr); - return; - } - - if (dbExpand(c->db, keys, 1) == C_ERR) { - addReplyError(c, "OOM in dictTryExpand"); - return; - } - long valsize = 0; - if ( c->argc == 5 && getPositiveLongFromObjectOrReply(c, c->argv[4], &valsize, NULL) != C_OK ) - return; - - for (j = 0; j < keys; j++) { - snprintf(buf,sizeof(buf),"%s:%lu", - (c->argc == 3) ? "key" : (char*)c->argv[3]->ptr, j); - key = createStringObject(buf,strlen(buf)); - if (lookupKeyWrite(c->db,key) != NULL) { - decrRefCount(key); - continue; - } - snprintf(buf,sizeof(buf),"value:%lu",j); - if (valsize==0) - val = createStringObject(buf,strlen(buf)); - else { - int buflen = strlen(buf); - val = createStringObject(NULL,valsize); - memcpy(val->ptr, buf, valsize<=buflen? valsize: buflen); - } - dbAdd(c->db, key, &val); - keyModified(c,c->db,key,NULL,1); - decrRefCount(key); - } - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"digest") && c->argc == 2) { - /* DEBUG DIGEST (form without keys specified) */ - unsigned char digest[20]; - sds d = sdsempty(); - - computeDatasetDigest(digest); - for (int i = 0; i < 20; i++) d = sdscatprintf(d, "%02x",digest[i]); - addReplyStatus(c,d); - sdsfree(d); - } else if (!strcasecmp(c->argv[1]->ptr,"internal_secret") && c->argc == 2) { - size_t len; - const char *internal_secret = clusterGetSecret(&len); - if (!internal_secret) { - addReplyError(c, "Internal secret is missing"); - } else { - uint16_t hash = crc16(internal_secret, len); - addReplyLongLong(c, hash); - } - } else if (!strcasecmp(c->argv[1]->ptr,"digest-value") && c->argc >= 2) { - /* DEBUG DIGEST-VALUE key key key ... key. */ - addReplyArrayLen(c,c->argc-2); - for (int j = 2; j < c->argc; j++) { - unsigned char digest[20]; - memset(digest,0,20); /* Start with a clean result */ - - /* We don't use lookupKey because a debug command should - * work on logically expired keys */ - kvobj *o = dbFind(c->db, c->argv[j]->ptr); - if (o) xorObjectDigest(c->db,c->argv[j],digest,o); - - sds d = sdsempty(); - for (int i = 0; i < 20; i++) d = sdscatprintf(d, "%02x",digest[i]); - addReplyStatus(c,d); - sdsfree(d); - } - } else if (!strcasecmp(c->argv[1]->ptr,"protocol") && c->argc == 3) { - /* DEBUG PROTOCOL [string|integer|double|bignum|null|array|set|map| - * attrib|push|verbatim|true|false] */ - char *name = c->argv[2]->ptr; - if (!strcasecmp(name,"string")) { - addReplyBulkCString(c,"Hello World"); - } else if (!strcasecmp(name,"integer")) { - addReplyLongLong(c,12345); - } else if (!strcasecmp(name,"double")) { - addReplyDouble(c,3.141); - } else if (!strcasecmp(name,"bignum")) { - addReplyBigNum(c,"1234567999999999999999999999999999999",37); - } else if (!strcasecmp(name,"null")) { - addReplyNull(c); - } else if (!strcasecmp(name,"array")) { - addReplyArrayLen(c,3); - for (int j = 0; j < 3; j++) addReplyLongLong(c,j); - } else if (!strcasecmp(name,"set")) { - addReplySetLen(c,3); - for (int j = 0; j < 3; j++) addReplyLongLong(c,j); - } else if (!strcasecmp(name,"map")) { - addReplyMapLen(c,3); - for (int j = 0; j < 3; j++) { - addReplyLongLong(c,j); - addReplyBool(c, j == 1); - } - } else if (!strcasecmp(name,"attrib")) { - if (c->resp >= 3) { - addReplyAttributeLen(c,1); - addReplyBulkCString(c,"key-popularity"); - addReplyArrayLen(c,2); - addReplyBulkCString(c,"key:123"); - addReplyLongLong(c,90); - } - /* Attributes are not real replies, so a well formed reply should - * also have a normal reply type after the attribute. */ - addReplyBulkCString(c,"Some real reply following the attribute"); - } else if (!strcasecmp(name,"push")) { - if (c->resp < 3) { - addReplyError(c,"RESP2 is not supported by this command"); - return; - } - uint64_t old_flags = c->flags; - c->flags |= CLIENT_PUSHING; - addReplyPushLen(c,2); - addReplyBulkCString(c,"server-cpu-usage"); - addReplyLongLong(c,42); - if (!(old_flags & CLIENT_PUSHING)) c->flags &= ~CLIENT_PUSHING; - /* Push replies are not synchronous replies, so we emit also a - * normal reply in order for blocking clients just discarding the - * push reply, to actually consume the reply and continue. */ - addReplyBulkCString(c,"Some real reply following the push reply"); - } else if (!strcasecmp(name,"true")) { - addReplyBool(c,1); - } else if (!strcasecmp(name,"false")) { - addReplyBool(c,0); - } else if (!strcasecmp(name,"verbatim")) { - addReplyVerbatim(c,"This is a verbatim\nstring",25,"txt"); - } else { - addReplyError(c,"Wrong protocol type name. Please use one of the following: string|integer|double|bignum|null|array|set|map|attrib|push|verbatim|true|false"); - } - } else if (!strcasecmp(c->argv[1]->ptr,"sleep") && c->argc == 3) { - double dtime = fast_float_strtod(c->argv[2]->ptr,NULL); - long long utime = dtime*1000000; - struct timespec tv; - - tv.tv_sec = utime / 1000000; - tv.tv_nsec = (utime % 1000000) * 1000; - nanosleep(&tv, NULL); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"set-active-expire") && - c->argc == 3) - { - server.active_expire_enabled = atoi(c->argv[2]->ptr); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"set-allow-access-expired") && - c->argc == 3) - { - server.allow_access_expired = atoi(c->argv[2]->ptr); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"quicklist-packed-threshold") && - c->argc == 3) - { - int memerr; - unsigned long long sz = memtoull((const char *)c->argv[2]->ptr, &memerr); - if (memerr || !quicklistSetPackedThreshold(sz)) { - addReplyError(c, "argument must be a memory value bigger than 1 and smaller than 4gb"); - } else { - addReply(c,shared.ok); - } - } else if (!strcasecmp(c->argv[1]->ptr,"set-skip-checksum-validation") && - c->argc == 3) - { - server.skip_checksum_validation = atoi(c->argv[2]->ptr); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"aof-flush-sleep") && - c->argc == 3) - { - server.aof_flush_sleep = atoi(c->argv[2]->ptr); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"replicate") && c->argc >= 3) { - replicationFeedSlaves(server.slaves, -1, - c->argv + 2, c->argc - 2); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"error") && c->argc == 3) { - sds errstr = sdsnewlen("-",1); - - errstr = sdscatsds(errstr,c->argv[2]->ptr); - errstr = sdsmapchars(errstr,"\n\r"," ",2); /* no newlines in errors. */ - errstr = sdscatlen(errstr,"\r\n",2); - addReplySds(c,errstr); - } else if (!strcasecmp(c->argv[1]->ptr,"structsize") && c->argc == 2) { - sds sizes = sdsempty(); - sizes = sdscatprintf(sizes,"bits:%d ",(sizeof(void*) == 8)?64:32); - sizes = sdscatprintf(sizes,"robj:%d ",(int)sizeof(robj)); - sizes = sdscatprintf(sizes,"dictentry:%d ",(int)dictEntryMemUsage(0)); - sizes = sdscatprintf(sizes,"sdshdr5:%d ",(int)sizeof(struct sdshdr5)); - sizes = sdscatprintf(sizes,"sdshdr8:%d ",(int)sizeof(struct sdshdr8)); - sizes = sdscatprintf(sizes,"sdshdr16:%d ",(int)sizeof(struct sdshdr16)); - sizes = sdscatprintf(sizes,"sdshdr32:%d ",(int)sizeof(struct sdshdr32)); - sizes = sdscatprintf(sizes,"sdshdr64:%d ",(int)sizeof(struct sdshdr64)); - addReplyBulkSds(c,sizes); - } else if (!strcasecmp(c->argv[1]->ptr,"htstats") && c->argc >= 3) { - long dbid; - sds stats = sdsempty(); - char buf[4096]; - int full = 0; - - if (getLongFromObjectOrReply(c, c->argv[2], &dbid, NULL) != C_OK) { - sdsfree(stats); - return; - } - if (dbid < 0 || dbid >= server.dbnum) { - sdsfree(stats); - addReplyError(c,"Out of range database"); - return; - } - if (c->argc >= 4 && !strcasecmp(c->argv[3]->ptr,"full")) - full = 1; - - stats = sdscatprintf(stats,"[Dictionary HT]\n"); - kvstoreGetStats(server.db[dbid].keys, buf, sizeof(buf), full); - stats = sdscat(stats,buf); - - stats = sdscatprintf(stats,"[Expires HT]\n"); - kvstoreGetStats(server.db[dbid].expires, buf, sizeof(buf), full); - stats = sdscat(stats,buf); - - addReplyVerbatim(c,stats,sdslen(stats),"txt"); - sdsfree(stats); - } else if (!strcasecmp(c->argv[1]->ptr,"htstats-key") && c->argc >= 3) { - kvobj *o; - dict *ht = NULL; - int full = 0; - - if (c->argc >= 4 && !strcasecmp(c->argv[3]->ptr,"full")) - full = 1; - - if ((o = kvobjCommandLookupOrReply(c,c->argv[2],shared.nokeyerr)) - == NULL) return; - - /* Get the hash table reference from the object, if possible. */ - switch (o->encoding) { - case OBJ_ENCODING_SKIPLIST: - { - zset *zs = o->ptr; - ht = zs->dict; - } - break; - case OBJ_ENCODING_HT: - ht = o->ptr; - break; - } - - if (ht == NULL) { - addReplyError(c,"The value stored at the specified key is not " - "represented using an hash table"); - } else { - char buf[4096]; - dictGetStats(buf,sizeof(buf),ht,full); - addReplyVerbatim(c,buf,strlen(buf),"txt"); - } - } else if (!strcasecmp(c->argv[1]->ptr,"change-repl-id") && c->argc == 2) { - serverLog(LL_NOTICE,"Changing replication IDs after receiving DEBUG change-repl-id"); - changeReplicationId(); - clearReplicationId2(); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"stringmatch-test") && c->argc == 2) - { - stringmatchlen_fuzz_test(); - addReplyStatus(c,"Apparently Redis did not crash: test passed"); - } else if (!strcasecmp(c->argv[1]->ptr,"set-disable-deny-scripts") && c->argc == 3) - { - server.script_disable_deny_script = atoi(c->argv[2]->ptr); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"config-rewrite-force-all") && c->argc == 2) - { - if (rewriteConfig(server.configfile, 1) == -1) - addReplyErrorFormat(c, "CONFIG-REWRITE-FORCE-ALL failed: %s", strerror(errno)); - else - addReply(c, shared.ok); - } else if(!strcasecmp(c->argv[1]->ptr,"client-eviction") && c->argc == 2) { - if (!server.client_mem_usage_buckets) { - addReplyError(c,"maxmemory-clients is disabled."); - return; - } - sds bucket_info = sdsempty(); - for (int j = 0; j < CLIENT_MEM_USAGE_BUCKETS; j++) { - if (j == 0) - bucket_info = sdscatprintf(bucket_info, "bucket 0"); - else - bucket_info = sdscatprintf(bucket_info, "bucket %10zu", (size_t)1<<(j-1+CLIENT_MEM_USAGE_BUCKET_MIN_LOG)); - if (j == CLIENT_MEM_USAGE_BUCKETS-1) - bucket_info = sdscatprintf(bucket_info, "+ : "); - else - bucket_info = sdscatprintf(bucket_info, " - %10zu: ", ((size_t)1<<(j+CLIENT_MEM_USAGE_BUCKET_MIN_LOG))-1); - bucket_info = sdscatprintf(bucket_info, "tot-mem: %10zu, clients: %lu\n", - server.client_mem_usage_buckets[j].mem_usage_sum, - server.client_mem_usage_buckets[j].clients->len); - } - addReplyVerbatim(c,bucket_info,sdslen(bucket_info),"txt"); - sdsfree(bucket_info); -#ifdef USE_JEMALLOC - } else if(!strcasecmp(c->argv[1]->ptr,"mallctl") && c->argc >= 3) { - mallctl_int(c, c->argv+2, c->argc-2); - return; - } else if(!strcasecmp(c->argv[1]->ptr,"mallctl-str") && c->argc >= 3) { - mallctl_string(c, c->argv+2, c->argc-2); - return; -#endif - } else if (!strcasecmp(c->argv[1]->ptr,"pause-cron") && c->argc == 3) - { - server.pause_cron = atoi(c->argv[2]->ptr); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"replybuffer") && c->argc == 4 ) { - if(!strcasecmp(c->argv[2]->ptr, "peak-reset-time")) { - if (!strcasecmp(c->argv[3]->ptr, "never")) { - server.reply_buffer_peak_reset_time = -1; - } else if(!strcasecmp(c->argv[3]->ptr, "reset")) { - server.reply_buffer_peak_reset_time = REPLY_BUFFER_DEFAULT_PEAK_RESET_TIME; - } else { - if (getLongFromObjectOrReply(c, c->argv[3], &server.reply_buffer_peak_reset_time, NULL) != C_OK) - return; - } - } else if(!strcasecmp(c->argv[2]->ptr,"resizing")) { - server.reply_buffer_resizing_enabled = atoi(c->argv[3]->ptr); - } else { - addReplySubcommandSyntaxError(c); - return; - } - addReply(c, shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"reply-copy-avoidance") && c->argc == 3) { - server.reply_copy_avoidance_enabled = atoi(c->argv[2]->ptr); - addReply(c,shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr, "repl-pause") && c->argc == 3) { - if (!strcasecmp(c->argv[2]->ptr, "clear")) { - server.repl_debug_pause = REPL_DEBUG_PAUSE_NONE; - } else if (!strcasecmp(c->argv[2]->ptr,"after-fork")) { - server.repl_debug_pause |= REPL_DEBUG_AFTER_FORK; - } else if (!strcasecmp(c->argv[2]->ptr,"before-rdb-channel")) { - server.repl_debug_pause |= REPL_DEBUG_BEFORE_RDB_CHANNEL; - } else if (!strcasecmp(c->argv[2]->ptr, "on-streaming-repl-buf")) { - server.repl_debug_pause |= REPL_DEBUG_ON_STREAMING_REPL_BUF; - } else { - addReplySubcommandSyntaxError(c); - return; - } - addReply(c, shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr, "dict-resizing") && c->argc == 3) { - server.dict_resizing = atoi(c->argv[2]->ptr); - addReply(c, shared.ok); - } else if (!strcasecmp(c->argv[1]->ptr,"script") && c->argc == 3) { - if (!strcasecmp(c->argv[2]->ptr,"list")) { - dictIterator di; - dictEntry *de; - dictInitIterator(&di, evalScriptsDict()); - while ((de = dictNext(&di)) != NULL) { - luaScript *script = dictGetVal(de); - sds *sha = dictGetKey(de); - serverLog(LL_WARNING, "SCRIPT SHA: %s\n%s", (char*)sha, (char*)script->body->ptr); - } - dictResetIterator(&di); - } else if (sdslen(c->argv[2]->ptr) == 40) { - dictEntry *de; - if ((de = dictFind(evalScriptsDict(), c->argv[2]->ptr)) == NULL) { - addReplyErrorObject(c, shared.noscripterr); - return; - } - luaScript *script = dictGetVal(de); - serverLog(LL_WARNING, "SCRIPT SHA: %s\n%s", (char*)c->argv[2]->ptr, (char*)script->body->ptr); - } else { - addReplySubcommandSyntaxError(c); - return; - } - addReply(c,shared.ok); - } else if(!strcasecmp(c->argv[1]->ptr,"mark-internal-client") && c->argc < 4) { - if (c->argc == 2) { - c->flags |= CLIENT_INTERNAL; - addReply(c, shared.ok); - } else if (c->argc == 3 && !strcasecmp(c->argv[2]->ptr, "unmark")) { - c->flags &= ~CLIENT_INTERNAL; - addReply(c, shared.ok); - } else { - addReplySubcommandSyntaxError(c); - return; - } - } else if(!strcasecmp(c->argv[1]->ptr,"asm-failpoint") && c->argc == 4) { - if (asmDebugSetFailPoint(c->argv[2]->ptr, c->argv[3]->ptr) != C_OK) { - addReplyError(c, "Failed to set ASM fail point"); - } else { - addReply(c, shared.ok); - } - } else if(!strcasecmp(c->argv[1]->ptr,"asm-trim-method") && c->argc >= 3) { - int delay = c->argc == 4 ? atoi(c->argv[3]->ptr) : 0; - if (asmDebugSetTrimMethod(c->argv[2]->ptr, delay) != C_OK) { - addReplyError(c, "Failed to set ASM trim method"); - } else { - addReply(c, shared.ok); - } - } else if(!handleDebugClusterCommand(c)) { - addReplySubcommandSyntaxError(c); - return; - } -} - -/* =========================== Crash handling ============================== */ - -/* When hide-user-data-from-log is enabled, to avoid leaking user info, we only - * print tokens of the current command into the log. First, we collect command - * tokens into this struct (Commands tokens are defined in json schema). Later, - * checking each argument against the token list. */ -#define CMD_TOKEN_MAX_COUNT 128 /* Max token count in a command's json schema */ -struct cmdToken { - const char *tokens[CMD_TOKEN_MAX_COUNT]; - int n_token; -}; - -/* Collect tokens from command arguments recursively. */ -static void cmdTokenCollect(struct cmdToken *tk, redisCommandArg *args, int argc) { - if (args == NULL) - return; - - for (int i = 0; i < argc && tk->n_token < CMD_TOKEN_MAX_COUNT; i++) { - if (args[i].token) - tk->tokens[tk->n_token++] = args[i].token; - cmdTokenCollect(tk, args[i].subargs, args[i].num_args); - } -} - -/* Get tokens of the command. */ -static void cmdTokenGetFromCommand(struct cmdToken *tk, struct redisCommand *cmd) { - tk->n_token = 0; - cmdTokenCollect(tk, cmd->args, cmd->num_args); -} - -/* Check if object is one of command's tokens. */ -static int cmdTokenCheck(struct cmdToken *tk, robj *o) { - if (o->type != OBJ_STRING || !sdsEncodedObject(o)) - return 0; - - for (int i = 0; i < tk->n_token; i++) { - if (strcasecmp(tk->tokens[i], o->ptr) == 0) - return 1; - } - return 0; -} - -__attribute__ ((noinline)) -void _serverAssert(const char *estr, const char *file, int line) { - int new_report = bugReportStart(); - serverLog(LL_WARNING,"=== %sASSERTION FAILED ===", new_report ? "" : "RECURSIVE "); - serverLog(LL_WARNING,"==> %s:%d '%s' is not true",file,line,estr); - - if (server.crashlog_enabled) { -#ifdef HAVE_BACKTRACE - logStackTrace(NULL, 1, 0); -#endif - /* If this was a recursive assertion, it what most likely generated - * from printCrashReport. */ - if (new_report) printCrashReport(); - } - - // remove the signal handler so on abort() we will output the crash report. - removeSigSegvHandlers(); - bugReportEnd(0, 0); -} - -void _serverAssertPrintClientInfo(const client *c) { - int j; - char conninfo[CONN_INFO_LEN]; - struct redisCommand *cmd = NULL; - struct cmdToken tokens = {{0}}; - - bugReportStart(); - serverLog(LL_WARNING,"=== ASSERTION FAILED CLIENT CONTEXT ==="); - serverLog(LL_WARNING,"client->flags = %llu", (unsigned long long) c->flags); - serverLog(LL_WARNING,"client->conn = %s", connGetInfo(c->conn, conninfo, sizeof(conninfo))); - serverLog(LL_WARNING,"client->argc = %d", c->argc); - if (server.hide_user_data_from_log) { - cmd = lookupCommand(c->argv, c->argc); - if (cmd) - cmdTokenGetFromCommand(&tokens, cmd); - } - - for (j=0; j < c->argc; j++) { - char buf[128]; - char *arg; - - /* Allow command name, subcommand name and command tokens in the log. */ - if (server.hide_user_data_from_log && (j != 0 && !(j == 1 && cmd && cmd->parent))) { - if (!cmdTokenCheck(&tokens, c->argv[j])) { - serverLog(LL_WARNING, "client->argv[%d] = *redacted*", j); - continue; - } - } - - if (c->argv[j]->type == OBJ_STRING && sdsEncodedObject(c->argv[j])) { - arg = (char*) c->argv[j]->ptr; - } else { - snprintf(buf,sizeof(buf),"Object type: %u, encoding: %u", - c->argv[j]->type, c->argv[j]->encoding); - arg = buf; - } - serverLog(LL_WARNING,"client->argv[%d] = \"%s\" (refcount: %d)", - j, arg, c->argv[j]->refcount); - } -} - -void serverLogObjectDebugInfo(const robj *o) { - serverLog(LL_WARNING,"Object type: %u", o->type); - serverLog(LL_WARNING,"Object encoding: %u", o->encoding); - serverLog(LL_WARNING,"Object refcount: %d", o->refcount); -#if UNSAFE_CRASH_REPORT - /* This code is now disabled. o->ptr may be unreliable to print. in some - * cases a ziplist could have already been freed by realloc, but not yet - * updated to o->ptr. in other cases the call to ziplistLen may need to - * iterate on all the items in the list (and possibly crash again). - * For some cases it may be ok to crash here again, but these could cause - * invalid memory access which will bother valgrind and also possibly cause - * random memory portion to be "leaked" into the logfile. */ - if (o->type == OBJ_STRING && sdsEncodedObject(o)) { - serverLog(LL_WARNING,"Object raw string len: %zu", sdslen(o->ptr)); - if (sdslen(o->ptr) < 4096) { - sds repr = sdscatrepr(sdsempty(),o->ptr,sdslen(o->ptr)); - serverLog(LL_WARNING,"Object raw string content: %s", repr); - sdsfree(repr); - } - } else if (o->type == OBJ_LIST) { - serverLog(LL_WARNING,"List length: %d", (int) listTypeLength(o)); - } else if (o->type == OBJ_SET) { - serverLog(LL_WARNING,"Set size: %d", (int) setTypeSize(o)); - } else if (o->type == OBJ_HASH) { - serverLog(LL_WARNING,"Hash size: %d", (int) hashTypeLength(o, 0)); - } else if (o->type == OBJ_ZSET) { - serverLog(LL_WARNING,"Sorted set size: %d", (int) zsetLength(o)); - if (o->encoding == OBJ_ENCODING_SKIPLIST) - serverLog(LL_WARNING,"Skiplist level: %d", (int) ((const zset*)o->ptr)->zsl->level); - } else if (o->type == OBJ_STREAM) { - serverLog(LL_WARNING,"Stream size: %d", (int) streamLength(o)); - } -#endif -} - -void _serverAssertPrintObject(const robj *o) { - bugReportStart(); - serverLog(LL_WARNING,"=== ASSERTION FAILED OBJECT CONTEXT ==="); - serverLogObjectDebugInfo(o); -} - -void _serverAssertWithInfo(const client *c, const robj *o, const char *estr, const char *file, int line) { - if (c) _serverAssertPrintClientInfo(c); - if (o) _serverAssertPrintObject(o); - _serverAssert(estr,file,line); -} - -__attribute__ ((noinline)) -void _serverPanic(const char *file, int line, const char *msg, ...) { - va_list ap; - va_start(ap,msg); - char fmtmsg[256]; - vsnprintf(fmtmsg,sizeof(fmtmsg),msg,ap); - va_end(ap); - - int new_report = bugReportStart(); - serverLog(LL_WARNING,"------------------------------------------------"); - serverLog(LL_WARNING,"!!! Software Failure. Press left mouse button to continue"); - serverLog(LL_WARNING,"Guru Meditation: %s #%s:%d",fmtmsg,file,line); - - if (server.crashlog_enabled) { -#ifdef HAVE_BACKTRACE - logStackTrace(NULL, 1, 0); -#endif - /* If this was a recursive panic, it what most likely generated - * from printCrashReport. */ - if (new_report) printCrashReport(); - } - - // remove the signal handler so on abort() we will output the crash report. - removeSigSegvHandlers(); - bugReportEnd(0, 0); -} - -/* Start a bug report, returning 1 if this is the first time this function was called, 0 otherwise. */ -int bugReportStart(void) { - pthread_mutex_lock(&bug_report_start_mutex); - if (bug_report_start == 0) { - bug_report_start = 1; - serverLogRaw(LL_WARNING|LL_RAW, - "\n\n=== REDIS BUG REPORT START: Cut & paste starting from here ===\n"); - pthread_mutex_unlock(&bug_report_start_mutex); - return 1; - } - pthread_mutex_unlock(&bug_report_start_mutex); - return 0; -} - -#ifdef HAVE_BACKTRACE - -/* Returns the current eip and set it to the given new value (if its not NULL) */ -static void* getAndSetMcontextEip(ucontext_t *uc, void *eip) { -#define NOT_SUPPORTED() do {\ - UNUSED(uc);\ - UNUSED(eip);\ - return NULL;\ -} while(0) -#define GET_SET_RETURN(target_var, new_val) do {\ - void *old_val = (void*)target_var; \ - if (new_val) { \ - void **temp = (void**)&target_var; \ - *temp = new_val; \ - } \ - return old_val; \ -} while(0) -#if defined(__APPLE__) && !defined(MAC_OS_10_6_DETECTED) - /* OSX < 10.6 */ - #if defined(__x86_64__) - GET_SET_RETURN(uc->uc_mcontext->__ss.__rip, eip); - #elif defined(__i386__) - GET_SET_RETURN(uc->uc_mcontext->__ss.__eip, eip); - #else - GET_SET_RETURN(uc->uc_mcontext->__ss.__srr0, eip); - #endif -#elif defined(__APPLE__) && defined(MAC_OS_10_6_DETECTED) - /* OSX >= 10.6 */ - #if defined(_STRUCT_X86_THREAD_STATE64) && !defined(__i386__) - GET_SET_RETURN(uc->uc_mcontext->__ss.__rip, eip); - #elif defined(__i386__) - GET_SET_RETURN(uc->uc_mcontext->__ss.__eip, eip); - #else - /* OSX ARM64 */ - void *old_val = (void*)arm_thread_state64_get_pc(uc->uc_mcontext->__ss); - if (eip) { - arm_thread_state64_set_pc_fptr(uc->uc_mcontext->__ss, eip); - } - return old_val; - #endif -#elif defined(__linux__) - /* Linux */ - #if defined(__i386__) || ((defined(__X86_64__) || defined(__x86_64__)) && defined(__ILP32__)) - GET_SET_RETURN(uc->uc_mcontext.gregs[14], eip); - #elif defined(__X86_64__) || defined(__x86_64__) - GET_SET_RETURN(uc->uc_mcontext.gregs[16], eip); - #elif defined(__ia64__) /* Linux IA64 */ - GET_SET_RETURN(uc->uc_mcontext.sc_ip, eip); - #elif defined(__riscv) /* Linux RISC-V */ - GET_SET_RETURN(uc->uc_mcontext.__gregs[REG_PC], eip); - #elif defined(__arm__) /* Linux ARM */ - GET_SET_RETURN(uc->uc_mcontext.arm_pc, eip); - #elif defined(__aarch64__) /* Linux AArch64 */ - GET_SET_RETURN(uc->uc_mcontext.pc, eip); - #else - NOT_SUPPORTED(); - #endif -#elif defined(__FreeBSD__) - /* FreeBSD */ - #if defined(__i386__) - GET_SET_RETURN(uc->uc_mcontext.mc_eip, eip); - #elif defined(__x86_64__) - GET_SET_RETURN(uc->uc_mcontext.mc_rip, eip); - #else - NOT_SUPPORTED(); - #endif -#elif defined(__OpenBSD__) - /* OpenBSD */ - #if defined(__i386__) - GET_SET_RETURN(uc->sc_eip, eip); - #elif defined(__x86_64__) - GET_SET_RETURN(uc->sc_rip, eip); - #else - NOT_SUPPORTED(); - #endif -#elif defined(__NetBSD__) - #if defined(__i386__) - GET_SET_RETURN(uc->uc_mcontext.__gregs[_REG_EIP], eip); - #elif defined(__x86_64__) - GET_SET_RETURN(uc->uc_mcontext.__gregs[_REG_RIP], eip); - #else - NOT_SUPPORTED(); - #endif -#elif defined(__DragonFly__) - GET_SET_RETURN(uc->uc_mcontext.mc_rip, eip); -#elif defined(__sun) && defined(__x86_64__) - GET_SET_RETURN(uc->uc_mcontext.gregs[REG_RIP], eip); -#else - NOT_SUPPORTED(); -#endif -#undef NOT_SUPPORTED -} - -REDIS_NO_SANITIZE_MSAN("memory") -REDIS_NO_SANITIZE("address") -void logStackContent(void **sp) { - if (server.hide_user_data_from_log) { - serverLog(LL_NOTICE,"hide-user-data-from-log is on, skip logging stack content to avoid spilling PII."); - return; - } - int i; - for (i = 15; i >= 0; i--) { - unsigned long addr = (unsigned long) sp+i; - unsigned long val = (unsigned long) sp[i]; - - if (sizeof(long) == 4) - serverLog(LL_WARNING, "(%08lx) -> %08lx", addr, val); - else - serverLog(LL_WARNING, "(%016lx) -> %016lx", addr, val); - } -} - -/* Log dump of processor registers */ -void logRegisters(ucontext_t *uc) { - serverLog(LL_WARNING|LL_RAW, "\n------ REGISTERS ------\n"); -#define NOT_SUPPORTED() do {\ - UNUSED(uc);\ - serverLog(LL_WARNING,\ - " Dumping of registers not supported for this OS/arch");\ -} while(0) - -/* OSX */ -#if defined(__APPLE__) && defined(MAC_OS_10_6_DETECTED) - /* OSX AMD64 */ - #if defined(_STRUCT_X86_THREAD_STATE64) && !defined(__i386__) - serverLog(LL_WARNING, - "\n" - "RAX:%016lx RBX:%016lx\nRCX:%016lx RDX:%016lx\n" - "RDI:%016lx RSI:%016lx\nRBP:%016lx RSP:%016lx\n" - "R8 :%016lx R9 :%016lx\nR10:%016lx R11:%016lx\n" - "R12:%016lx R13:%016lx\nR14:%016lx R15:%016lx\n" - "RIP:%016lx EFL:%016lx\nCS :%016lx FS:%016lx GS:%016lx", - (unsigned long) uc->uc_mcontext->__ss.__rax, - (unsigned long) uc->uc_mcontext->__ss.__rbx, - (unsigned long) uc->uc_mcontext->__ss.__rcx, - (unsigned long) uc->uc_mcontext->__ss.__rdx, - (unsigned long) uc->uc_mcontext->__ss.__rdi, - (unsigned long) uc->uc_mcontext->__ss.__rsi, - (unsigned long) uc->uc_mcontext->__ss.__rbp, - (unsigned long) uc->uc_mcontext->__ss.__rsp, - (unsigned long) uc->uc_mcontext->__ss.__r8, - (unsigned long) uc->uc_mcontext->__ss.__r9, - (unsigned long) uc->uc_mcontext->__ss.__r10, - (unsigned long) uc->uc_mcontext->__ss.__r11, - (unsigned long) uc->uc_mcontext->__ss.__r12, - (unsigned long) uc->uc_mcontext->__ss.__r13, - (unsigned long) uc->uc_mcontext->__ss.__r14, - (unsigned long) uc->uc_mcontext->__ss.__r15, - (unsigned long) uc->uc_mcontext->__ss.__rip, - (unsigned long) uc->uc_mcontext->__ss.__rflags, - (unsigned long) uc->uc_mcontext->__ss.__cs, - (unsigned long) uc->uc_mcontext->__ss.__fs, - (unsigned long) uc->uc_mcontext->__ss.__gs - ); - logStackContent((void**)uc->uc_mcontext->__ss.__rsp); - #elif defined(__i386__) - /* OSX x86 */ - serverLog(LL_WARNING, - "\n" - "EAX:%08lx EBX:%08lx ECX:%08lx EDX:%08lx\n" - "EDI:%08lx ESI:%08lx EBP:%08lx ESP:%08lx\n" - "SS:%08lx EFL:%08lx EIP:%08lx CS :%08lx\n" - "DS:%08lx ES:%08lx FS :%08lx GS :%08lx", - (unsigned long) uc->uc_mcontext->__ss.__eax, - (unsigned long) uc->uc_mcontext->__ss.__ebx, - (unsigned long) uc->uc_mcontext->__ss.__ecx, - (unsigned long) uc->uc_mcontext->__ss.__edx, - (unsigned long) uc->uc_mcontext->__ss.__edi, - (unsigned long) uc->uc_mcontext->__ss.__esi, - (unsigned long) uc->uc_mcontext->__ss.__ebp, - (unsigned long) uc->uc_mcontext->__ss.__esp, - (unsigned long) uc->uc_mcontext->__ss.__ss, - (unsigned long) uc->uc_mcontext->__ss.__eflags, - (unsigned long) uc->uc_mcontext->__ss.__eip, - (unsigned long) uc->uc_mcontext->__ss.__cs, - (unsigned long) uc->uc_mcontext->__ss.__ds, - (unsigned long) uc->uc_mcontext->__ss.__es, - (unsigned long) uc->uc_mcontext->__ss.__fs, - (unsigned long) uc->uc_mcontext->__ss.__gs - ); - logStackContent((void**)uc->uc_mcontext->__ss.__esp); - #else - /* OSX ARM64 */ - serverLog(LL_WARNING, - "\n" - "x0:%016lx x1:%016lx x2:%016lx x3:%016lx\n" - "x4:%016lx x5:%016lx x6:%016lx x7:%016lx\n" - "x8:%016lx x9:%016lx x10:%016lx x11:%016lx\n" - "x12:%016lx x13:%016lx x14:%016lx x15:%016lx\n" - "x16:%016lx x17:%016lx x18:%016lx x19:%016lx\n" - "x20:%016lx x21:%016lx x22:%016lx x23:%016lx\n" - "x24:%016lx x25:%016lx x26:%016lx x27:%016lx\n" - "x28:%016lx fp:%016lx lr:%016lx\n" - "sp:%016lx pc:%016lx cpsr:%08lx\n", - (unsigned long) uc->uc_mcontext->__ss.__x[0], - (unsigned long) uc->uc_mcontext->__ss.__x[1], - (unsigned long) uc->uc_mcontext->__ss.__x[2], - (unsigned long) uc->uc_mcontext->__ss.__x[3], - (unsigned long) uc->uc_mcontext->__ss.__x[4], - (unsigned long) uc->uc_mcontext->__ss.__x[5], - (unsigned long) uc->uc_mcontext->__ss.__x[6], - (unsigned long) uc->uc_mcontext->__ss.__x[7], - (unsigned long) uc->uc_mcontext->__ss.__x[8], - (unsigned long) uc->uc_mcontext->__ss.__x[9], - (unsigned long) uc->uc_mcontext->__ss.__x[10], - (unsigned long) uc->uc_mcontext->__ss.__x[11], - (unsigned long) uc->uc_mcontext->__ss.__x[12], - (unsigned long) uc->uc_mcontext->__ss.__x[13], - (unsigned long) uc->uc_mcontext->__ss.__x[14], - (unsigned long) uc->uc_mcontext->__ss.__x[15], - (unsigned long) uc->uc_mcontext->__ss.__x[16], - (unsigned long) uc->uc_mcontext->__ss.__x[17], - (unsigned long) uc->uc_mcontext->__ss.__x[18], - (unsigned long) uc->uc_mcontext->__ss.__x[19], - (unsigned long) uc->uc_mcontext->__ss.__x[20], - (unsigned long) uc->uc_mcontext->__ss.__x[21], - (unsigned long) uc->uc_mcontext->__ss.__x[22], - (unsigned long) uc->uc_mcontext->__ss.__x[23], - (unsigned long) uc->uc_mcontext->__ss.__x[24], - (unsigned long) uc->uc_mcontext->__ss.__x[25], - (unsigned long) uc->uc_mcontext->__ss.__x[26], - (unsigned long) uc->uc_mcontext->__ss.__x[27], - (unsigned long) uc->uc_mcontext->__ss.__x[28], - (unsigned long) arm_thread_state64_get_fp(uc->uc_mcontext->__ss), - (unsigned long) arm_thread_state64_get_lr(uc->uc_mcontext->__ss), - (unsigned long) arm_thread_state64_get_sp(uc->uc_mcontext->__ss), - (unsigned long) arm_thread_state64_get_pc(uc->uc_mcontext->__ss), - (unsigned long) uc->uc_mcontext->__ss.__cpsr - ); - logStackContent((void**) arm_thread_state64_get_sp(uc->uc_mcontext->__ss)); - #endif -/* Linux */ -#elif defined(__linux__) - /* Linux x86 */ - #if defined(__i386__) || ((defined(__X86_64__) || defined(__x86_64__)) && defined(__ILP32__)) - serverLog(LL_WARNING, - "\n" - "EAX:%08lx EBX:%08lx ECX:%08lx EDX:%08lx\n" - "EDI:%08lx ESI:%08lx EBP:%08lx ESP:%08lx\n" - "SS :%08lx EFL:%08lx EIP:%08lx CS:%08lx\n" - "DS :%08lx ES :%08lx FS :%08lx GS:%08lx", - (unsigned long) uc->uc_mcontext.gregs[11], - (unsigned long) uc->uc_mcontext.gregs[8], - (unsigned long) uc->uc_mcontext.gregs[10], - (unsigned long) uc->uc_mcontext.gregs[9], - (unsigned long) uc->uc_mcontext.gregs[4], - (unsigned long) uc->uc_mcontext.gregs[5], - (unsigned long) uc->uc_mcontext.gregs[6], - (unsigned long) uc->uc_mcontext.gregs[7], - (unsigned long) uc->uc_mcontext.gregs[18], - (unsigned long) uc->uc_mcontext.gregs[17], - (unsigned long) uc->uc_mcontext.gregs[14], - (unsigned long) uc->uc_mcontext.gregs[15], - (unsigned long) uc->uc_mcontext.gregs[3], - (unsigned long) uc->uc_mcontext.gregs[2], - (unsigned long) uc->uc_mcontext.gregs[1], - (unsigned long) uc->uc_mcontext.gregs[0] - ); - logStackContent((void**)uc->uc_mcontext.gregs[7]); - #elif defined(__X86_64__) || defined(__x86_64__) - /* Linux AMD64 */ - serverLog(LL_WARNING, - "\n" - "RAX:%016lx RBX:%016lx\nRCX:%016lx RDX:%016lx\n" - "RDI:%016lx RSI:%016lx\nRBP:%016lx RSP:%016lx\n" - "R8 :%016lx R9 :%016lx\nR10:%016lx R11:%016lx\n" - "R12:%016lx R13:%016lx\nR14:%016lx R15:%016lx\n" - "RIP:%016lx EFL:%016lx\nCSGSFS:%016lx", - (unsigned long) uc->uc_mcontext.gregs[13], - (unsigned long) uc->uc_mcontext.gregs[11], - (unsigned long) uc->uc_mcontext.gregs[14], - (unsigned long) uc->uc_mcontext.gregs[12], - (unsigned long) uc->uc_mcontext.gregs[8], - (unsigned long) uc->uc_mcontext.gregs[9], - (unsigned long) uc->uc_mcontext.gregs[10], - (unsigned long) uc->uc_mcontext.gregs[15], - (unsigned long) uc->uc_mcontext.gregs[0], - (unsigned long) uc->uc_mcontext.gregs[1], - (unsigned long) uc->uc_mcontext.gregs[2], - (unsigned long) uc->uc_mcontext.gregs[3], - (unsigned long) uc->uc_mcontext.gregs[4], - (unsigned long) uc->uc_mcontext.gregs[5], - (unsigned long) uc->uc_mcontext.gregs[6], - (unsigned long) uc->uc_mcontext.gregs[7], - (unsigned long) uc->uc_mcontext.gregs[16], - (unsigned long) uc->uc_mcontext.gregs[17], - (unsigned long) uc->uc_mcontext.gregs[18] - ); - logStackContent((void**)uc->uc_mcontext.gregs[15]); - #elif defined(__riscv) /* Linux RISC-V */ - serverLog(LL_WARNING, - "\n" - "ra:%016lx gp:%016lx\ntp:%016lx t0:%016lx\n" - "t1:%016lx t2:%016lx\ns0:%016lx s1:%016lx\n" - "a0:%016lx a1:%016lx\na2:%016lx a3:%016lx\n" - "a4:%016lx a5:%016lx\na6:%016lx a7:%016lx\n" - "s2:%016lx s3:%016lx\ns4:%016lx s5:%016lx\n" - "s6:%016lx s7:%016lx\ns8:%016lx s9:%016lx\n" - "s10:%016lx s11:%016lx\nt3:%016lx t4:%016lx\n" - "t5:%016lx t6:%016lx\n", - (unsigned long) uc->uc_mcontext.__gregs[1], - (unsigned long) uc->uc_mcontext.__gregs[3], - (unsigned long) uc->uc_mcontext.__gregs[4], - (unsigned long) uc->uc_mcontext.__gregs[5], - (unsigned long) uc->uc_mcontext.__gregs[6], - (unsigned long) uc->uc_mcontext.__gregs[7], - (unsigned long) uc->uc_mcontext.__gregs[8], - (unsigned long) uc->uc_mcontext.__gregs[9], - (unsigned long) uc->uc_mcontext.__gregs[10], - (unsigned long) uc->uc_mcontext.__gregs[11], - (unsigned long) uc->uc_mcontext.__gregs[12], - (unsigned long) uc->uc_mcontext.__gregs[13], - (unsigned long) uc->uc_mcontext.__gregs[14], - (unsigned long) uc->uc_mcontext.__gregs[15], - (unsigned long) uc->uc_mcontext.__gregs[16], - (unsigned long) uc->uc_mcontext.__gregs[17], - (unsigned long) uc->uc_mcontext.__gregs[18], - (unsigned long) uc->uc_mcontext.__gregs[19], - (unsigned long) uc->uc_mcontext.__gregs[20], - (unsigned long) uc->uc_mcontext.__gregs[21], - (unsigned long) uc->uc_mcontext.__gregs[22], - (unsigned long) uc->uc_mcontext.__gregs[23], - (unsigned long) uc->uc_mcontext.__gregs[24], - (unsigned long) uc->uc_mcontext.__gregs[25], - (unsigned long) uc->uc_mcontext.__gregs[26], - (unsigned long) uc->uc_mcontext.__gregs[27], - (unsigned long) uc->uc_mcontext.__gregs[28], - (unsigned long) uc->uc_mcontext.__gregs[29], - (unsigned long) uc->uc_mcontext.__gregs[30], - (unsigned long) uc->uc_mcontext.__gregs[31] - ); - logStackContent((void**)uc->uc_mcontext.__gregs[REG_SP]); - #elif defined(__aarch64__) /* Linux AArch64 */ - serverLog(LL_WARNING, - "\n" - "X18:%016lx X19:%016lx\nX20:%016lx X21:%016lx\n" - "X22:%016lx X23:%016lx\nX24:%016lx X25:%016lx\n" - "X26:%016lx X27:%016lx\nX28:%016lx X29:%016lx\n" - "X30:%016lx\n" - "pc:%016lx sp:%016lx\npstate:%016lx fault_address:%016lx\n", - (unsigned long) uc->uc_mcontext.regs[18], - (unsigned long) uc->uc_mcontext.regs[19], - (unsigned long) uc->uc_mcontext.regs[20], - (unsigned long) uc->uc_mcontext.regs[21], - (unsigned long) uc->uc_mcontext.regs[22], - (unsigned long) uc->uc_mcontext.regs[23], - (unsigned long) uc->uc_mcontext.regs[24], - (unsigned long) uc->uc_mcontext.regs[25], - (unsigned long) uc->uc_mcontext.regs[26], - (unsigned long) uc->uc_mcontext.regs[27], - (unsigned long) uc->uc_mcontext.regs[28], - (unsigned long) uc->uc_mcontext.regs[29], - (unsigned long) uc->uc_mcontext.regs[30], - (unsigned long) uc->uc_mcontext.pc, - (unsigned long) uc->uc_mcontext.sp, - (unsigned long) uc->uc_mcontext.pstate, - (unsigned long) uc->uc_mcontext.fault_address - ); - logStackContent((void**)uc->uc_mcontext.sp); - #elif defined(__arm__) /* Linux ARM */ - serverLog(LL_WARNING, - "\n" - "R10:%016lx R9 :%016lx\nR8 :%016lx R7 :%016lx\n" - "R6 :%016lx R5 :%016lx\nR4 :%016lx R3 :%016lx\n" - "R2 :%016lx R1 :%016lx\nR0 :%016lx EC :%016lx\n" - "fp: %016lx ip:%016lx\n" - "pc:%016lx sp:%016lx\ncpsr:%016lx fault_address:%016lx\n", - (unsigned long) uc->uc_mcontext.arm_r10, - (unsigned long) uc->uc_mcontext.arm_r9, - (unsigned long) uc->uc_mcontext.arm_r8, - (unsigned long) uc->uc_mcontext.arm_r7, - (unsigned long) uc->uc_mcontext.arm_r6, - (unsigned long) uc->uc_mcontext.arm_r5, - (unsigned long) uc->uc_mcontext.arm_r4, - (unsigned long) uc->uc_mcontext.arm_r3, - (unsigned long) uc->uc_mcontext.arm_r2, - (unsigned long) uc->uc_mcontext.arm_r1, - (unsigned long) uc->uc_mcontext.arm_r0, - (unsigned long) uc->uc_mcontext.error_code, - (unsigned long) uc->uc_mcontext.arm_fp, - (unsigned long) uc->uc_mcontext.arm_ip, - (unsigned long) uc->uc_mcontext.arm_pc, - (unsigned long) uc->uc_mcontext.arm_sp, - (unsigned long) uc->uc_mcontext.arm_cpsr, - (unsigned long) uc->uc_mcontext.fault_address - ); - logStackContent((void**)uc->uc_mcontext.arm_sp); - #else - NOT_SUPPORTED(); - #endif -#elif defined(__FreeBSD__) - #if defined(__x86_64__) - serverLog(LL_WARNING, - "\n" - "RAX:%016lx RBX:%016lx\nRCX:%016lx RDX:%016lx\n" - "RDI:%016lx RSI:%016lx\nRBP:%016lx RSP:%016lx\n" - "R8 :%016lx R9 :%016lx\nR10:%016lx R11:%016lx\n" - "R12:%016lx R13:%016lx\nR14:%016lx R15:%016lx\n" - "RIP:%016lx EFL:%016lx\nCSGSFS:%016lx", - (unsigned long) uc->uc_mcontext.mc_rax, - (unsigned long) uc->uc_mcontext.mc_rbx, - (unsigned long) uc->uc_mcontext.mc_rcx, - (unsigned long) uc->uc_mcontext.mc_rdx, - (unsigned long) uc->uc_mcontext.mc_rdi, - (unsigned long) uc->uc_mcontext.mc_rsi, - (unsigned long) uc->uc_mcontext.mc_rbp, - (unsigned long) uc->uc_mcontext.mc_rsp, - (unsigned long) uc->uc_mcontext.mc_r8, - (unsigned long) uc->uc_mcontext.mc_r9, - (unsigned long) uc->uc_mcontext.mc_r10, - (unsigned long) uc->uc_mcontext.mc_r11, - (unsigned long) uc->uc_mcontext.mc_r12, - (unsigned long) uc->uc_mcontext.mc_r13, - (unsigned long) uc->uc_mcontext.mc_r14, - (unsigned long) uc->uc_mcontext.mc_r15, - (unsigned long) uc->uc_mcontext.mc_rip, - (unsigned long) uc->uc_mcontext.mc_rflags, - (unsigned long) uc->uc_mcontext.mc_cs - ); - logStackContent((void**)uc->uc_mcontext.mc_rsp); - #elif defined(__i386__) - serverLog(LL_WARNING, - "\n" - "EAX:%08lx EBX:%08lx ECX:%08lx EDX:%08lx\n" - "EDI:%08lx ESI:%08lx EBP:%08lx ESP:%08lx\n" - "SS :%08lx EFL:%08lx EIP:%08lx CS:%08lx\n" - "DS :%08lx ES :%08lx FS :%08lx GS:%08lx", - (unsigned long) uc->uc_mcontext.mc_eax, - (unsigned long) uc->uc_mcontext.mc_ebx, - (unsigned long) uc->uc_mcontext.mc_ebx, - (unsigned long) uc->uc_mcontext.mc_edx, - (unsigned long) uc->uc_mcontext.mc_edi, - (unsigned long) uc->uc_mcontext.mc_esi, - (unsigned long) uc->uc_mcontext.mc_ebp, - (unsigned long) uc->uc_mcontext.mc_esp, - (unsigned long) uc->uc_mcontext.mc_ss, - (unsigned long) uc->uc_mcontext.mc_eflags, - (unsigned long) uc->uc_mcontext.mc_eip, - (unsigned long) uc->uc_mcontext.mc_cs, - (unsigned long) uc->uc_mcontext.mc_es, - (unsigned long) uc->uc_mcontext.mc_fs, - (unsigned long) uc->uc_mcontext.mc_gs - ); - logStackContent((void**)uc->uc_mcontext.mc_esp); - #else - NOT_SUPPORTED(); - #endif -#elif defined(__OpenBSD__) - #if defined(__x86_64__) - serverLog(LL_WARNING, - "\n" - "RAX:%016lx RBX:%016lx\nRCX:%016lx RDX:%016lx\n" - "RDI:%016lx RSI:%016lx\nRBP:%016lx RSP:%016lx\n" - "R8 :%016lx R9 :%016lx\nR10:%016lx R11:%016lx\n" - "R12:%016lx R13:%016lx\nR14:%016lx R15:%016lx\n" - "RIP:%016lx EFL:%016lx\nCSGSFS:%016lx", - (unsigned long) uc->sc_rax, - (unsigned long) uc->sc_rbx, - (unsigned long) uc->sc_rcx, - (unsigned long) uc->sc_rdx, - (unsigned long) uc->sc_rdi, - (unsigned long) uc->sc_rsi, - (unsigned long) uc->sc_rbp, - (unsigned long) uc->sc_rsp, - (unsigned long) uc->sc_r8, - (unsigned long) uc->sc_r9, - (unsigned long) uc->sc_r10, - (unsigned long) uc->sc_r11, - (unsigned long) uc->sc_r12, - (unsigned long) uc->sc_r13, - (unsigned long) uc->sc_r14, - (unsigned long) uc->sc_r15, - (unsigned long) uc->sc_rip, - (unsigned long) uc->sc_rflags, - (unsigned long) uc->sc_cs - ); - logStackContent((void**)uc->sc_rsp); - #elif defined(__i386__) - serverLog(LL_WARNING, - "\n" - "EAX:%08lx EBX:%08lx ECX:%08lx EDX:%08lx\n" - "EDI:%08lx ESI:%08lx EBP:%08lx ESP:%08lx\n" - "SS :%08lx EFL:%08lx EIP:%08lx CS:%08lx\n" - "DS :%08lx ES :%08lx FS :%08lx GS:%08lx", - (unsigned long) uc->sc_eax, - (unsigned long) uc->sc_ebx, - (unsigned long) uc->sc_ebx, - (unsigned long) uc->sc_edx, - (unsigned long) uc->sc_edi, - (unsigned long) uc->sc_esi, - (unsigned long) uc->sc_ebp, - (unsigned long) uc->sc_esp, - (unsigned long) uc->sc_ss, - (unsigned long) uc->sc_eflags, - (unsigned long) uc->sc_eip, - (unsigned long) uc->sc_cs, - (unsigned long) uc->sc_es, - (unsigned long) uc->sc_fs, - (unsigned long) uc->sc_gs - ); - logStackContent((void**)uc->sc_esp); - #else - NOT_SUPPORTED(); - #endif -#elif defined(__NetBSD__) - #if defined(__x86_64__) - serverLog(LL_WARNING, - "\n" - "RAX:%016lx RBX:%016lx\nRCX:%016lx RDX:%016lx\n" - "RDI:%016lx RSI:%016lx\nRBP:%016lx RSP:%016lx\n" - "R8 :%016lx R9 :%016lx\nR10:%016lx R11:%016lx\n" - "R12:%016lx R13:%016lx\nR14:%016lx R15:%016lx\n" - "RIP:%016lx EFL:%016lx\nCSGSFS:%016lx", - (unsigned long) uc->uc_mcontext.__gregs[_REG_RAX], - (unsigned long) uc->uc_mcontext.__gregs[_REG_RBX], - (unsigned long) uc->uc_mcontext.__gregs[_REG_RCX], - (unsigned long) uc->uc_mcontext.__gregs[_REG_RDX], - (unsigned long) uc->uc_mcontext.__gregs[_REG_RDI], - (unsigned long) uc->uc_mcontext.__gregs[_REG_RSI], - (unsigned long) uc->uc_mcontext.__gregs[_REG_RBP], - (unsigned long) uc->uc_mcontext.__gregs[_REG_RSP], - (unsigned long) uc->uc_mcontext.__gregs[_REG_R8], - (unsigned long) uc->uc_mcontext.__gregs[_REG_R9], - (unsigned long) uc->uc_mcontext.__gregs[_REG_R10], - (unsigned long) uc->uc_mcontext.__gregs[_REG_R11], - (unsigned long) uc->uc_mcontext.__gregs[_REG_R12], - (unsigned long) uc->uc_mcontext.__gregs[_REG_R13], - (unsigned long) uc->uc_mcontext.__gregs[_REG_R14], - (unsigned long) uc->uc_mcontext.__gregs[_REG_R15], - (unsigned long) uc->uc_mcontext.__gregs[_REG_RIP], - (unsigned long) uc->uc_mcontext.__gregs[_REG_RFLAGS], - (unsigned long) uc->uc_mcontext.__gregs[_REG_CS] - ); - logStackContent((void**)uc->uc_mcontext.__gregs[_REG_RSP]); - #elif defined(__i386__) - serverLog(LL_WARNING, - "\n" - "EAX:%08lx EBX:%08lx ECX:%08lx EDX:%08lx\n" - "EDI:%08lx ESI:%08lx EBP:%08lx ESP:%08lx\n" - "SS :%08lx EFL:%08lx EIP:%08lx CS:%08lx\n" - "DS :%08lx ES :%08lx FS :%08lx GS:%08lx", - (unsigned long) uc->uc_mcontext.__gregs[_REG_EAX], - (unsigned long) uc->uc_mcontext.__gregs[_REG_EBX], - (unsigned long) uc->uc_mcontext.__gregs[_REG_EDX], - (unsigned long) uc->uc_mcontext.__gregs[_REG_EDI], - (unsigned long) uc->uc_mcontext.__gregs[_REG_ESI], - (unsigned long) uc->uc_mcontext.__gregs[_REG_EBP], - (unsigned long) uc->uc_mcontext.__gregs[_REG_ESP], - (unsigned long) uc->uc_mcontext.__gregs[_REG_SS], - (unsigned long) uc->uc_mcontext.__gregs[_REG_EFLAGS], - (unsigned long) uc->uc_mcontext.__gregs[_REG_EIP], - (unsigned long) uc->uc_mcontext.__gregs[_REG_CS], - (unsigned long) uc->uc_mcontext.__gregs[_REG_ES], - (unsigned long) uc->uc_mcontext.__gregs[_REG_FS], - (unsigned long) uc->uc_mcontext.__gregs[_REG_GS] - ); - #else - NOT_SUPPORTED(); - #endif -#elif defined(__DragonFly__) - serverLog(LL_WARNING, - "\n" - "RAX:%016lx RBX:%016lx\nRCX:%016lx RDX:%016lx\n" - "RDI:%016lx RSI:%016lx\nRBP:%016lx RSP:%016lx\n" - "R8 :%016lx R9 :%016lx\nR10:%016lx R11:%016lx\n" - "R12:%016lx R13:%016lx\nR14:%016lx R15:%016lx\n" - "RIP:%016lx EFL:%016lx\nCSGSFS:%016lx", - (unsigned long) uc->uc_mcontext.mc_rax, - (unsigned long) uc->uc_mcontext.mc_rbx, - (unsigned long) uc->uc_mcontext.mc_rcx, - (unsigned long) uc->uc_mcontext.mc_rdx, - (unsigned long) uc->uc_mcontext.mc_rdi, - (unsigned long) uc->uc_mcontext.mc_rsi, - (unsigned long) uc->uc_mcontext.mc_rbp, - (unsigned long) uc->uc_mcontext.mc_rsp, - (unsigned long) uc->uc_mcontext.mc_r8, - (unsigned long) uc->uc_mcontext.mc_r9, - (unsigned long) uc->uc_mcontext.mc_r10, - (unsigned long) uc->uc_mcontext.mc_r11, - (unsigned long) uc->uc_mcontext.mc_r12, - (unsigned long) uc->uc_mcontext.mc_r13, - (unsigned long) uc->uc_mcontext.mc_r14, - (unsigned long) uc->uc_mcontext.mc_r15, - (unsigned long) uc->uc_mcontext.mc_rip, - (unsigned long) uc->uc_mcontext.mc_rflags, - (unsigned long) uc->uc_mcontext.mc_cs - ); - logStackContent((void**)uc->uc_mcontext.mc_rsp); -#elif defined(__sun) - #if defined(__x86_64__) - serverLog(LL_WARNING, - "\n" - "RAX:%016lx RBX:%016lx\nRCX:%016lx RDX:%016lx\n" - "RDI:%016lx RSI:%016lx\nRBP:%016lx RSP:%016lx\n" - "R8 :%016lx R9 :%016lx\nR10:%016lx R11:%016lx\n" - "R12:%016lx R13:%016lx\nR14:%016lx R15:%016lx\n" - "RIP:%016lx EFL:%016lx\nCSGSFS:%016lx", - (unsigned long) uc->uc_mcontext.gregs[REG_RAX], - (unsigned long) uc->uc_mcontext.gregs[REG_RBX], - (unsigned long) uc->uc_mcontext.gregs[REG_RCX], - (unsigned long) uc->uc_mcontext.gregs[REG_RDX], - (unsigned long) uc->uc_mcontext.gregs[REG_RDI], - (unsigned long) uc->uc_mcontext.gregs[REG_RSI], - (unsigned long) uc->uc_mcontext.gregs[REG_RBP], - (unsigned long) uc->uc_mcontext.gregs[REG_RSP], - (unsigned long) uc->uc_mcontext.gregs[REG_R8], - (unsigned long) uc->uc_mcontext.gregs[REG_R9], - (unsigned long) uc->uc_mcontext.gregs[REG_R10], - (unsigned long) uc->uc_mcontext.gregs[REG_R11], - (unsigned long) uc->uc_mcontext.gregs[REG_R12], - (unsigned long) uc->uc_mcontext.gregs[REG_R13], - (unsigned long) uc->uc_mcontext.gregs[REG_R14], - (unsigned long) uc->uc_mcontext.gregs[REG_R15], - (unsigned long) uc->uc_mcontext.gregs[REG_RIP], - (unsigned long) uc->uc_mcontext.gregs[REG_RFL], - (unsigned long) uc->uc_mcontext.gregs[REG_CS] - ); - logStackContent((void**)uc->uc_mcontext.gregs[REG_RSP]); - #endif -#else - NOT_SUPPORTED(); -#endif -#undef NOT_SUPPORTED -} - -#endif /* HAVE_BACKTRACE */ - -/* Return a file descriptor to write directly to the Redis log with the - * write(2) syscall, that can be used in critical sections of the code - * where the rest of Redis can't be trusted (for example during the memory - * test) or when an API call requires a raw fd. - * - * Close it with closeDirectLogFiledes(). */ -int openDirectLogFiledes(void) { - int log_to_stdout = server.logfile[0] == '\0'; - int fd = log_to_stdout ? - STDOUT_FILENO : - open(server.logfile, O_APPEND|O_CREAT|O_WRONLY, 0644); - return fd; -} - -/* Used to close what closeDirectLogFiledes() returns. */ -void closeDirectLogFiledes(int fd) { - int log_to_stdout = server.logfile[0] == '\0'; - if (!log_to_stdout) close(fd); -} - -#if defined(HAVE_BACKTRACE) && defined(__linux__) -static int stacktrace_pipe[2] = {0}; -static void setupStacktracePipe(void) { - if (-1 == anetPipe(stacktrace_pipe, O_CLOEXEC | O_NONBLOCK, O_CLOEXEC | O_NONBLOCK)) { - serverLog(LL_WARNING, "setupStacktracePipe failed: %s", strerror(errno)); - } -} -#else -static void setupStacktracePipe(void) {/* we don't need a pipe to write the stacktraces */} -#endif -#ifdef HAVE_BACKTRACE -#define BACKTRACE_MAX_SIZE 100 - -#ifdef __linux__ -#if !defined(_GNU_SOURCE) -#define _GNU_SOURCE -#endif -#include <sys/prctl.h> -#include <unistd.h> -#include <sys/syscall.h> -#include <dirent.h> - -#define TIDS_MAX_SIZE 50 -static size_t get_ready_to_signal_threads_tids(int sig_num, pid_t tids[TIDS_MAX_SIZE]); - -typedef struct { - char thread_name[16]; - int trace_size; - pid_t tid; - void *trace[BACKTRACE_MAX_SIZE]; -} stacktrace_data; - -__attribute__ ((noinline)) static void collect_stacktrace_data(void) { - stacktrace_data trace_data = {{0}}; - - /* Get the stack trace first! */ - trace_data.trace_size = backtrace(trace_data.trace, BACKTRACE_MAX_SIZE); - - /* get the thread name */ - prctl(PR_GET_NAME, trace_data.thread_name); - - /* get the thread id */ - trace_data.tid = syscall(SYS_gettid); - - /* Send the output to the main process*/ - if (write(stacktrace_pipe[1], &trace_data, sizeof(trace_data)) == -1) {/* Avoid warning. */}; -} - -__attribute__ ((noinline)) -static void writeStacktraces(int fd, int uplevel) { - /* get the list of all the process's threads that don't block or ignore the THREADS_SIGNAL */ - pid_t tids[TIDS_MAX_SIZE]; - size_t len_tids = get_ready_to_signal_threads_tids(THREADS_SIGNAL, tids); - if (!len_tids) { - serverLogRawFromHandler(LL_WARNING, "writeStacktraces(): Failed to get the process's threads."); - } - - char buff[PIPE_BUF]; - /* Clear the stacktraces pipe */ - while (read(stacktrace_pipe[0], &buff, sizeof(buff)) > 0) {} - - /* ThreadsManager_runOnThreads returns 0 if it is already running */ - if (!ThreadsManager_runOnThreads(tids, len_tids, collect_stacktrace_data)) return; - - size_t collected = 0; - - pid_t calling_tid = syscall(SYS_gettid); - - /* Read the stacktrace_pipe until it's empty */ - stacktrace_data curr_stacktrace_data = {{0}}; - while (read(stacktrace_pipe[0], &curr_stacktrace_data, sizeof(curr_stacktrace_data)) > 0) { - /* stacktrace header includes the tid and the thread's name */ - snprintf_async_signal_safe(buff, sizeof(buff), "\n%d %s", curr_stacktrace_data.tid, curr_stacktrace_data.thread_name); - if (write(fd,buff,strlen(buff)) == -1) {/* Avoid warning. */}; - - /* skip kernel call to the signal handler, the signal handler and the callback addresses */ - int curr_uplevel = 3; - - if (curr_stacktrace_data.tid == calling_tid) { - /* skip signal syscall and ThreadsManager_runOnThreads */ - curr_uplevel += uplevel + 2; - /* Add an indication to header of the thread that is handling the log file */ - if (write(fd," *\n",strlen(" *\n")) == -1) {/* Avoid warning. */}; - } else { - /* just add a new line */ - if (write(fd,"\n",strlen("\n")) == -1) {/* Avoid warning. */}; - } - - /* add the stacktrace */ - backtrace_symbols_fd(curr_stacktrace_data.trace+curr_uplevel, curr_stacktrace_data.trace_size-curr_uplevel, fd); - - ++collected; - } - - snprintf_async_signal_safe(buff, sizeof(buff), "\n%lu/%lu expected stacktraces.\n", (long unsigned)(collected), (long unsigned)len_tids); - if (write(fd,buff,strlen(buff)) == -1) {/* Avoid warning. */}; - -} - -#endif /* __linux__ */ -__attribute__ ((noinline)) -static void writeCurrentThreadsStackTrace(int fd, int uplevel) { - void *trace[BACKTRACE_MAX_SIZE]; - - int trace_size = backtrace(trace, BACKTRACE_MAX_SIZE); - - char *msg = "\nBacktrace:\n"; - if (write(fd,msg,strlen(msg)) == -1) {/* Avoid warning. */}; - backtrace_symbols_fd(trace+uplevel, trace_size-uplevel, fd); -} - -/* Logs the stack trace using the backtrace() call. This function is designed - * to be called from signal handlers safely. - * The eip argument is optional (can take NULL). - * The uplevel argument indicates how many of the calling functions to skip. - * Functions that are taken in consideration in "uplevel" should be declared with - * __attribute__ ((noinline)) to make sure the compiler won't inline them. - */ -__attribute__ ((noinline)) -void logStackTrace(void *eip, int uplevel, int current_thread) { - int fd = openDirectLogFiledes(); - char *msg; - uplevel++; /* skip this function */ - - if (fd == -1) return; /* If we can't log there is anything to do. */ - - msg = "\n------ STACK TRACE ------\n"; - if (write(fd,msg,strlen(msg)) == -1) {/* Avoid warning. */}; - - if (eip) { - /* Write EIP to the log file*/ - msg = "EIP:\n"; - if (write(fd,msg,strlen(msg)) == -1) {/* Avoid warning. */}; - backtrace_symbols_fd(&eip, 1, fd); - } - - /* Write symbols to log file */ - ++uplevel; -#ifdef __linux__ - if (current_thread) { - writeCurrentThreadsStackTrace(fd, uplevel); - } else { - writeStacktraces(fd, uplevel); - } -#else - /* Outside of linux, we only support writing the current thread. */ - UNUSED(current_thread); - writeCurrentThreadsStackTrace(fd, uplevel); -#endif - msg = "\n------ STACK TRACE DONE ------\n"; - if (write(fd,msg,strlen(msg)) == -1) {/* Avoid warning. */}; - - - /* Cleanup */ - closeDirectLogFiledes(fd); -} - -#endif /* HAVE_BACKTRACE */ - -sds genClusterDebugString(sds infostring) { - sds cluster_info = genClusterInfoString(); - sds cluster_nodes = clusterGenNodesDescription(NULL, 0, 0); - - infostring = sdscatprintf(infostring, "\r\n# Cluster info\r\n"); - infostring = sdscatsds(infostring, cluster_info); - infostring = sdscatprintf(infostring, "\n------ CLUSTER NODES OUTPUT ------\n"); - infostring = sdscatsds(infostring, cluster_nodes); - - sdsfree(cluster_info); - sdsfree(cluster_nodes); - - return infostring; -} - -/* Log global server info */ -void logServerInfo(void) { - sds infostring, clients; - serverLogRaw(LL_WARNING|LL_RAW, "\n------ INFO OUTPUT ------\n"); - int all = 0, everything = 0; - robj *argv[1]; - argv[0] = createStringObject("all", strlen("all")); - dict *section_dict = genInfoSectionDict(argv, 1, NULL, &all, &everything); - infostring = genRedisInfoString(section_dict, all, everything); - if (server.cluster_enabled){ - infostring = genClusterDebugString(infostring); - } - serverLogRaw(LL_WARNING|LL_RAW, infostring); - serverLogRaw(LL_WARNING|LL_RAW, "\n------ CLIENT LIST OUTPUT ------\n"); - clients = getAllClientsInfoString(-1); - serverLogRaw(LL_WARNING|LL_RAW, clients); - sdsfree(infostring); - sdsfree(clients); - releaseInfoSectionDict(section_dict); - decrRefCount(argv[0]); -} - -/* Log certain config values, which can be used for debugging */ -void logConfigDebugInfo(void) { - sds configstring; - configstring = getConfigDebugInfo(); - serverLogRaw(LL_WARNING|LL_RAW, "\n------ CONFIG DEBUG OUTPUT ------\n"); - serverLogRaw(LL_WARNING|LL_RAW, configstring); - sdsfree(configstring); -} - -/* Log modules info. Something we wanna do last since we fear it may crash. */ -void logModulesInfo(void) { - serverLogRaw(LL_WARNING|LL_RAW, "\n------ MODULES INFO OUTPUT ------\n"); - sds infostring = modulesCollectInfo(sdsempty(), NULL, 1, 0); - serverLogRaw(LL_WARNING|LL_RAW, infostring); - sdsfree(infostring); -} - -/* Log information about the "current" client, that is, the client that is - * currently being served by Redis. May be NULL if Redis is not serving a - * client right now. */ -void logCurrentClient(client *cc, const char *title) { - if (cc == NULL) return; - - sds client; - int j; - struct redisCommand *cmd = NULL; - struct cmdToken tokens = {{0}}; - - serverLog(LL_WARNING|LL_RAW, "\n------ %s CLIENT INFO ------\n", title); - client = catClientInfoString(sdsempty(),cc); - serverLog(LL_WARNING|LL_RAW,"%s\n", client); - sdsfree(client); - serverLog(LL_WARNING|LL_RAW,"argc: '%d'\n", cc->argc); - if (server.hide_user_data_from_log) { - cmd = lookupCommand(cc->argv, cc->argc); - if (cmd) - cmdTokenGetFromCommand(&tokens, cmd); - } - - for (j = 0; j < cc->argc; j++) { - /* Allow command name, subcommand name and command tokens in the log. */ - if (server.hide_user_data_from_log && (j != 0 && !(j == 1 && cmd && cmd->parent))) { - if (!cmdTokenCheck(&tokens, cc->argv[j])) { - serverLog(LL_WARNING|LL_RAW, "argv[%d]: '*redacted*'\n", j); - continue; - } - } - robj *decoded; - decoded = getDecodedObject(cc->argv[j]); - sds repr = sdscatrepr(sdsempty(),decoded->ptr, min(sdslen(decoded->ptr), 1024)); - serverLog(LL_WARNING|LL_RAW,"argv[%d]: '%s'\n", j, (char*)repr); - if (!strcasecmp(decoded->ptr, "auth") || !strcasecmp(decoded->ptr, "auth2")) { - sdsfree(repr); - decrRefCount(decoded); - break; - } - sdsfree(repr); - decrRefCount(decoded); - } - /* Check if the first argument, usually a key, is found inside the - * selected DB, and if so print info about the associated object. */ - if (cc->argc > 1) { - robj *key = getDecodedObject(cc->argv[1]); - kvobj *kv = dbFind(cc->db, key->ptr); - if (kv) { - serverLog(LL_WARNING,"key '%s' found in DB containing the following object:", (char*)key->ptr); - serverLogObjectDebugInfo(kv); - } - decrRefCount(key); - } -} - -#if defined(HAVE_PROC_MAPS) - -#define MEMTEST_MAX_REGIONS 128 - -/* A non destructive memory test executed during segfault. */ -int memtest_test_linux_anonymous_maps(void) { - FILE *fp; - char line[1024]; - char logbuf[1024]; - size_t start_addr, end_addr, size; - size_t start_vect[MEMTEST_MAX_REGIONS]; - size_t size_vect[MEMTEST_MAX_REGIONS]; - int regions = 0, j; - - int fd = openDirectLogFiledes(); - if (fd == -1) return 0; - - fp = fopen("/proc/self/maps","r"); - if (!fp) { - closeDirectLogFiledes(fd); - return 0; - } - while(fgets(line,sizeof(line),fp) != NULL) { - char *start, *end, *p = line; - - start = p; - p = strchr(p,'-'); - if (!p) continue; - *p++ = '\0'; - end = p; - p = strchr(p,' '); - if (!p) continue; - *p++ = '\0'; - if (strstr(p,"stack") || - strstr(p,"vdso") || - strstr(p,"vsyscall")) continue; - if (!strstr(p,"00:00")) continue; - if (!strstr(p,"rw")) continue; - - start_addr = strtoul(start,NULL,16); - end_addr = strtoul(end,NULL,16); - size = end_addr-start_addr; - - start_vect[regions] = start_addr; - size_vect[regions] = size; - snprintf(logbuf,sizeof(logbuf), - "*** Preparing to test memory region %lx (%lu bytes)\n", - (unsigned long) start_vect[regions], - (unsigned long) size_vect[regions]); - if (write(fd,logbuf,strlen(logbuf)) == -1) { /* Nothing to do. */ } - regions++; - } - - int errors = 0; - for (j = 0; j < regions; j++) { - if (write(fd,".",1) == -1) { /* Nothing to do. */ } - errors += memtest_preserving_test((void*)start_vect[j],size_vect[j],1); - if (write(fd, errors ? "E" : "O",1) == -1) { /* Nothing to do. */ } - } - if (write(fd,"\n",1) == -1) { /* Nothing to do. */ } - - /* NOTE: It is very important to close the file descriptor only now - * because closing it before may result into unmapping of some memory - * region that we are testing. */ - fclose(fp); - closeDirectLogFiledes(fd); - return errors; -} -#endif /* HAVE_PROC_MAPS */ - -static void killMainThread(void) { - int err; - if (pthread_self() != server.main_thread_id && pthread_cancel(server.main_thread_id) == 0) { - if ((err = pthread_join(server.main_thread_id,NULL)) != 0) { - serverLog(LL_WARNING, "main thread can not be joined: %s", strerror(err)); - } else { - serverLog(LL_WARNING, "main thread terminated"); - } - } -} - -/* Kill the running threads (other than current) in an unclean way. This function - * should be used only when it's critical to stop the threads for some reason. - * Currently Redis does this only on crash (for instance on SIGSEGV) in order - * to perform a fast memory check without other threads messing with memory. */ -void killThreads(void) { - killMainThread(); - bioKillThreads(); - killIOThreads(); -} - -void doFastMemoryTest(void) { -#if defined(HAVE_PROC_MAPS) - if (server.memcheck_enabled) { - /* Test memory */ - serverLogRaw(LL_WARNING|LL_RAW, "\n------ FAST MEMORY TEST ------\n"); - killThreads(); - if (memtest_test_linux_anonymous_maps()) { - serverLogRaw(LL_WARNING|LL_RAW, - "!!! MEMORY ERROR DETECTED! Check your memory ASAP !!!\n"); - } else { - serverLogRaw(LL_WARNING|LL_RAW, - "Fast memory test PASSED, however your memory can still be broken. Please run a memory test for several hours if possible.\n"); - } - } -#endif /* HAVE_PROC_MAPS */ -} - -/* Scans the (assumed) x86 code starting at addr, for a max of `len` - * bytes, searching for E8 (callq) opcodes, and dumping the symbols - * and the call offset if they appear to be valid. */ -void dumpX86Calls(void *addr, size_t len) { - size_t j; - unsigned char *p = addr; - Dl_info info; - /* Hash table to best-effort avoid printing the same symbol - * multiple times. */ - unsigned long ht[256] = {0}; - - if (len < 5) return; - for (j = 0; j < len-4; j++) { - if (p[j] != 0xE8) continue; /* Not an E8 CALL opcode. */ - unsigned long target = (unsigned long)addr+j+5; - uint32_t tmp; - memcpy(&tmp, p+j+1, sizeof(tmp)); - target += tmp; - if (dladdr((void*)target, &info) != 0 && info.dli_sname != NULL) { - if (ht[target&0xff] != target) { - printf("Function at 0x%lx is %s\n",target,info.dli_sname); - ht[target&0xff] = target; - } - j += 4; /* Skip the 32 bit immediate. */ - } - } -} - -void dumpCodeAroundEIP(void *eip) { - Dl_info info; - if (dladdr(eip, &info) != 0) { - serverLog(LL_WARNING|LL_RAW, - "\n------ DUMPING CODE AROUND EIP ------\n" - "Symbol: %s (base: %p)\n" - "Module: %s (base %p)\n" - "$ xxd -r -p /tmp/dump.hex /tmp/dump.bin\n" - "$ objdump --adjust-vma=%p -D -b binary -m i386:x86-64 /tmp/dump.bin\n" - "------\n", - info.dli_sname, info.dli_saddr, info.dli_fname, info.dli_fbase, - info.dli_saddr); - size_t len = (long)eip - (long)info.dli_saddr; - unsigned long sz = sysconf(_SC_PAGESIZE); - if (len < 1<<13) { /* we don't have functions over 8k (verified) */ - /* Find the address of the next page, which is our "safety" - * limit when dumping. Then try to dump just 128 bytes more - * than EIP if there is room, or stop sooner. */ - void *base = (void *)info.dli_saddr; - unsigned long next = ((unsigned long)eip + sz) & ~(sz-1); - unsigned long end = (unsigned long)eip + 128; - if (end > next) end = next; - len = end - (unsigned long)base; - serverLogHexDump(LL_WARNING, "dump of function", - base, len); - dumpX86Calls(base, len); - } - } -} - -void invalidFunctionWasCalled(void) {} - -typedef void (*invalidFunctionWasCalledType)(void); - -__attribute__ ((noinline)) -static void sigsegvHandler(int sig, siginfo_t *info, void *secret) { - UNUSED(secret); - UNUSED(info); - int print_full_crash_info = 1; - /* Check if it is safe to enter the signal handler. second thread crashing at the same time will deadlock. */ - if(pthread_mutex_lock(&signal_handler_lock) == EDEADLK) { - /* If this thread already owns the lock (meaning we crashed during handling a signal) switch - * to printing the minimal information about the crash. */ - serverLogRawFromHandler(LL_WARNING, - "Crashed running signal handler. Providing reduced version of recursive crash report."); - print_full_crash_info = 0; - } - - bugReportStart(); - serverLog(LL_WARNING, - "Redis %s crashed by signal: %d, si_code: %d", REDIS_VERSION, sig, info->si_code); - if (sig == SIGSEGV || sig == SIGBUS) { - serverLog(LL_WARNING, - "Accessing address: %p", (void*)info->si_addr); - } - if (info->si_code == SI_USER && info->si_pid != -1) { - serverLog(LL_WARNING, "Killed by PID: %ld, UID: %d", (long) info->si_pid, info->si_uid); - } - -#ifdef HAVE_BACKTRACE - ucontext_t *uc = (ucontext_t*) secret; - void *eip = getAndSetMcontextEip(uc, NULL); - if (eip != NULL) { - serverLog(LL_WARNING, - "Crashed running the instruction at: %p", eip); - } - - if (eip == info->si_addr) { - /* When eip matches the bad address, it's an indication that we crashed when calling a non-mapped - * function pointer. In that case the call to backtrace will crash trying to access that address and we - * won't get a crash report logged. Set it to a valid point to avoid that crash. */ - - /* This trick allow to avoid compiler warning */ - void *ptr; - invalidFunctionWasCalledType *ptr_ptr = (invalidFunctionWasCalledType*)&ptr; - *ptr_ptr = invalidFunctionWasCalled; - getAndSetMcontextEip(uc, ptr); - } - - /* When printing the reduced crash info, just print the current thread - * to avoid race conditions with the multi-threaded stack collector. */ - logStackTrace(eip, 1, !print_full_crash_info); - - if (eip == info->si_addr) { - /* Restore old eip */ - getAndSetMcontextEip(uc, eip); - } - - logRegisters(uc); -#endif - - if (print_full_crash_info) printCrashReport(); - -#ifdef HAVE_BACKTRACE - if (eip != NULL) - dumpCodeAroundEIP(eip); -#endif - - bugReportEnd(1, sig); -} - -void setupDebugSigHandlers(void) { - setupStacktracePipe(); - - setupSigSegvHandler(); - - struct sigaction act; - - sigemptyset(&act.sa_mask); - act.sa_flags = SA_SIGINFO; - act.sa_sigaction = sigalrmSignalHandler; - sigaction(SIGALRM, &act, NULL); -} - -void setupSigSegvHandler(void) { - /* Initialize the signal handler lock. - Attempting to initialize an already initialized mutex or mutexattr results in undefined behavior. */ - if (!signal_handler_lock_initialized) { - /* Set signal handler with error checking attribute. re-lock within the same thread will error. */ - pthread_mutexattr_init(&signal_handler_lock_attr); - pthread_mutexattr_settype(&signal_handler_lock_attr, PTHREAD_MUTEX_ERRORCHECK); - pthread_mutex_init(&signal_handler_lock, &signal_handler_lock_attr); - - pthread_mutexattr_init(&bug_report_start_attr); - /* Use recursive to avoid deadlock when a signal is raised during bugReportStart(). */ - pthread_mutexattr_settype(&bug_report_start_attr, PTHREAD_MUTEX_RECURSIVE); - pthread_mutex_init(&bug_report_start_mutex, &bug_report_start_attr); - - signal_handler_lock_initialized = 1; - } - - struct sigaction act; - - sigemptyset(&act.sa_mask); - /* SA_NODEFER to disables adding the signal to the signal mask of the - * calling process on entry to the signal handler unless it is included in the sa_mask field. */ - /* SA_SIGINFO flag is set to raise the function defined in sa_sigaction. - * Otherwise, sa_handler is used. */ - act.sa_flags = SA_NODEFER | SA_SIGINFO; - act.sa_sigaction = sigsegvHandler; - if(server.crashlog_enabled) { - sigaction(SIGSEGV, &act, NULL); - sigaction(SIGBUS, &act, NULL); - sigaction(SIGFPE, &act, NULL); - sigaction(SIGILL, &act, NULL); - sigaction(SIGABRT, &act, NULL); - } -} - -void removeSigSegvHandlers(void) { - struct sigaction act; - sigemptyset(&act.sa_mask); - act.sa_flags = SA_NODEFER | SA_RESETHAND; - act.sa_handler = SIG_DFL; - sigaction(SIGSEGV, &act, NULL); - sigaction(SIGBUS, &act, NULL); - sigaction(SIGFPE, &act, NULL); - sigaction(SIGILL, &act, NULL); - sigaction(SIGABRT, &act, NULL); -} - -void printCrashReport(void) { - atomicSet(server.crashing, 1); - - /* Log INFO and CLIENT LIST */ - logServerInfo(); - - /* Log the current client */ - logCurrentClient(server.current_client, "CURRENT"); - logCurrentClient(server.executing_client, "EXECUTING"); - - /* Log modules info. Something we wanna do last since we fear it may crash. */ - logModulesInfo(); - - /* Log debug config information, which are some values - * which may be useful for debugging crashes. */ - logConfigDebugInfo(); - - /* Run memory test in case the crash was triggered by memory corruption. */ - doFastMemoryTest(); -} - -void bugReportEnd(int killViaSignal, int sig) { - struct sigaction act; - - serverLogRawFromHandler(LL_WARNING|LL_RAW, -"\n=== REDIS BUG REPORT END. Make sure to include from START to END. ===\n\n" -" Please report the crash by opening an issue on github:\n\n" -" http://github.com/redis/redis/issues\n\n" -" If a Redis module was involved, please open in the module's repo instead.\n\n" -" Suspect RAM error? Use redis-server --test-memory to verify it.\n\n" -" Some other issues could be detected by redis-server --check-system\n" -); - - /* free(messages); Don't call free() with possibly corrupted memory. */ - if (server.daemonize && server.supervised == 0 && server.pidfile) unlink(server.pidfile); - - if (!killViaSignal) { - /* To avoid issues with valgrind, we may wanna exit rather than generate a signal */ - if (server.use_exit_on_panic) { - /* Using _exit to bypass false leak reports by gcc ASAN */ - fflush(stdout); - _exit(1); - } - abort(); - } - - /* Make sure we exit with the right signal at the end. So for instance - * the core will be dumped if enabled. */ - sigemptyset (&act.sa_mask); - act.sa_flags = 0; - act.sa_handler = SIG_DFL; - sigaction (sig, &act, NULL); - kill(getpid(),sig); -} - -/* ==================== Logging functions for debugging ===================== */ - -void serverLogHexDump(int level, char *descr, void *value, size_t len) { - char buf[65], *b; - unsigned char *v = value; - char charset[] = "0123456789abcdef"; - - serverLog(level,"%s (hexdump of %zu bytes):", descr, len); - b = buf; - while(len) { - b[0] = charset[(*v)>>4]; - b[1] = charset[(*v)&0xf]; - b[2] = '\0'; - b += 2; - len--; - v++; - if (b-buf == 64 || len == 0) { - serverLogRaw(level|LL_RAW,buf); - b = buf; - } - } - serverLogRaw(level|LL_RAW,"\n"); -} - -/* =========================== Software Watchdog ============================ */ -#include <sys/time.h> - -void sigalrmSignalHandler(int sig, siginfo_t *info, void *secret) { - /* Save and restore errno to avoid spoiling it's value as caught by - * WARNING: ThreadSanitizer: signal handler spoils errno */ - int save_errno = errno; -#ifdef HAVE_BACKTRACE - ucontext_t *uc = (ucontext_t*) secret; -#else - (void)secret; -#endif - UNUSED(sig); - - /* SIGALRM can be sent explicitly to the process calling kill() to get the stacktraces, - or every watchdog_period interval. In the last case, si_pid is not set */ - if(info->si_pid == 0) { - serverLogRawFromHandler(LL_WARNING,"\n--- WATCHDOG TIMER EXPIRED ---"); - } else { - serverLogRawFromHandler(LL_WARNING, "\nReceived SIGALRM"); - } -#ifdef HAVE_BACKTRACE - logStackTrace(getAndSetMcontextEip(uc, NULL), 1, 0); -#else - serverLogRawFromHandler(LL_WARNING,"Sorry: no support for backtrace()."); -#endif - serverLogRawFromHandler(LL_WARNING,"--------\n"); - errno = save_errno; -} - -/* Schedule a SIGALRM delivery after the specified period in milliseconds. - * If a timer is already scheduled, this function will re-schedule it to the - * specified time. If period is 0 the current timer is disabled. */ -void watchdogScheduleSignal(int period) { - struct itimerval it; - - /* Will stop the timer if period is 0. */ - it.it_value.tv_sec = period/1000; - it.it_value.tv_usec = (period%1000)*1000; - /* Don't automatically restart. */ - it.it_interval.tv_sec = 0; - it.it_interval.tv_usec = 0; - setitimer(ITIMER_REAL, &it, NULL); -} -void applyWatchdogPeriod(void) { - /* Disable watchdog when period is 0 */ - if (server.watchdog_period == 0) { - watchdogScheduleSignal(0); /* Stop the current timer. */ - } else { - /* If the configured period is smaller than twice the timer period, it is - * too short for the software watchdog to work reliably. Fix it now - * if needed. */ - int min_period = (1000/server.hz)*2; - if (server.watchdog_period < min_period) server.watchdog_period = min_period; - watchdogScheduleSignal(server.watchdog_period); /* Adjust the current timer. */ - } -} - -void debugPauseProcess(void) { - serverLog(LL_NOTICE, "Process is about to stop."); - raise(SIGSTOP); - serverLog(LL_NOTICE, "Process has been continued."); -} - -/* Positive input is sleep time in microseconds. Negative input is fractions - * of microseconds, i.e. -10 means 100 nanoseconds. */ -void debugDelay(int usec) { - /* Since even the shortest sleep results in context switch and system call, - * the way we achieve short sleeps is by statistically sleeping less often. */ - if (usec < 0) usec = (rand() % -usec) == 0 ? 1: 0; - if (usec) usleep(usec); -} - -#ifdef HAVE_BACKTRACE -#ifdef __linux__ - -/* =========================== Stacktrace Utils ============================ */ - - - -/** If it doesn't block and doesn't ignore, return 1 (the thread will handle the signal) - * If thread tid blocks or ignores sig_num returns 0 (thread is not ready to catch the signal). - * also returns 0 if something is wrong and prints a warning message to the log file **/ -static int is_thread_ready_to_signal(const char *proc_pid_task_path, const char *tid, int sig_num) { - /* Open the threads status file path /proc/<pid>/task/<tid>/status */ - char path_buff[PATH_MAX]; - snprintf_async_signal_safe(path_buff, PATH_MAX, "%s/%s/status", proc_pid_task_path, tid); - - int thread_status_file = open(path_buff, O_RDONLY); - char buff[PATH_MAX]; - if (thread_status_file == -1) { - serverLogFromHandler(LL_WARNING, "tid:%s: failed to open %s file", tid, path_buff); - return 0; - } - - int ret = 1; - size_t field_name_len = strlen("SigBlk:\t"); /* SigIgn has the same length */ - char *line = NULL; - size_t fields_count = 2; - while ((line = fgets_async_signal_safe(buff, PATH_MAX, thread_status_file)) && fields_count) { - /* iterate the file until we reach SigBlk or SigIgn field line */ - if (!strncmp(buff, "SigBlk:\t", field_name_len) || !strncmp(buff, "SigIgn:\t", field_name_len)) { - line = buff + field_name_len; - unsigned long sig_mask; - if (-1 == string2ul_base16_async_signal_safe(line, sizeof(buff), &sig_mask)) { - serverLogRawFromHandler(LL_WARNING, "Can't convert signal mask to an unsigned long due to an overflow"); - ret = 0; - break; - } - - /* The bit position in a signal mask aligns with the signal number. Since signal numbers start from 1 - we need to adjust the signal number by subtracting 1 to align it correctly with the zero-based indexing used */ - if (sig_mask & (1L << (sig_num - 1))) { /* if the signal is blocked/ignored return 0 */ - ret = 0; - break; - } - --fields_count; - } - } - - close(thread_status_file); - - /* if we reached EOF, it means we haven't found SigBlk or/and SigIgn, something is wrong */ - if (line == NULL) { - ret = 0; - serverLogFromHandler(LL_WARNING, "tid:%s: failed to find SigBlk or/and SigIgn field(s) in %s/%s/status file", tid, proc_pid_task_path, tid); - } - return ret; -} - -/** We are using syscall(SYS_getdents64) to read directories, which unlike opendir(), is considered - * async-signal-safe. This function wrapper getdents64() in glibc is supported as of glibc 2.30. - * To support earlier versions of glibc, we use syscall(SYS_getdents64), which requires defining - * linux_dirent64 ourselves. This structure is very old and stable: It will not change unless the kernel - * chooses to break compatibility with all existing binaries. Highly Unlikely. -*/ -struct linux_dirent64 { - unsigned long long d_ino; - long long d_off; - unsigned short d_reclen; /* Length of this linux_dirent */ - unsigned char d_type; - char d_name[256]; /* Filename (null-terminated) */ -}; - -/** Returns the number of the process's threads that can receive signal sig_num. - * Writes into tids the tids of these threads. - * If it fails, returns 0. -*/ -static size_t get_ready_to_signal_threads_tids(int sig_num, pid_t tids[TIDS_MAX_SIZE]) { - /* Open /proc/<pid>/task file. */ - char path_buff[PATH_MAX]; - snprintf_async_signal_safe(path_buff, PATH_MAX, "/proc/%d/task", getpid()); - - int dir; - if (-1 == (dir = open(path_buff, O_RDONLY | O_DIRECTORY))) return 0; - - size_t tids_count = 0; - pid_t calling_tid = syscall(SYS_gettid); - int current_thread_index = -1; - long nread; - char buff[PATH_MAX] = {0}; - - /* readdir() is not async-signal-safe (AS-safe). - Hence, we read the file using SYS_getdents64, which is considered AS-sync*/ - while ((nread = syscall(SYS_getdents64, dir, buff, PATH_MAX))) { - if (nread == -1) { - close(dir); - serverLogRawFromHandler(LL_WARNING, "get_ready_to_signal_threads_tids(): Failed to read the process's task directory"); - return 0; - } - /* Each thread is represented by a directory */ - for (long pos = 0; pos < nread;) { - struct linux_dirent64 *entry = (struct linux_dirent64 *)(buff + pos); - pos += entry->d_reclen; - /* Skip irrelevant directories. */ - if (strcmp(entry->d_name, ".") == 0 || strcmp(entry->d_name, "..") == 0) continue; - - /* the thread's directory name is equivalent to its tid. */ - long tid; - string2l(entry->d_name, strlen(entry->d_name), &tid); - - if(!is_thread_ready_to_signal(path_buff, entry->d_name, sig_num)) continue; - - if(tid == calling_tid) { - current_thread_index = tids_count; - } - - /* save the thread id */ - tids[tids_count++] = tid; - - /* Stop if we reached the maximum threads number. */ - if(tids_count == TIDS_MAX_SIZE) { - serverLogRawFromHandler(LL_WARNING, "get_ready_to_signal_threads_tids(): Reached the limit of the tids buffer."); - break; - } - } - - if(tids_count == TIDS_MAX_SIZE) break; - } - - /* Swap the last tid with the the current thread id */ - if(current_thread_index != -1) { - pid_t last_tid = tids[tids_count - 1]; - - tids[tids_count - 1] = calling_tid; - tids[current_thread_index] = last_tid; - } - - close(dir); - - return tids_count; -} -#endif /* __linux__ */ -#endif /* HAVE_BACKTRACE */ |