"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "src/cluster.c" between
redis-6.2-rc3.tar.gz and redis-6.2.0.tar.gz

About: redis is an advanced key-value store. It is often referred to as a data structure server since keys can contain strings, hashes, lists, sets and sorted sets.

cluster.c  (redis-6.2-rc3):cluster.c  (redis-6.2.0)
skipping to change at line 2128 skipping to change at line 2128
"Ignoring FAIL message from unknown node %.40s about %.40s", "Ignoring FAIL message from unknown node %.40s about %.40s",
hdr->sender, hdr->data.fail.about.nodename); hdr->sender, hdr->data.fail.about.nodename);
} }
} else if (type == CLUSTERMSG_TYPE_PUBLISH) { } else if (type == CLUSTERMSG_TYPE_PUBLISH) {
robj *channel, *message; robj *channel, *message;
uint32_t channel_len, message_len; uint32_t channel_len, message_len;
/* Don't bother creating useless objects if there are no /* Don't bother creating useless objects if there are no
* Pub/Sub subscribers. */ * Pub/Sub subscribers. */
if (dictSize(server.pubsub_channels) || if (dictSize(server.pubsub_channels) ||
listLength(server.pubsub_patterns)) dictSize(server.pubsub_patterns))
{ {
channel_len = ntohl(hdr->data.publish.msg.channel_len); channel_len = ntohl(hdr->data.publish.msg.channel_len);
message_len = ntohl(hdr->data.publish.msg.message_len); message_len = ntohl(hdr->data.publish.msg.message_len);
channel = createStringObject( channel = createStringObject(
(char*)hdr->data.publish.msg.bulk_data,channel_len); (char*)hdr->data.publish.msg.bulk_data,channel_len);
message = createStringObject( message = createStringObject(
(char*)hdr->data.publish.msg.bulk_data+channel_len, (char*)hdr->data.publish.msg.bulk_data+channel_len,
message_len); message_len);
pubsubPublishMessage(channel,message); pubsubPublishMessage(channel,message);
decrRefCount(channel); decrRefCount(channel);
skipping to change at line 2817 skipping to change at line 2817
* messages to hosts without receives for a given channel. * messages to hosts without receives for a given channel.
* -------------------------------------------------------------------------- */ * -------------------------------------------------------------------------- */
void clusterPropagatePublish(robj *channel, robj *message) { void clusterPropagatePublish(robj *channel, robj *message) {
clusterSendPublish(NULL, channel, message); clusterSendPublish(NULL, channel, message);
} }
/* ----------------------------------------------------------------------------- /* -----------------------------------------------------------------------------
* SLAVE node specific functions * SLAVE node specific functions
* -------------------------------------------------------------------------- */ * -------------------------------------------------------------------------- */
/* This function sends a FAILOVE_AUTH_REQUEST message to every node in order to /* This function sends a FAILOVER_AUTH_REQUEST message to every node in order to
* see if there is the quorum for this slave instance to failover its failing * see if there is the quorum for this slave instance to failover its failing
* master. * master.
* *
* Note that we send the failover request to everybody, master and slave nodes, * Note that we send the failover request to everybody, master and slave nodes,
* but only the masters are supposed to reply to our query. */ * but only the masters are supposed to reply to our query. */
void clusterRequestFailoverAuth(void) { void clusterRequestFailoverAuth(void) {
clusterMsg buf[1]; clusterMsg buf[1];
clusterMsg *hdr = (clusterMsg*) buf; clusterMsg *hdr = (clusterMsg*) buf;
uint32_t totlen; uint32_t totlen;
 End of changes. 2 change blocks. 
2 lines changed or deleted 2 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)