MCPcopy Create free account
hub / github.com/antirez/disque / queueFetchJob

Function queueFetchJob

src/queue.c:217–226  ·  view source on GitHub ↗

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 * specified queue, NULL is returned. * * The returned job is, among the jobs available, the one with lower * 'ctime'. * * If 'qlen' is not NULL, the residual length of the queue is stored * at *qlen. */

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 4

queueNameFetchJobFunction · 0.85
receiveNeedJobsFunction · 0.85
getjobCommandFunction · 0.85

Calls 2

skiplistLengthFunction · 0.85
skiplistPopHeadFunction · 0.85

Tested by

no test coverage detected