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

Function workingCommand

src/queue.c:1093–1123  ·  view source on GitHub ↗

WORKING job-id * * If the job is queued, remove it from queue and change state to active. * Postpone the job requeue time in the future so that we'll wait the retry * time before enqueueing again. * Broadcast a WORKING message to all the other nodes that have a copy according * to our local info. * * Return how much time the worker likely have before the next requeue event * or an error:

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 9

validateJobIDsFunction · 0.85
lookupJobFunction · 0.85
addReplySdsFunction · 0.85
dequeueJobFunction · 0.85
updateJobRequeueTimeFunction · 0.85
randomTimeErrorFunction · 0.85
clusterBroadcastWorkingFunction · 0.85
addReplyLongLongFunction · 0.85
sdsnewFunction · 0.70

Tested by

no test coverage detected