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

Function clusterProcessPacket

src/cluster.c:1051–1500  ·  view source on GitHub ↗

When this function is called, there is a packet to process starting * at node->rcvbuf. Releasing the buffer is up to the caller, so this * function should just handle the higher level stuff of processing the * packet, modifying the cluster state if needed. * * The function returns 1 if the link is still valid after the packet * was processed, otherwise 0 if the link was freed since the packe

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 1

clusterReadHandlerFunction · 0.85

Calls 15

serverLogFunction · 0.85
clusterLookupNodeFunction · 0.85
anetSockNameFunction · 0.85
clusterDoBeforeSleepFunction · 0.85
createClusterNodeFunction · 0.85
nodeIp2StringFunction · 0.85
clusterAddNodeFunction · 0.85
clusterSendPingFunction · 0.85
clusterDelNodeFunction · 0.85
clusterRenameNodeFunction · 0.85

Tested by

no test coverage detected