MCPcopy Index your code

hub / github.com/beanstalkd/beanstalkd / functions

Functions349 in github.com/beanstalkd/beanstalkd

⨍ Functions 349◇ Types & classes 47
↓ 2 callersFunctionfilewclose
file.c:554
↓ 2 callersFunctionhas_reserved_job
conn.c:108
↓ 2 callersFunctionis_job_reserved_by_conn
prot.c:728
↓ 2 callersFunctionkick_buried_job
prot.c:584
↓ 2 callersFunctionkick_delayed_job
prot.c:620
↓ 2 callersFunctionmakenextfile
walg.c:210
↓ 2 callersFunctionmaybe_enqueue_incoming_job
prot.c:1240
↓ 2 callersFunctionreadline
testserv.c:264
↓ 2 callersFunctionrehash
job.c:40
↓ 2 callersFunctionremove_delayed_job
remove_delayed_job returns non-NULL value if job j was in the delayed state. It removes the job from the tube delayed heap.
prot.c:702
↓ 2 callersFunctionremove_this_reserved_job
j can be NULL */
prot.c:1256
↓ 2 callersFunctionrmtree
Removes path and all of its children. Writes errors to stderr and keeps going. If path doesn't exist, rmtree returns silently. */
ct/ct.c:260
↓ 2 callersFunctionrunbenchn
ct/ct.c:298
↓ 2 callersFunctionset_nonblocking
net.c:18
↓ 2 callersFunctionset_sig_handler
testserv.c:143
↓ 2 callersFunctionsiftdown
heap.c:33
↓ 2 callersFunctionstore_job
job.c:25
↓ 2 callersFunctionswap
heap.c:15
↓ 2 callersFunctiontube_dref
tube.c:44
↓ 2 callersFunctionusenext
returns 1 on success, 0 on error.
walg.c:74
↓ 2 callersFunctionvwarnx
util.c:19
↓ 2 callersFunctionwaittest
ct/ct.c:160
↓ 2 callersFunctionwarn_systemd_ignored_option
util.c:89
↓ 1 callersFunctionbalance
Ensures: 1. w->cur->resv >= n. 2. w->cur->resv is congruent to n (mod z). 3. x->resv is congruent to 0 (mod z) for each future file x. (where z is the
walg.c:305
↓ 1 callersFunctionbalancerest
Ensures: 1. b->resv is congruent to n (mod z). 2. x->resv is congruent to 0 (mod z) for each future file x. Assumes (and preserves) that b->resv >= n.
walg.c:268
↓ 1 callersFunctionconn_process_io
prot.c:1923
↓ 1 callersFunctionconn_ready
conn.c:207
↓ 1 callersFunctionconn_timeout
There are three reasons this function may be called. We need to check for * all of them. * * 1. A reserved job has run out of time. * 2. A waiti
prot.c:1860
↓ 1 callersFunctionconnsetproducer
conn.c:68
↓ 1 callersFunctionconntickat
Returns positive nanoseconds when c should tick, 0 otherwise.
conn.c:116
↓ 1 callersFunctioncount_cur_conns
conn.c:84
↓ 1 callersFunctioncount_cur_producers
conn.c:96
↓ 1 callersFunctioncount_cur_workers
conn.c:102
↓ 1 callersFunctioncount_tot_conns
conn.c:90
↓ 1 callersFunctionctfailnow
ct/ct.c:76
↓ 1 callersFunctionctsetbytes
ct/ct.c:119
↓ 1 callersFunctionctstarttimer
ct/ct.c:99
↓ 1 callersFunctiondispatch_cmd
prot.c:1286
↓ 1 callersFunctionenqueue_incoming_job
prot.c:865
↓ 1 callersFunctionenqueue_reserved_jobs
prot.c:570
↓ 1 callersFunctionenqueue_waiting_conn
enqueue_waiting_conn sets CONN_TYPE_WAITING for the connection, adds it to the waiting_conns set of every tube it's watching.
prot.c:416
↓ 1 callersFunctionenter_drain_mode
prot.c:1902
↓ 1 callersFunctionepollq_rmconn
epollq_rmconn removes connection c from the epollq.
prot.c:297
↓ 1 callersFunctionfileread
Fileread reads jobs from f->path into list. It returns 0 on success, or 1 if any errors occurred.
file.c:127
↓ 1 callersFunctionfilewopen
Opens f for writing, writes a header, and initializes f->free and f->resv. Sets f->iswopen if successful.
file.c:459
↓ 1 callersFunctionfilewrjobfull
file.c:539
↓ 1 callersFunctionfilewrjobshort
file.c:521
↓ 1 callersFunctionget_delayed_job_ct
prot.c:607
↓ 1 callersFunctiongrow
ms.c:15
↓ 1 callersFunctionh_accept
prot.c:2200
↓ 1 callersFunctionh_conn
prot.c:2107
↓ 1 callersFunctionjob_hash_free
job.c:141
↓ 1 callersFunctionjob_state
job.c:220
↓ 1 callersFunctionkick_buried_jobs
return the number of jobs successfully kicked */
prot.c:656
↓ 1 callersFunctionkick_delayed_jobs
return the number of jobs successfully kicked */
prot.c:667
↓ 1 callersFunctionkick_jobs
prot.c:677
↓ 1 callersFunctionmake_and_insert_tube
tube.c:65
↓ 1 callersFunctionmake_conn
conn.c:34
↓ 1 callersFunctionmake_inet_socket
net.c:36
↓ 1 callersFunctionmake_unix_socket
net.c:150
↓ 1 callersFunctionmax
ct/ct.c:409
↓ 1 callersFunctionmoveone
walg.c:120
↓ 1 callersFunctionmustdialunix
testserv.c:113
↓ 1 callersFunctionmuststart
testserv.c:55
↓ 1 callersFunctionnext_awaited_job
next_awaited_job iterates through all the tubes with awaiting connections, returns the next ready job with the smallest priority. If jobs has the same
prot.c:433
↓ 1 callersFunctionprot_replay
For each job in list, inserts the job into the appropriate data structures and adds it to the log. Returns 1 on success, 0 on failure.
prot.c:2305
↓ 1 callersFunctionprottick
prottick returns nanoseconds till the next work.
prot.c:2141
↓ 1 callersFunctionratio
walg.c:91
↓ 1 callersFunctionrawfalloc
rawfalloc allocates disk space of len bytes. It expects fd's offset to be 0; may also reset fd's offset to 0. Returns 0 on success, and a positive err
file.c:56
↓ 1 callersFunctionread_tube_name
Read a tube name from the given buffer moving the buffer to the name start */
prot.c:1081
↓ 1 callersFunctionreadrec
Readrec reads a record from f->fd into linked list l. If an error occurs, it sets *err to 1. Readrec returns the number of records read, either 1 or 0
file.c:156
↓ 1 callersFunctionreadrec5
Readrec5 is like readrec, but it reads a record in "version 5" of the log format.
file.c:287
↓ 1 callersFunctionreadtokens
ct/ct.c:523
↓ 1 callersFunctionreport
ct/ct.c:482
↓ 1 callersFunctionrounddown10
rounddown10 rounds a number down to the nearest power of 10. */
ct/ct.c:364
↓ 1 callersFunctionroundup
roundup rounds n up to a number of the form [1eX, 2eX, 5eX]. */
ct/ct.c:383
↓ 1 callersFunctionrunallbench
ct/ct.c:473
↓ 1 callersFunctionrunalltest
ct/ct.c:222
↓ 1 callersFunctionrunbench
ct/ct.c:419
↓ 1 callersFunctionset_sig_handlers
main.c:45
↓ 1 callersFunctionsiftup
heap.c:49
↓ 1 callersFunctionsockinit
sunos.c:13
↓ 1 callersFunctionsocknext
sunos.c:57
↓ 1 callersFunctionsoonest_delayed_job
soonest_delayed_job returns the delayed job with the smallest deadline_at among all tubes.
prot.c:484
↓ 1 callersFunctionstart
ct/ct.c:188
↓ 1 callersFunctionsu
main.c:12
↓ 1 callersFunctiontouch_job
prot.c:734
↓ 1 callersFunctiontube_free
tube.c:34
↓ 1 callersFunctiontube_iref
tube.c:58
↓ 1 callersFunctionuptime
prot.c:923
↓ 1 callersFunctionwait_for_job
prot.c:1098
↓ 1 callersFunctionwalcompact
walg.c:148
↓ 1 callersFunctionwaldirlock
Returns the number of locks acquired: either 0 or 1.
walg.c:397
↓ 1 callersFunctionwalgc
walg.c:53
↓ 1 callersFunctionwalinit
walg.c:477
↓ 1 callersFunctionwalread
walg.c:436
↓ 1 callersFunctionwalresvmigrate
Returns the number of bytes reserved or 0 on error.
walg.c:104
↓ 1 callersFunctionwalresvput
Returns the number of bytes reserved or 0 on error.
walg.c:366
↓ 1 callersFunctionwalscandir
Reads w->dir for files matching binlog.NNN, sets w->next to the next unused number, and returns the minimum number. If no files are found, sets w->nex
walg.c:22
↓ 1 callersFunctionwalsync
walg.c:159
← previousnext →101–200 of 349, ranked by callers