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

Function queueChangePausedState

src/queue.c:674–685  ·  view source on GitHub ↗

Changes the paused state of the queue and handles serving again blocked * clients if needed. * * 'flag' must be QUEUE_FLAG_PAUSED_IN or QUEUE_FLAG_PAUSED_OUT * 'set' is true if we have to set this state or 0 if we have * to clear this state. */

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 2

receivePauseQueueFunction · 0.85
pauseCommandFunction · 0.85

Calls 1

signalQueueAsReadyFunction · 0.85

Tested by

no test coverage detected