translation_unit
comment "/*\n * Copyright (c) 2009-Present, Redis Ltd.\n * All rights r"...
preproc_include
#include "#include"
string_literal
" "\""
string_content "server.h"
" "\""
preproc_include
#include "#include"
string_literal
" "\""
string_content "atomicvar.h"
" "\""
preproc_include
#include "#include"
string_literal
" "\""
string_content "cluster.h"
" "\""
preproc_include
#include "#include"
string_literal
" "\""
string_content "script.h"
" "\""
preproc_include
#include "#include"
string_literal
" "\""
string_content "fpconv_dtoa.h"
" "\""
preproc_include
#include "#include"
string_literal
" "\""
string_content "fmtargs.h"
" "\""
preproc_include
#include "#include"
system_lib_string "<sys/socket.h>"
preproc_include
#include "#include"
system_lib_string "<sys/uio.h>"
preproc_include
#include "#include"
system_lib_string "<math.h>"
preproc_include
#include "#include"
system_lib_string "<ctype.h>"
declaration (+23 nodes collapsed)
declaration
storage_class_specifier
static "static"
primitive_type "void"
function_declarator
identifier "pauseClientsByClient"
parameter_list
( "("
parameter_declaration
type_identifier "mstime_t"
identifier "end"
, ","
parameter_declaration
primitive_type "int"
identifier "isPauseClientAll"
) ")"
; ";"
declaration
primitive_type "char"
pointer_declarator
* "*"
function_declarator
identifier "getClientSockname"
parameter_list
( "("
parameter_declaration
type_identifier "client"
pointer_declarator
* "*"
identifier "c"
) ")"
; ";"
declaration
storage_class_specifier
static "static"
storage_class_specifier
inline "inline"
primitive_type "int"
function_declarator
identifier "clientTypeIsSlave"
parameter_list
( "("
parameter_declaration
type_identifier "client"
pointer_declarator
* "*"
identifier "c"
) ")"
; ";"
declaration
storage_class_specifier
static "static"
storage_class_specifier
inline "inline"
primitive_type "int"
function_declarator
identifier "_clientHasPendingRepliesSlave"
parameter_list
( "("
parameter_declaration
type_identifier "client"
pointer_declarator
* "*"
identifier "c"
) ")"
; ";"
declaration
storage_class_specifier
static "static"
storage_class_specifier
inline "inline"
primitive_type "int"
function_declarator
identifier "_clientHasPendingRepliesNonSlave"
parameter_list
( "("
parameter_declaration
type_identifier "client"
pointer_declarator
* "*"
identifier "c"
) ")"
; ";"
declaration (+23 nodes collapsed)
declaration (+23 nodes collapsed)
declaration
primitive_type "int"
init_declarator
identifier "ProcessingEventsWhileBlocked"
= "="
number_literal "0"
; ";"
comment "/* See processEventsWhileBlocked(). */"
declaration
storage_class_specifier
__thread "__thread"
type_identifier "sds"
init_declarator
identifier "thread_reusable_qb"
= "="
null
NULL "NULL"
; ";"
declaration
storage_class_specifier
__thread "__thread"
primitive_type "int"
init_declarator
identifier "thread_reusable_qb_used"
= "="
number_literal "0"
; ";"
comment "/* Avoid multiple clients using reusable query\n "...
comment "/* Return the size consumed from the allocator, for the spec"...
function_definition (+36 nodes collapsed)
comment "/* Return the size consumed from the allocator, for the spec"...
function_definition (+36 nodes collapsed)
comment "/* Return the amount of memory used by the sds string at obj"...
function_definition (+91 nodes collapsed)
comment "/* Return the length of a string object.\n * This does NOT in"...
function_definition (+86 nodes collapsed)
comment "/* Client.reply list dup and free methods. */"
function_definition (+78 nodes collapsed)
function_definition (+23 nodes collapsed)
comment "/* This function links the client to the global linked list "...
function_definition (+97 nodes collapsed)
comment "/* Initialize client authentication state.\n */"
function_definition (+65 nodes collapsed)
function_definition (+61 nodes collapsed)
function_definition
type_identifier "client"
pointer_declarator
* "*"
function_declarator
identifier "createClient"
parameter_list
( "("
parameter_declaration
type_identifier "connection"
pointer_declarator
* "*"
identifier "conn"
) ")"
compound_statement
{ "{"
declaration
type_identifier "client"
init_declarator
pointer_declarator
* "*"
identifier "c"
= "="
call_expression
identifier "zmalloc"
argument_list
( "("
sizeof_expression
sizeof "sizeof"
parenthesized_expression
( "("
identifier "client"
) ")"
) ")"
; ";"
comment "/* passing NULL as conn it is possible to create a non conne"...
if_statement (+59 nodes collapsed)
expression_statement (+21 nodes collapsed)
expression_statement
call_expression
identifier "selectDb"
argument_list
( "("
identifier "c"
, ","
number_literal "0"
) ")"
; ";"
declaration
primitive_type "uint64_t"
identifier "client_id"
; ";"
expression_statement
call_expression
identifier "atomicGetIncr"
argument_list
( "("
field_expression
identifier "server"
. "."
field_identifier "next_client_id"
, ","
identifier "client_id"
, ","
number_literal "1"
) ")"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "id"
= "="
identifier "client_id"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "tid"
= "="
identifier "IOTHREAD_MAIN_THREAD_ID"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "running_tid"
= "="
identifier "IOTHREAD_MAIN_THREAD_ID"
; ";"
if_statement (+21 nodes collapsed)
preproc_ifdef (+37 nodes collapsed)
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "conn"
= "="
identifier "conn"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "name"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "lib_name"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "lib_ver"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "bufpos"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "buf_peak"
= "="
field_expression
identifier "c"
-> "->"
field_identifier "buf_usable_size"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "buf_peak_last_reset_time"
= "="
field_expression
identifier "server"
. "."
field_identifier "unixtime"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "ref_repl_buf_node"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "ref_block_pos"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "qb_pos"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "querybuf"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "querybuf_peak"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "reqtype"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "argc"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "argv"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "argv_len"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "argv_len_sum"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "original_argc"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "original_argv"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "deferred_objects"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "deferred_objects_num"
= "="
number_literal "0"
; ";"
expression_statement (+28 nodes collapsed)
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "cur_script"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "multibulklen"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "bulklen"
= "="
number_literal "-1"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "sentlen"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "flags"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "io_flags"
= "="
binary_expression
identifier "CLIENT_IO_READ_ENABLED"
| "|"
identifier "CLIENT_IO_WRITE_ENABLED"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "read_error"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "slot"
= "="
number_literal "-1"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "cluster_compatibility_check_slot"
= "="
number_literal "-2"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "ctime"
= "="
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "lastinteraction"
= "="
field_expression
identifier "server"
. "."
field_identifier "unixtime"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "duration"
= "="
number_literal "0"
; ";"
expression_statement
call_expression
identifier "clientSetDefaultAuth"
argument_list
( "("
identifier "c"
) ")"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "replstate"
= "="
identifier "REPL_STATE_NONE"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "repl_start_cmd_stream_on_ack"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "reploff"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "read_reploff"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "repl_applied"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "repl_ack_off"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "repl_ack_time"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "repl_aof_off"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "repl_last_partial_write"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "slave_listening_port"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "slave_addr"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "slave_capa"
= "="
identifier "SLAVE_CAPA_NONE"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "slave_req"
= "="
identifier "SLAVE_REQ_NONE"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "main_ch_client_id"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "reply"
= "="
call_expression
identifier "listCreate"
argument_list
( "("
) ")"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "deferred_reply_errors"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "reply_bytes"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "obuf_soft_limit_reached_time"
= "="
number_literal "0"
; ";"
expression_statement
call_expression
identifier "listSetFreeMethod"
argument_list
( "("
field_expression
identifier "c"
-> "->"
field_identifier "reply"
, ","
identifier "freeClientReplyValue"
) ")"
; ";"
expression_statement
call_expression
identifier "listSetDupMethod"
argument_list
( "("
field_expression
identifier "c"
-> "->"
field_identifier "reply"
, ","
identifier "dupClientReplyValue"
) ")"
; ";"
expression_statement
call_expression
identifier "initClientBlockingState"
argument_list
( "("
identifier "c"
) ")"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "woff"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "watched_keys"
= "="
call_expression
identifier "listCreate"
argument_list
( "("
) ")"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "pubsub_channels"
= "="
call_expression
identifier "dictCreate"
argument_list
( "("
pointer_expression
& "&"
identifier "objectKeyPointerValueDictType"
) ")"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "pubsub_patterns"
= "="
call_expression
identifier "dictCreate"
argument_list
( "("
pointer_expression
& "&"
identifier "objectKeyPointerValueDictType"
) ")"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "pubsubshard_channels"
= "="
call_expression
identifier "dictCreate"
argument_list
( "("
pointer_expression
& "&"
identifier "objectKeyPointerValueDictType"
) ")"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "peerid"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "sockname"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "client_list_node"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "io_thread_client_list_node"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "postponed_list_node"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "client_tracking_redirection"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "client_tracking_prefixes"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "last_memory_usage"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "last_memory_type"
= "="
identifier "CLIENT_TYPE_NORMAL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "module_blocked_client"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "module_auth_ctx"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "auth_callback"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "auth_callback_privdata"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "auth_module"
= "="
null
NULL "NULL"
; ";"
expression_statement
call_expression
identifier "listInitNode"
argument_list
( "("
pointer_expression
& "&"
field_expression
identifier "c"
-> "->"
field_identifier "clients_pending_write_node"
, ","
identifier "c"
) ")"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "mem_usage_bucket"
= "="
null
NULL "NULL"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "mem_usage_bucket_node"
= "="
null
NULL "NULL"
; ";"
if_statement
if "if"
parenthesized_expression
( "("
identifier "conn"
) ")"
expression_statement
call_expression
identifier "linkClient"
argument_list
( "("
identifier "c"
) ")"
; ";"
expression_statement
call_expression
identifier "initClientMultiState"
argument_list
( "("
identifier "c"
) ")"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "net_input_bytes"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "net_output_bytes"
= "="
number_literal "0"
; ";"
expression_statement
assignment_expression
field_expression
identifier "c"
-> "->"
field_identifier "commands_processed"
= "="
number_literal "0"
; ";"
return_statement
return "return"
identifier "c"
; ";"
} "}"
function_definition (+85 nodes collapsed)
comment "/* This function puts the client in the queue of clients tha"...
function_definition (+105 nodes collapsed)
function_definition (+209 nodes collapsed)
comment "/* This function is called every time we are going to transm"...
function_definition (+24 nodes collapsed)
comment "/* ---------------------------------------------------------"...
comment "/* Adds the reply to the reply linked list.\n * Note: some ed"...
function_definition (+278 nodes collapsed)
comment "/* The subscribe / unsubscribe command family has a push as "...
function_definition (+84 nodes collapsed)
function_definition (+340 nodes collapsed)
comment "/* ---------------------------------------------------------"...
comment "/* Add the object 'obj' string representation to the client "...
function_definition (+159 nodes collapsed)
comment "/* Add the SDS 's' string to the client output buffer, as a "...
function_definition (+73 nodes collapsed)
comment "/* This low level function just adds whatever protocol you s"...
function_definition (+56 nodes collapsed)
comment "/* Low level function called by the addReplyError...() funct"...
function_definition (+92 nodes collapsed)
comment "/* Do some actions after an error reply was sent (Log if nee"...
function_definition (+654 nodes collapsed)
comment "/* The 'err' object is expected to start with -ERRORCODE and"...
function_definition (+60 nodes collapsed)
comment "/* Sends either a reply or an error reply by checking the fi"...
function_definition (+99 nodes collapsed)
comment "/* See addReplyErrorLength for expectations from the input s"...
function_definition (+59 nodes collapsed)
comment "/* Add error reply to the given client.\n * Supported flags:\n"...
function_definition (+67 nodes collapsed)
comment "/* See addReplyErrorLength for expectations from the input s"...
comment "/* As a side effect the SDS string is freed. */"
function_definition (+31 nodes collapsed)
comment "/* See addReplyErrorLength for expectations from the input s"...
comment "/* As a side effect the SDS string is freed. */"
function_definition (+55 nodes collapsed)
comment "/* Internal function used by addReplyErrorFormat, addReplyEr"...
function_definition (+160 nodes collapsed)
function_definition (+66 nodes collapsed)
comment "/* See addReplyErrorLength for expectations from the formatt"...
function_definition (+62 nodes collapsed)
function_definition (+36 nodes collapsed)
function_definition (+36 nodes collapsed)
function_definition (+70 nodes collapsed)
function_definition (+40 nodes collapsed)
function_definition (+93 nodes collapsed)
comment "/* Sometimes we are forced to create a new reply node, and w"...
function_definition (+193 nodes collapsed)
comment "/* Adds an empty object to the reply list that will contain "...
function_definition (+151 nodes collapsed)
function_definition (+470 nodes collapsed)
comment "/* Populate the length object and try gluing it to the next "...
function_definition (+269 nodes collapsed)
function_definition (+43 nodes collapsed)
function_definition (+82 nodes collapsed)
function_definition (+64 nodes collapsed)
function_definition (+57 nodes collapsed)
function_definition (+57 nodes collapsed)
comment "/* Add a double as a bulk reply */"
function_definition (+397 nodes collapsed)
function_definition (+102 nodes collapsed)
comment "/* Add a long double as a bulk reply, but uses a human reada"...
function_definition (+149 nodes collapsed)
function_definition (+188 nodes collapsed)
function_definition (+45 nodes collapsed)
function_definition (+45 nodes collapsed)
comment "/* Add a long long as integer reply or bulk len / multi bulk"...
function_definition (+333 nodes collapsed)
function_definition (+104 nodes collapsed)
function_definition (+62 nodes collapsed)
function_definition (+64 nodes collapsed)
function_definition (+58 nodes collapsed)
function_definition (+74 nodes collapsed)
function_definition (+56 nodes collapsed)
function_definition (+49 nodes collapsed)
function_definition (+68 nodes collapsed)
function_definition (+69 nodes collapsed)
function_definition (+87 nodes collapsed)
comment "/* A null array is a concept that no longer exists in RESP3."...
function_definition (+69 nodes collapsed)
comment "/* Create the length prefix of a bulk reply, example: $2234 "...
function_definition (+60 nodes collapsed)
comment "/* Add a Redis Object as a bulk reply */"
function_definition (+236 nodes collapsed)
comment "/* Add a C buffer as bulk reply */"
function_definition (+82 nodes collapsed)
comment "/* Add sds to reply (takes ownership of sds and frees it) */"
function_definition (+108 nodes collapsed)
comment "/* Set sds to a deferred reply (for symmetry with addReplyBu"...
function_definition (+101 nodes collapsed)
comment "/* Add a C null term string as bulk reply */"
function_definition (+66 nodes collapsed)
comment "/* Add a long long as a bulk reply */"
function_definition (+60 nodes collapsed)
comment "/* Reply with a verbatim type having the specified extension"...
function_definition (+233 nodes collapsed)
comment "/* This function is similar to the addReplyHelp function but"...
function_definition (+242 nodes collapsed)
comment "/* Add an array of C strings as status replies with a headin"...
function_definition (+38 nodes collapsed)
comment "/* Add a suggestive error reply.\n * This function is typical"...
function_definition (+94 nodes collapsed)
comment "/* Append 'src' client output buffers into 'dst' client outp"...
function_definition (+260 nodes collapsed)
comment "/* Append the listed errors to the server error statistics. "...
function_definition (+94 nodes collapsed)
comment "/* Logically copy 'src' replica client buffers info to 'dst'"...
function_definition (+115 nodes collapsed)
function_definition (+37 nodes collapsed)
function_definition (+129 nodes collapsed)
comment "/* Return true if the specified client has pending reply buf"...
function_definition (+52 nodes collapsed)
function_definition (+307 nodes collapsed)
function_definition (+500 nodes collapsed)
comment "/* Attempt to defer freeing the object to the IO thread. We "...
function_definition (+114 nodes collapsed)
comment "/* Free the objects in the deferred_objects array. If free_a"...
function_definition (+98 nodes collapsed)
function_definition (+97 nodes collapsed)
function_definition (+196 nodes collapsed)
function_definition (+25 nodes collapsed)
comment "/* Close all the slaves connections. This is useful in chain"...
function_definition (+77 nodes collapsed)
comment "/* Check if there is any other slave waiting dumping RDB fin"...
function_definition (+103 nodes collapsed)
comment "/* Remove the specified client from global lists where the c"...
function_definition (+504 nodes collapsed)
comment "/* Clear the client state to resemble a newly connected clie"...
function_definition (+303 nodes collapsed)
function_definition (+71 nodes collapsed)
comment "/* Resets the reusable query buffer used by the given client"...
function_definition (+122 nodes collapsed)
function_definition (+1134 nodes collapsed)
comment "/* Schedule a client to free it at a safe time in the before"...
function_definition (+195 nodes collapsed)
comment "/* Log errors for invalid use and free the client in async w"...
function_definition (+127 nodes collapsed)
comment "/* Perform processing of the client before moving on to proc"...
function_definition (+75 nodes collapsed)
comment "/* Free the clients marked as CLOSE_ASAP, return the number "...
function_definition (+140 nodes collapsed)
comment "/* Return a client by ID, or NULL if the client ID is not in"...
function_definition (+75 nodes collapsed)
comment "/* This function should be called from _writeToClient when t"...
function_definition (+638 nodes collapsed)
comment "/* This function does actual writing output buffers for non "...
function_definition (+240 nodes collapsed)
comment "/* This function does actual writing output buffers for slav"...
function_definition (+281 nodes collapsed)
comment "/* Write data in output buffers to client. Return C_OK if th"...
function_definition (+515 nodes collapsed)
comment "/* Write event handler. Just send data to the client. */"
function_definition (+39 nodes collapsed)
comment "/* This function is called just before entering the event lo"...
function_definition (+242 nodes collapsed)
function_definition (+299 nodes collapsed)
comment "/* resetClient prepare the client to process the next comman"...
function_definition (+25 nodes collapsed)
comment "/* This function is used when we want to re-enter the event "...
function_definition (+73 nodes collapsed)
comment "/* This will undo the client protection done by protectClien"...
function_definition (+97 nodes collapsed)
comment "/* Like processMultibulkBuffer(), but for the inline protoco"...
function_definition (+529 nodes collapsed)
comment "/* Helper function. Record protocol error details in server "...
preproc_def
#define "#define"
identifier "PROTO_DUMP_LEN"
preproc_arg "128"
function_definition (+342 nodes collapsed)
comment "/* Process the query buffer for client 'c', setting up the c"...
function_definition (+1440 nodes collapsed)
comment "/* Perform necessary tasks after a command was executed:\n *\n"...
function_definition (+188 nodes collapsed)
comment "/* This function calls processCommand(), but also performs a"...
function_definition (+125 nodes collapsed)
comment "/* This function will execute any fully parsed commands pend"...
function_definition (+103 nodes collapsed)
function_definition (+567 nodes collapsed)
comment "/* This function is called every time, in the client structu"...
function_definition (+669 nodes collapsed)
function_definition (+1014 nodes collapsed)
comment "/* A Redis \"Address String\" is a colon separated ip:port pai"...
function_definition (+88 nodes collapsed)
comment "/* This function returns the client peer id, by creating and"...
function_definition (+87 nodes collapsed)
comment "/* This function returns the client bound socket name, by cr"...
function_definition (+87 nodes collapsed)
function_definition (+37 nodes collapsed)
comment "/* Concatenate a string representing the state of a client i"...
function_definition (+1533 nodes collapsed)
function_definition (+247 nodes collapsed)
comment "/* Check validity of an attribute that's gonna be shown in C"...
function_definition (+71 nodes collapsed)
comment "/* Returns C_OK if the name is valid. Returns C_ERR & sets `"...
function_definition (+122 nodes collapsed)
comment "/* Returns C_OK if the name has been set or C_ERR if the nam"...
function_definition (+169 nodes collapsed)
comment "/* This function implements CLIENT SETNAME, including replyi"...
function_definition (+77 nodes collapsed)
comment "/* Set client or connection related info */"
function_definition (+266 nodes collapsed)
comment "/* Reset the client state to resemble a newly connected clie"...
function_definition (+107 nodes collapsed)
comment "/* Disconnect the current client */"
function_definition (+37 nodes collapsed)
function_definition (+5571 nodes collapsed)
comment "/* HELLO [<protocol-version> [AUTH <user> <password>] [SETNA"...
function_definition (+867 nodes collapsed)
comment "/* This callback is bound to POST and \"Host:\" command names."...
function_definition (+151 nodes collapsed)
comment "/* Keep track of the original command arguments so that we c"...
function_definition (+132 nodes collapsed)
comment "/* Redact a given argument to prevent it from being shown\n *"...
function_definition (+84 nodes collapsed)
comment "/* Rewrite the command vector of the client. All the new obj"...
function_definition (+149 nodes collapsed)
comment "/* Completely replace the client command vector with the pro"...
function_definition (+176 nodes collapsed)
comment "/* Rewrite a single item in the command vector.\n * The new v"...
function_definition (+365 nodes collapsed)
comment "/* This function returns the number of bytes that Redis is\n "...
function_definition (+220 nodes collapsed)
comment "/* Returns the total client's memory usage.\n * Optionally, i"...
function_definition (+189 nodes collapsed)
comment "/* Get the class of a client, used in order to enforce limit"...
function_definition (+85 nodes collapsed)
function_definition (+62 nodes collapsed)
function_definition (+139 nodes collapsed)
function_definition (+76 nodes collapsed)
comment "/* The function checks if the client reached output buffer s"...
function_definition (+328 nodes collapsed)
comment "/* Asynchronously close a client if soft or hard limit is re"...
function_definition (+213 nodes collapsed)
comment "/* Helper function used by performEvictions() in order to fl"...
function_definition (+171 nodes collapsed)
comment "/* Compute current paused actions and its end time, aggregat"...
function_definition (+172 nodes collapsed)
comment "/* Unblock all paused clients (ones that where blocked by BL"...
function_definition (+87 nodes collapsed)
comment "/* Set pause-client end-time and restricted action. If alrea"...
function_definition (+95 nodes collapsed)
comment "/* Pause actions up to the specified unixtime (in ms) for a "...
function_definition (+103 nodes collapsed)
comment "/* Unpause actions and queue them for reprocessing. */"
function_definition (+52 nodes collapsed)
comment "/* Returns bitmask of paused actions */"
function_definition (+26 nodes collapsed)
comment "/* Returns bitmask of paused actions */"
function_definition (+54 nodes collapsed)
comment "/* This function is called by Redis in order to process a fe"...
function_definition (+177 nodes collapsed)
comment "/* Returns the actual client eviction limit based on current"...
function_definition (+159 nodes collapsed)
function_definition (+394 nodes collapsed)