MCPcopy Create free account

hub / github.com/antirez/disque / functions

Functions1,943 in github.com/antirez/disque

↓ 12 callersFunctionthd_create
deps/jemalloc/test/src/thd.c:4
↓ 12 callersFunctionthd_join
deps/jemalloc/test/src/thd.c:13
↓ 11 callersFunctionget_huge_size
deps/jemalloc/test/integration/xallocx.c:118
↓ 11 callersFunctionredisReaderGetReply
deps/hiredis/hiredis.c:617
↓ 11 callersFunctionsdsempty
Create an empty (zero length) sds string. Even in this case the string * always has an implicit null term. */
deps/hiredis/sds.c:139
↓ 10 callersFunctionbase_alloc
* base_alloc() guarantees demand-zeroed memory, in order to make multi-page * sparse data structures such as radix tree nodes efficient with respect
deps/jemalloc/src/base.c:78
↓ 10 callersFunctionckh_search
deps/jemalloc/src/ckh.c:514
↓ 10 callersFunctiondictDelete
src/dict.c:446
↓ 10 callersFunctiondictFetchValue
src/dict.c:510
↓ 10 callersFunctiondictGetIterator
src/dict.c:555
↓ 10 callersFunctionfini_gen_rand
deps/jemalloc/test/src/SFMT.c:714
↓ 10 callersFunctiongen_rand32
* This function generates and returns 32-bit pseudorandom number. * init_gen_rand or init_by_array must be called before this function. * @return 32
deps/jemalloc/test/src/SFMT.c:447
↓ 10 callersFunctionredisGetReply
deps/hiredis/hiredis.c:1210
↓ 10 callersFunctionsdscatrepr
Append to the sds string "s" an escaped string representation where * all the non-printable characters (tested with isprint()) are turned into * esc
src/sds.c:858
↓ 10 callersFunctionsdscatsds
Append the specified sds 't' to the existing sds 's'. * * After the call, the modified sds string is no longer valid and all the * references must
src/sds.c:399
↓ 10 callersFunctionsdsnewlen
Create a new sds string with the content specified by the 'init' pointer * and 'initlen'. * If NULL is used for 'init' the string is initialized wit
deps/hiredis/sds.c:81
↓ 10 callersFunctionzrealloc
src/zmalloc.c:132
↓ 9 callersFunctiona0dalloc
deps/jemalloc/src/jemalloc.c:329
↓ 9 callersFunctionaddReplyString
src/networking.c:319
↓ 9 callersFunctionarena_mapbits_large_get
deps/jemalloc/include/jemalloc/internal/arena.h:752
↓ 9 callersFunctionconnect
deps/hiredis/test.c:86
↓ 9 callersFunctiondictGenHashFunction
MurmurHash2, by Austin Appleby * Note - This code makes a few assumptions about how your machine behaves - * 1. We can read a 4-byte value from any
src/dict.c:103
↓ 9 callersFunctionextent_node_init
deps/jemalloc/include/jemalloc/internal/extent.h:195
↓ 9 callersFunctionextent_node_zeroed_get
deps/jemalloc/include/jemalloc/internal/extent.h:117
↓ 9 callersFunctionfreeClient
src/networking.c:663
↓ 9 callersFunctiongetLongLongFromObject
src/object.c:481
↓ 9 callersFunctionprof_bt_count
deps/jemalloc/src/prof.c:907
↓ 9 callersFunctionredisContextCloseFd
deps/hiredis/net.c:57
↓ 9 callersFunctionredisFormatCommand
Format a command according to the Redis protocol. This function * takes a format similar to printf: * * %s represents a C null terminated string yo
deps/hiredis/hiredis.c:925
↓ 9 callersFunctionredisReaderCreate
deps/hiredis/hiredis.c:556
↓ 9 callersFunctionredisReaderFree
deps/hiredis/hiredis.c:577
↓ 9 callersFunctionrewriteConfigRewriteLine
Rewrite the specified configuration option with the new "line". * It progressively uses lines of the file that were already used for the same * conf
src/config.c:985
↓ 9 callersFunctionsdsavail
deps/hiredis/sds.h:103
↓ 9 callersFunctionsdssetlen
src/sds.h:129
↓ 9 callersFunctionsdssetlen
deps/hiredis/sds.h:129
↓ 9 callersFunctionupdateJobAwakeTime
Ask the system to update the time the job will be called again as an * argument of awakeJob() in order to handle delayed tasks for this job. * If 'a
src/job.c:384
↓ 9 callersFunctionustime
Return the UNIX time in microseconds */
src/server.c:263
↓ 9 callersFunctionyesnotoi
src/config.c:123
↓ 8 callersFunctionSHA1Update
src/sha1.c:131
↓ 8 callersFunctionaddReplyBulk
Add a Disque Object as a bulk reply */
src/networking.c:490
↓ 8 callersFunctionaddReplyCommandFlag
Helper function for addReplyCommand() to output flags. */
src/server.c:1812
↓ 8 callersFunctionarena_mapbits_unallocated_set
deps/jemalloc/include/jemalloc/internal/arena.h:794
↓ 8 callersFunctionarena_miscelm_to_rpages
deps/jemalloc/include/jemalloc/internal/arena.h:605
↓ 8 callersFunctionclusterBuildMessageHdr
Build the message header */
src/cluster.c:1640
↓ 8 callersFunctiondictRelease
Clear & Release the hash table */
src/dict.c:482
↓ 8 callersFunctionextent_node_size_set
deps/jemalloc/include/jemalloc/internal/extent.h:160
↓ 8 callersFunctiongetLongInfoField
Like the above function but automatically convert the result into * a long. On error (missing field) LONG_MIN is returned. */
src/disque-cli.c:1648
↓ 8 callersFunctionhuge_node_get
deps/jemalloc/src/huge.c:6
↓ 8 callersFunctionmstime
src/disque-cli.c:120
↓ 8 callersFunctionredisAsyncCommand
deps/hiredis/async.c:644
↓ 8 callersFunctionredisContextInit
deps/hiredis/hiredis.c:989
↓ 8 callersFunctionrewriteConfigStringOption
Rewrite a string option. */
src/config.c:1059
↓ 8 callersFunctionrewriteConfigYesNoOption
Rewrite a yes/no option. */
src/config.c:1050
↓ 8 callersFunctionrtree_set
deps/jemalloc/include/jemalloc/internal/rtree.h:262
↓ 8 callersFunctionsdsHdrSize
src/sds.c:41
↓ 8 callersFunctionsdsHdrSize
deps/hiredis/sds.c:41
↓ 8 callersFunctionsdsMakeRoomFor
Enlarge the free space at the end of the sds string so that the caller * is sure that after calling this function can overwrite up to addlen * bytes
deps/hiredis/sds.c:194
↓ 8 callersFunctionsdsrange
Turn the string into a smaller (or equal) string containing only the * substring specified by the 'start' and 'end' indexes. * * start and end can
deps/hiredis/sds.c:714
↓ 8 callersFunctiontsd_nominal
deps/jemalloc/include/jemalloc/internal/tsd.h:631
↓ 8 callersFunctionusec
deps/hiredis/test.c:40
↓ 8 callersFunctionvalidate_fill
deps/jemalloc/test/integration/rallocx.c:46
↓ 7 callersFunction__redisAsyncDisconnect
Helper function to make the disconnect happen and clean up. */
deps/hiredis/async.c:320
↓ 7 callersFunctiona0malloc
deps/jemalloc/src/jemalloc.c:322
↓ 7 callersFunctionarena_mapbitsp_get
deps/jemalloc/include/jemalloc/internal/arena.h:638
↓ 7 callersFunctionbitmap_full
deps/jemalloc/include/jemalloc/internal/bitmap.h:113
↓ 7 callersFunctionbitmap_get
deps/jemalloc/include/jemalloc/internal/bitmap.h:122
↓ 7 callersFunctionckh_remove
deps/jemalloc/src/ckh.c:482
↓ 7 callersFunctionclusterLookupNode
Node lookup by name */
src/cluster.c:690
↓ 7 callersFunctiondo_prof_reset
deps/jemalloc/test/unit/prof_reset.c:38
↓ 7 callersFunctionenqueueJob
Queue the job and change its state accordingly. If the job is already * in QUEUED state, or the job has retry set to 0 and the JOB_FLAG_DELIVERED *
src/queue.c:148
↓ 7 callersFunctiongen_rand64
* This function generates and returns 64-bit pseudorandom number. * init_gen_rand or init_by_array must be called before this function. * The functi
deps/jemalloc/test/src/SFMT.c:482
↓ 7 callersFunctionget_lg_prof_sample
deps/jemalloc/test/unit/prof_reset.c:27
↓ 7 callersFunctionmalloc_init
deps/jemalloc/src/jemalloc.c:281
↓ 7 callersFunctionprof_active_get_unlocked
deps/jemalloc/include/jemalloc/internal/prof.h:350
↓ 7 callersFunctionprof_idump
deps/jemalloc/src/prof.c:1587
↓ 7 callersFunctionrandomTimeError
Return a random time error between -(milliseconds/2) and +(milliseconds/2). * This is useful in order to desynchronize multiple nodes competing for t
src/server.c:281
↓ 7 callersFunctionsetProtocolError
Helper function. Trims query buffer to make the function that processes * multi bulk requests idempotent. */
src/networking.c:914
↓ 7 callersFunctionskiplistPopTail
If the skip list is empty, NULL is returned, otherwise the element * at tail is removed and its pointed object returned. */
src/skiplist.c:255
↓ 7 callersFunctionunblockClient
Unblock a client calling the right function depending on the kind * of operation the client is blocking for. */
src/blocked.c:136
↓ 7 callersFunctionzmalloc_size
src/zmalloc.c:165
↓ 6 callersFunctiona0get
deps/jemalloc/src/jemalloc.c:297
↓ 6 callersFunctionaddDeferredMultiBulkLength
Adds an empty object to the reply list that will contain the multi bulk * length, which is not known when this function is called. */
src/networking.c:372
↓ 6 callersFunctionaddReplyBulkLongLong
Add a long long as a bulk reply */
src/networking.c:521
↓ 6 callersFunctionarena_mapbitsp_write
deps/jemalloc/include/jemalloc/internal/arena.h:770
↓ 6 callersFunctionarena_prof_promoted
deps/jemalloc/src/arena.c:2384
↓ 6 callersFunctionatomic_add_uint32
deps/jemalloc/include/jemalloc/internal/atomic.h:295
↓ 6 callersFunctionatomic_add_uint64
deps/jemalloc/include/jemalloc/internal/atomic.h:71
↓ 6 callersFunctionbuferror
* glibc provides a non-standard strerror_r() when _GNU_SOURCE is defined, so * provide a wrapper. */
deps/jemalloc/src/util.c:79
↓ 6 callersFunctionchunk_hooks_get
deps/jemalloc/src/chunk.c:65
↓ 6 callersFunctionckh_new
deps/jemalloc/src/ckh.c:349
↓ 6 callersFunctionclusterAddNode
Add a node to the nodes hash table */
src/cluster.c:660
↓ 6 callersFunctionclusterSendMessage
Put stuff into the send buffer. * * It is guaranteed that this function will never have as a side effect * the link to be invalidated, so it is saf
src/cluster.c:1604
↓ 6 callersFunctioncrc64
src/crc64.c:173
↓ 6 callersFunctioncreateQueue
Crete a new queue, register it in the queue hash tables. * On success the pointer to the new queue is returned. If a queue with the * same name alre
src/queue.c:61
↓ 6 callersFunctiondequeueJob
Remove a job from the queue. Returns C_OK if the job was there and * is now removed (updating the job state back to ACTIVE), otherwise * C_ERR is re
src/queue.c:198
↓ 6 callersFunctiondictGetRandomKey
Return a random entry from the hash table. Useful to * implement randomized algorithms */
src/dict.c:623
↓ 6 callersFunctiondisqueGitSHA1
src/release.c:40
↓ 6 callersFunctiondo_recursion
deps/jemalloc/test/src/SFMT.c:244
↓ 6 callersFunctiondouble_eq_rel
deps/jemalloc/test/unit/math.c:12
↓ 6 callersFunctiongetDecodedObject
Get a decoded version of an encoded object (returned as a new object). * If the object is already raw-encoded just increment the ref count. */
src/object.c:306
← previousnext →101–200 of 1,943, ranked by callers