Propagate the specified command (in the context of the specified database id) * to AOF and Slaves. * * flags are an xor between: * + PROPAGATE_NON

Get next element in iterator. * * Note: You must NOT insert into the list while iterating over it. * You *may* delete from the list while iterating

Free a whole radix tree. */

Append characters at the current key string of the iterator 'it'. This * is a low level function used to implement the iterator, not callable by * t

Cached cardinality, little endian. */

Set an expire to the specified key. If the expire is set in the context * of an user calling a command 'c' is the client, otherwise 'c' is set * to

* Sets *dst + *src non-atomically. This is safe, since everything is * synchronized by the ctl mutex. */

Defrag helper for sds strings * * returns NULL in case the allocation wasn't moved. * when it returns a non-null value, the old pointer was already

* Non-atomically sets *dst += src. *dst needs external synchronization. * This lets us avoid the cost of a fetch_add when its unnecessary (note that

Likewise: with ctl mutex synchronization, reading is simple. */

Return true if the specified client has pending reply buffers to write to * the socket. */

Register a read handler, to be called when the connection is readable. * If NULL, the existing handler is removed. */

* Sets *dst + *src non-atomically. This is safe, since everything is * synchronized by the ctl mutex. */

Get host ip and port from command arguments. If only one argument has * been provided it must be in the form of 'ip:port', elsewhere * the first arg

Given a path to a file, return the last time it was accessed (in seconds) */

Like the above function but automatically convert the result into * a long. On error (missing field) LONG_MIN is returned. */

Get last error code. */

Send ldb.logs to the debugging client as a multi-bulk reply * consisting of simple strings. Log entries which include newlines have them * replaced

Returns a quicklist iterator 'iter'. After the initialization every * call to quicklistNext() will return the next element of the quicklist. */

Gets the random number generator.

Send a notify message to systemd. Returns sd_notify return code which is * a positive number on success. */

Return the pointer to a string representing the replica ip:listening_port * pair. Mostly useful for logging, since we want to log a replica using its

Remove the part of the string from left and from right composed just of * contiguous characters found in 'cset', that is a null terminted C string.

Convert the specified stream entry ID as a 128 bit big endian number, so * that the IDs can be sorted lexicographically. */

Encode the length of the previous entry and write it to "p". Return the * number of bytes needed to encode this length if "p" is NULL. */

Move to next entry based on the values in eptr and sptr. Both are set to * NULL when there is no next entry. */

Helper function to make the disconnect happen and clean up. */

* Allocates n*sizeof(T) bytes of high bandwidth memory using hbw_malloc(). * Throws std::bad_alloc when cannot allocate memory. */

Enable the FD_CLOEXEC on the given fd to avoid fd leaks. * This function should be invoked for fd's on specific places * where fork + execve syste

Like the _u64 variant, needs an externally synchronized *dst. */

Helper for connection implementations to call handlers: * 1. Increment refs to protect the connection. * 2. Execute the handler (if set). * 3. Decr

Retrieves info about the cluster using argument 'node' as the starting * point. All nodes will be loaded inside the cluster_manager.nodes list. * Wa

Return a random entry from the hash table. Useful to * implement randomized algorithms */

Add data to the replication backlog. * This function also increments the global replication offset stored at * g_pserver->master_repl_offset, becaus