hub / github.com/antirez/disque / clusterReplicateJob

Function clusterReplicateJob

src/cluster.c:1830–1902 · view source on GitHub ↗

Broadcast a REPLJOB message to 'repl' nodes, and populates the list of jobs * that may have the job. * * If there are already nodes that received the message, additional * 'repl' nodes will be added to the list (if possible), and the message * broadcasted again to all the nodes that may already have the message, * plus the new ones. * * However for nodes for which we already have the GOTJO

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 2

clientsCronHandleDelayedJobReplicationFunction · 0.85

addjobCommandFunction · 0.85

Calls 14

clusterShuffleReachableNodesFunction · 0.85

serializeJobFunction · 0.85

clusterBuildMessageHdrFunction · 0.85

zmallocFunction · 0.85

clusterSendMessageFunction · 0.85

zfreeFunction · 0.85

dictAddFunction · 0.70

sdsemptyFunction · 0.70

sdslenFunction · 0.70

sdsfreeFunction · 0.70

dictGetIteratorFunction · 0.70

dictNextFunction · 0.70

Tested by

no test coverage detected