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

Function enqueueJob

src/queue.c:148–193  ·  view source on GitHub ↗

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 * flat set, C_ERR is returned, otherwise C_OK is returned and the operation * succeeds. * * The nack argument is set to 1 if the enqueue is the result of a client * negative acknowledge. */

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 7

receiveYourJobsFunction · 0.85
enqueueGenericCommandFunction · 0.85
clusterProcessPacketFunction · 0.85
processJobFunction · 0.85
loadjobCommandFunction · 0.85
jobReplicationAchievedFunction · 0.85
addjobCommandFunction · 0.85

Calls 8

serverLogFunction · 0.85
randomTimeErrorFunction · 0.85
clusterBroadcastQueuedFunction · 0.85
updateJobAwakeTimeFunction · 0.85
lookupQueueFunction · 0.85
createQueueFunction · 0.85
skiplistInsertFunction · 0.85
signalQueueAsReadyFunction · 0.85

Tested by

no test coverage detected