Functions — github.com/beanstalkd/beanstalkd

CodeHub MCPcopy Index your code

hub / github.com/beanstalkd/beanstalkd / functions

Functions349 in github.com/beanstalkd/beanstalkd

⨍ Functions 349◇ Types & classes 47

↓ 415 callersFunctionmustsend

↓ 259 callersFunctionckresp

↓ 202 callersFunctionckrespsub

↓ 70 callersFunctionmustdiallocal

↓ 30 callersFunctionjob_free

↓ 20 callersFunctionheapremove

↓ 19 callersFunctionnanoseconds

↓ 17 callersFunctionoptparse

↓ 16 callersFunctiondie

↓ 15 callersFunctionctdir

↓ 15 callersFunctionheapinsert

Heapinsert inserts x into heap h according to h->less. It returns 1 on success, otherwise 0.

↓ 14 callersFunctionwarnx

↓ 13 callersFunctionwarnpos

↓ 12 callersFunctionbench_put_delete_size

testserv.c:1990

↓ 12 callersFunctionjob_find

↓ 11 callersFunctionmake_tube

↓ 11 callersFunctionms_append

↓ 11 callersFunctionreply_line

reply_line prints *fmt into c->reply_buffer and calls reply() for the string and state.

↓ 10 callersFunctionms_init

↓ 9 callersFunctionbury_job

↓ 9 callersFunctionenqueue_job

enqueue_job inserts job j in the tube, returns 1 on success, otherwise 0. If update_store then it writes an entry to WAL. On success it processes the

↓ 8 callersFunctionepollq_apply

Propagate changes to event notification mechanism about expected operations in connections' sockets. Clear the epollq list.

↓ 8 callersFunctionfilermjob

↓ 8 callersFunctionfmtalloc

↓ 8 callersFunctionjob_list_remove

↓ 8 callersFunctionmin

↓ 8 callersFunctionread_u64

Read an integer from the given buffer and place it in num. * Parsed integer should fit into uint64. * Update end to point to the address after the l

↓ 7 callersFunctionflagusage

↓ 7 callersFunctionget_all_jobs_used

for unit tests */

↓ 7 callersFunctionreadfull

↓ 6 callersFunctioncheck_err

↓ 6 callersFunctionctstoptimer

↓ 6 callersFunctionfilewrite

↓ 6 callersFunctionjob_list_reset

job_list_reset detaches head from the list, marking the list starting in head pointing to itself.

↓ 6 callersFunctionms_remove

↓ 6 callersFunctionread_u32

Indentical to read_u64() but instead reads into uint32.

↓ 6 callersFunctionreply_job

reply_job tells the connection c which job to send, and replies with this line: <msg> <job_id> <job_size>.

↓ 6 callersFunctionsockwant

↓ 5 callersFunctionctresettimer

↓ 5 callersFunctionis_valid_tube

↓ 5 callersFunctionjob_copy

↓ 5 callersFunctionjob_list_is_empty

↓ 5 callersFunctionjob_pri_less

↓ 5 callersFunctionmake_job_with_id

↓ 5 callersFunctionms_clear

↓ 5 callersFunctionms_take

↓ 5 callersFunctionremove_waiting_conn

remove_waiting_conn unsets CONN_TYPE_WAITING for the connection, removes it from the waiting_conns set of every tube it's watching. Noop if connection

↓ 5 callersFunctiontube_find_or_make

↓ 5 callersFunctionusage

↓ 5 callersFunctionwalresvupdate

Returns the number of bytes reserved or 0 on error.

↓ 4 callersFunctionallocate_job

↓ 4 callersFunctionfiledecref

↓ 4 callersFunctionfileincref

↓ 4 callersFunctionfill_extra_data

Copy up to body_size trailing bytes into the job, then the rest into the cmd * buffer. If c->in_job exists, this assumes that c->in_job->body is empt

↓ 4 callersFunctionjob_list_insert

↓ 4 callersFunctionkill_srvpid

Kill the srvpid (child process) with SIGTERM to give it a chance to write gcov data to the filesystem before ct kills it with SIGKILL. Do nothing in c

↓ 4 callersFunctionread_duration

Read a delay value in seconds from the given buffer and place it in duration in nanoseconds. The interface and behavior are analogous to read_u3

↓ 4 callersFunctionset

↓ 4 callersFunctiontube_find

↓ 4 callersFunctionwalwrite

Walwrite writes j to the log w (if w is enabled). On failure, walwrite disables w and returns 0; on success, it returns 1. Unlke walresv*, walwrite sh

↓ 3 callersFunction_get_job_hash_index

↓ 3 callersFunctionburied_job_p

↓ 3 callersFunctionconnclose

↓ 3 callersFunctionconnsoonestjob

Return the reserved job with the earliest deadline, or NULL if there's no reserved job.

↓ 3 callersFunctiondo_stats

↓ 3 callersFunctionepollq_add

epollq_add schedules connection c in the s->conns heap, adds c to the epollq list to change expected operation in event notifications. rw='w' means to

↓ 3 callersFunctionexist

↓ 3 callersFunctionfailed

↓ 3 callersFunctionfileaddjob

↓ 3 callersFunctionless

↓ 3 callersFunctionmake_server_socket

↓ 3 callersFunctionmoveresv

↓ 3 callersFunctionms_contains

↓ 3 callersFunctionms_delete

↓ 3 callersFunctionneedfree

↓ 3 callersFunctionnstime

↓ 3 callersFunctionparse_size_t

↓ 3 callersFunctionprocess_queue

process_queue performs reservation for every jobs that is awaited for.

↓ 3 callersFunctionprot_init

↓ 3 callersFunctionremove_buried_job

remove_buried_job returns non-NULL value if job j was in the buried state. It excludes the job from the buried list and updates counters.

↓ 3 callersFunctionremove_ready_job

remove_ready_job returns non-NULL value if job j was in the ready state. It removes the job from the tube ready heap and updates counters.

↓ 3 callersFunctionremove_reserved_job

↓ 3 callersFunctionreply

↓ 3 callersFunctionreserve

Returns the number of bytes successfully reserved: either 0 or n.

↓ 3 callersFunctionscan_line_end

Scan the given string for the sequence "\r\n" and return the line length. * Always returns at least 2 if a match is found. Returns 0 if no match. */

↓ 3 callersFunctionsrv_acquire_wal

srv_acquire_wal tries to lock the wal dir specified by s->wal and replay entries from it to initialize the s state with jobs. On errors it exits from

↓ 3 callersFunctionsrvserve

↓ 3 callersFunctiontmpfd

↓ 3 callersFunctionwalmaint

↓ 2 callersFunctionconn_reserve_job

↓ 2 callersFunctionconn_set_soonestjob

conn_set_soonestjob updates c->soonest_job with j if j should be handled sooner than c->soonest_job.

↓ 2 callersFunctionconn_want_command

↓ 2 callersFunctionconndeadlinesoon

Return true if c has a reserved job with less than one second until its deadline.

↓ 2 callersFunctionconnsched

Remove c from the c->srv heap and reschedule it using the value returned by conntickat if there is an outstanding timeout in the c.

↓ 2 callersFunctionconnsetworker

↓ 2 callersFunctioncopyfd

↓ 2 callersFunctiondo_list_tubes

↓ 2 callersFunctionfileadd

Adds f to the linked list in w, updating w->tail and w->head as necessary.

↓ 2 callersFunctionfileinit

↓ 2 callersFunctionfilesize

next →1–100 of 349, ranked by callers