4cae66f5e8
If there are nodes in the cluster that do not support shard-id, they will gossip shard-id. From the perspective of nodes that support shard-id, their shard-id is meaningless (since shard-id is randomly generated when we create a node.) Nodes that support shard-id will save the shard-id information in nodes.conf. If the node is restarted according to nodes.conf, the server will report a corrupted cluster config file error. Because auxShardIdSetter will reject configurations with inconsistent master-replica shard-ids. A cluster-wide consensus for the node's shard_id is not necessary. The key is maintaining consistency of the shard_id on each individual 7.2 node. As the cluster progressively upgrades to version 7.2, we can expect the shard_ids across all nodes to naturally converge and align. In this PR, when processing the gossip, if sender is a replica and does not support shard-id, set the shard_id to the shard_id of its master.
119 lines
5.2 KiB
C
119 lines
5.2 KiB
C
#ifndef __CLUSTER_H
|
|
#define __CLUSTER_H
|
|
|
|
/*-----------------------------------------------------------------------------
|
|
* Redis cluster exported API.
|
|
*----------------------------------------------------------------------------*/
|
|
|
|
#define CLUSTER_SLOT_MASK_BITS 14 /* Number of bits used for slot id. */
|
|
#define CLUSTER_SLOTS (1<<CLUSTER_SLOT_MASK_BITS) /* Total number of slots in cluster mode, which is 16384. */
|
|
#define CLUSTER_SLOT_MASK ((unsigned long long)(CLUSTER_SLOTS - 1)) /* Bit mask for slot id stored in LSB. */
|
|
#define CLUSTER_OK 0 /* Everything looks ok */
|
|
#define CLUSTER_FAIL 1 /* The cluster can't work */
|
|
#define CLUSTER_NAMELEN 40 /* sha1 hex length */
|
|
|
|
/* Redirection errors returned by getNodeByQuery(). */
|
|
#define CLUSTER_REDIR_NONE 0 /* Node can serve the request. */
|
|
#define CLUSTER_REDIR_CROSS_SLOT 1 /* -CROSSSLOT request. */
|
|
#define CLUSTER_REDIR_UNSTABLE 2 /* -TRYAGAIN redirection required */
|
|
#define CLUSTER_REDIR_ASK 3 /* -ASK redirection required. */
|
|
#define CLUSTER_REDIR_MOVED 4 /* -MOVED redirection required. */
|
|
#define CLUSTER_REDIR_DOWN_STATE 5 /* -CLUSTERDOWN, global state. */
|
|
#define CLUSTER_REDIR_DOWN_UNBOUND 6 /* -CLUSTERDOWN, unbound slot. */
|
|
#define CLUSTER_REDIR_DOWN_RO_STATE 7 /* -CLUSTERDOWN, allow reads. */
|
|
|
|
typedef struct _clusterNode clusterNode;
|
|
struct clusterState;
|
|
|
|
/* Flags that a module can set in order to prevent certain Redis Cluster
|
|
* features to be enabled. Useful when implementing a different distributed
|
|
* system on top of Redis Cluster message bus, using modules. */
|
|
#define CLUSTER_MODULE_FLAG_NONE 0
|
|
#define CLUSTER_MODULE_FLAG_NO_FAILOVER (1<<1)
|
|
#define CLUSTER_MODULE_FLAG_NO_REDIRECTION (1<<2)
|
|
|
|
/* ---------------------- API exported outside cluster.c -------------------- */
|
|
/* functions requiring mechanism specific implementations */
|
|
void clusterInit(void);
|
|
void clusterInitLast(void);
|
|
void clusterCron(void);
|
|
void clusterBeforeSleep(void);
|
|
int verifyClusterConfigWithData(void);
|
|
|
|
int clusterSendModuleMessageToTarget(const char *target, uint64_t module_id, uint8_t type, const char *payload, uint32_t len);
|
|
|
|
void clusterUpdateMyselfFlags(void);
|
|
void clusterUpdateMyselfIp(void);
|
|
void clusterUpdateMyselfHostname(void);
|
|
void clusterUpdateMyselfAnnouncedPorts(void);
|
|
void clusterUpdateMyselfHumanNodename(void);
|
|
|
|
void clusterPropagatePublish(robj *channel, robj *message, int sharded);
|
|
|
|
unsigned long getClusterConnectionsCount(void);
|
|
int isClusterHealthy(void);
|
|
|
|
sds clusterGenNodesDescription(client *c, int filter, int tls_primary);
|
|
sds genClusterInfoString(void);
|
|
/* handle implementation specific debug cluster commands. Return 1 if handled, 0 otherwise. */
|
|
int handleDebugClusterCommand(client *c);
|
|
const char **clusterDebugCommandExtendedHelp(void);
|
|
/* handle implementation specific cluster commands. Return 1 if handled, 0 otherwise. */
|
|
int clusterCommandSpecial(client *c);
|
|
const char** clusterCommandExtendedHelp(void);
|
|
|
|
int clusterAllowFailoverCmd(client *c);
|
|
void clusterPromoteSelfToMaster(void);
|
|
int clusterManualFailoverTimeLimit(void);
|
|
|
|
void clusterCommandSlots(client * c);
|
|
void clusterCommandMyId(client *c);
|
|
void clusterCommandMyShardId(client *c);
|
|
void clusterCommandShards(client *c);
|
|
sds clusterGenNodeDescription(client *c, clusterNode *node, int tls_primary);
|
|
|
|
int clusterNodeCoversSlot(clusterNode *n, int slot);
|
|
int getNodeDefaultClientPort(clusterNode *n);
|
|
int clusterNodeIsMyself(clusterNode *n);
|
|
clusterNode *getMyClusterNode(void);
|
|
char *getMyClusterId(void);
|
|
int getClusterSize(void);
|
|
int getMyShardSlotCount(void);
|
|
int handleDebugClusterCommand(client *c);
|
|
int clusterNodePending(clusterNode *node);
|
|
int clusterNodeIsMaster(clusterNode *n);
|
|
char **getClusterNodesList(size_t *numnodes);
|
|
int clusterNodeIsMaster(clusterNode *n);
|
|
char *clusterNodeIp(clusterNode *node);
|
|
int clusterNodeIsSlave(clusterNode *node);
|
|
clusterNode *clusterNodeGetSlaveof(clusterNode *node);
|
|
clusterNode *clusterNodeGetMaster(clusterNode *node);
|
|
char *clusterNodeGetName(clusterNode *node);
|
|
int clusterNodeTimedOut(clusterNode *node);
|
|
int clusterNodeIsFailing(clusterNode *node);
|
|
int clusterNodeIsNoFailover(clusterNode *node);
|
|
char *clusterNodeGetShardId(clusterNode *node);
|
|
int clusterNodeNumSlaves(clusterNode *node);
|
|
clusterNode *clusterNodeGetSlave(clusterNode *node, int slave_idx);
|
|
clusterNode *getMigratingSlotDest(int slot);
|
|
clusterNode *getImportingSlotSource(int slot);
|
|
clusterNode *getNodeBySlot(int slot);
|
|
int clusterNodeClientPort(clusterNode *n, int use_tls);
|
|
char *clusterNodeHostname(clusterNode *node);
|
|
const char *clusterNodePreferredEndpoint(clusterNode *n);
|
|
long long clusterNodeReplOffset(clusterNode *node);
|
|
clusterNode *clusterLookupNode(const char *name, int length);
|
|
|
|
/* functions with shared implementations */
|
|
clusterNode *getNodeByQuery(client *c, struct redisCommand *cmd, robj **argv, int argc, int *hashslot, int *ask);
|
|
int clusterRedirectBlockedClientIfNeeded(client *c);
|
|
void clusterRedirectClient(client *c, clusterNode *n, int hashslot, int error_code);
|
|
void migrateCloseTimedoutSockets(void);
|
|
unsigned int keyHashSlot(char *key, int keylen);
|
|
int patternHashSlot(char *pattern, int length);
|
|
int isValidAuxString(char *s, unsigned int length);
|
|
void migrateCommand(client *c);
|
|
void clusterCommand(client *c);
|
|
ConnectionType *connTypeOfCluster(void);
|
|
#endif /* __CLUSTER_H */
|