Asynchronously close a client if soft or hard limit is reached on the * output buffer size. The caller can check if the client will be closed * chec

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

Send a DELJOB message to all the nodes that may have a copy. */

Remove a node from the cluster: * 1) Remove all the failure reports sent by this node. * 2) Free the node using freeClusterNode() that will remove i

Helper function to send all the messages that have just a type, * a Job ID, and an optional 'aux' additional value. */

Send a PING or PONG packet to the specified node, making sure to add enough * gossip informations. */

Update server.reachable_nodes and server.reachable_nodes_count with * a list of reachable nodes (not in PFAIL state), excluding this node. * Note th

Get enum value from name. If there is no match INT_MIN is returned. */

Create a new cluster node, with the specified flags. * If "nodename" is NULL this is considered a first handshake and a random * node name is assign

Create a reply object */

* This function generates pseudorandom 32-bit integers in the * specified array[] by one call. The number of pseudorandom integers * is specified by

* This function generates pseudorandom 64-bit integers in the * specified array[] by one call. The number of pseudorandom integers * is specified by

Generate the Disque "Run ID", a SHA1-sized random number that identifies a * given execution of Disque, so that if you are talking with an instance

* This function initializes the internal state array, * with an array of 32-bit integers used as the seeds * @param init_key the array of 32-bit int

Move cursor to the end of the line. */

This is the API call to add a new entry in the linenoise history. * It uses a fixed array of char pointers that are shifted (memmoved) * when the hi

Convert a string representing an amount of memory into the number of * bytes, so for instance memtoll("1Gi") will return 1073741824 that is * (1024*

This function is called every time we are going to transmit new data * to the client. The behavior is the following: * * If the client should recei

tdata->lock must be held. */

Changes the paused state of the queue and handles serving again blocked * clients if needed. * * 'flag' must be QUEUE_FLAG_PAUSED_IN or QUEUE_FLAG_

Fetch a job from the specified queue if any, updating the job state * as it gets fetched back to ACTIVE. If there are no jobs pending in the * speci

Tries to do a clean disconnect from Redis, meaning it stops new commands * from being issued, but tries to flush the output buffer and execute * cal

This function should be called when the socket is readable. * It processes all replies that can be read and executes their callbacks. */

Format a command according to the Redis protocol. This function takes the * number of arguments, an array with arguments and an array with their * l

This is how rewriting of the append only file in background works: * * 1) The user calls BGREWRITEAOF * 2) Disque calls this function, that forks()

Add the specified option to the set of processed options. * This is useful as only unused lines of processed options will be blanked * in the config

Write binary-safe string in the format: "$<count>\r\n<payload>\r\n". */

This function is similar to sdscatprintf, but much faster as it does * not rely on sprintf() family functions implemented by the libc that * are oft

Append to the sds string 's' a string obtained using printf-alike format * specifier. * * After the call, the modified sds string is no longer vali

Serialize the job pointed by 'j' appending the serialized version of * the job into the passed SDS string 'jobs'. * * The serialization may be perf

Insert the specified object, return NULL if the element already * exists. */

Set the specified unix time at which a job will be queued again * in the local node. */

Emit a LOADJOB command into the AOF. which is used explicitly to load * serialized jobs form disk: LOADJOB <serialize-job-string>. */

Helper function to free the context. */

Add sds to reply (takes ownership of sds and frees it) */

Send a job as a return value of a command. This is about jobs but inside * queue.c since this is the format used in order to return a job from a * q

Return a simple string reply with the Job ID. */

* Helper function to invoke port_associate for the given fd and mask. */

This function free the old AOF rewrite buffer if needed, and initialize * a fresh new one. It tests for server.aof_rewrite_buf_blocks equal to NULL

Return the current size of the AOF rewrite buffer. */