sdsalloc() = sdsavail() + sdslen() */

Like sdscpylen() but 't' must be a null-termined string so that the length * of the string is obtained with strlen(). */

Given a key name, this function sends an invalidation message in the * proper channel (depending on RESP version: PubSub or Push message) and * to t

Abort a failover in progress: * * This function can only be called before the promoted slave acknowledged * the slave -> master switch. Otherwise t

Generalise handling create instance error. Use SRI_MASTER, SRI_SLAVE or * SRI_SENTINEL as a role value. */

Convert the set to specified encoding. The resulting dict (when converting * to a hash table) is presized to hold the number of elements in the origi

4 iterations of each thread, all with same set of operations (malloc, then calloc, realloc and align), but different operation probability 120, 521, 1

Mark that we are loading in the global state and setup the fields * needed to provide loading stats. * 'filename' is optional and used for rdb-check

Called when the user switches from "appendonly yes" to "appendonly no" * at runtime using the CONFIG command. */

Return bytes remaining in the string buffer * Ensure there is space for a NULL terminator. */

Create a NACK entry setting the delivery count to 1 and the delivery * time to the current time. The NACK consumer will be set to the one * specifie

Get the field and value of the current item we are iterating. This should * be called immediately after streamIteratorGetID(), and for each field *

Trim the stream 's' according to args->trim_strategy, and return the * number of elements removed from the stream. The 'approx' option, if non-zero,

Convert a string into a double. Returns 1 if the string could be parsed * into a (non-overflowing) double, 0 otherwise. The value will be set to * t

Gets the number of tests that should run.

Attempt to configure/reconfigure TLS. This operation is atomic and will * leave the SSL_CTX unchanged if fails. */

Remove the specified client from global lists where the client could * be referenced, not including the Pub/Sub channels. * This is used by freeClie

This will undo the client protection done by protectClient() */

Unwatch all the keys watched by this client. To clean the EXEC dirty * flag is up to the caller. */

Acquires at least one, and (greedily) at most max

Write data in output buffers to client. Return C_OK if the client * is still valid after the call, C_ERR if it was freed because of some * error. I

Read integer encoded as 'encoding' from 'p' */

Return the total number of bytes used by the entry pointed to by 'p'. */

Check if string pointed to by 'entry' can be encoded as an integer. * Stores the integer value in 'v' and its encoding in 'encoding'. */

Find pointer to the entry equal to the specified entry. Skip 'skip' entries * between every comparison. Returns NULL when the field could not be foun

Merge ziplists 'first' and 'second' by appending 'second' to 'first'. * * NOTE: The larger ziplist is reallocated to contain the new merged ziplist.

Helper method to store a string into from val or lval into dest */

Delete the element 'ele' from the sorted set, returning 1 if the element * existed and was deleted, 0 otherwise (the element was not there). */

Find the first node that is contained in the specified range. * Returns NULL when no element is contained in the range. */

Finds an element by its rank. The rank argument needs to be 1-based. */

Populate the lex rangespec according to the objects min and max. * * Return C_OK on success. On error C_ERR is returned. * When OK is returned the

Try allocating memory, and return NULL if failed. */

Try allocating memory, and return NULL if failed. * '*usable' is set to the usable size if non NULL. */

Find pointer to the first element contained in the specified lex range. * Returns NULL when no element is contained in the range. */

Check whether the command is ready to be exceuted by ACLCheckCommandPerm. * If check passes, then check whether pub/sub channels of the command is *

Check if the pub/sub channels of the command, that's ready to be executed in * the client 'c', can be executed by this client according to the ACLs c

Copy the user ACL rules from the source user 'src' to the destination * user 'dst' so that at the end of the process they'll have exactly the * same

This is similar to ACLDescribeUserCommandRules(), however instead of * describing just the user command rules, everything is described: user * flags

Given an SDS string, returns the SHA256 hex representation as a * new SDS string. */

Get a command from the original command table, that is not affected * by the command renaming operations: we base all the ACL work from that * table

Flush the array of allowed subcommands for the specified user * and command ID. */

Adds a test part result to the list.

Starts capturing stderr.

Clears the object.

A module may be triggered synchronously in a non-module context. In this scenario we don't lock again as the server thread acquisition is sufficient.

Returns the name of the environment variable corresponding to the given flag. For example, FlagToEnvVar("foo") will return "GTEST_FOO" in the open-so

Formats the given time in milliseconds as seconds.