MCPcopy Create free account
hub / github.com/Snapchat/KeyDB / replicationFeedSlavesFromMasterStream

Function replicationFeedSlavesFromMasterStream

src/replication.cpp:734–746  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

732 * to our sub-slaves. */
733#include <ctype.h>
734void replicationFeedSlavesFromMasterStream(char *buf, size_t buflen) {
735 /* Debugging: this is handy to see the stream sent from master
736 * to slaves. Disabled with if(0). */
737 if (0) {
738 printf("%zu:",buflen);
739 for (size_t j = 0; j < buflen; j++) {
740 printf("%c", isprint(buf[j]) ? buf[j] : '.');
741 }
742 printf("\n");
743 }
744
745 if (g_pserver->repl_backlog) feedReplicationBacklog(buf,buflen);
746}
747
748void replicationFeedMonitors(client *c, list *monitors, int dictid, robj **argv, int argc) {
749 if (!(listLength(g_pserver->monitors) && !g_pserver->loading)) return;

Callers 1

commandProcessedFunction · 0.85

Calls 1

feedReplicationBacklogFunction · 0.85

Tested by

no test coverage detected