Home
last modified time | relevance | path

Searched refs:slave (Results 1 – 25 of 25) sorted by relevance

/redis-3.2.3/tests/integration/
H A Dreplication-4.tcl16 set slave [srv 0 client]
22 test {First server should have role slave after SLAVEOF} {
23 $slave slaveof $master_host $master_port
26 } {slave}
63 set slave [srv 0 client]
66 $slave slaveof $master_host $master_port
91 $slave deferred 1
92 $slave debug sleep 6
105 set slave [srv 0 client]
108 $slave slaveof $master_host $master_port
[all …]
H A Dreplication-psync.tcl27 set slave [srv 0 client]
39 $slave slaveof $master_host $master_port
41 [lindex [r role] 0] eq {slave} &&
68 $slave multi
69 $slave client kill $master_host:$master_port
70 $slave debug sleep $delay
71 $slave exec
73 $slave client kill $master_host:$master_port
83 while {$retry && ([$master debug digest] ne [$slave debug digest])}\
90 if {[$master debug digest] ne [$slave debug digest]} {
H A Dreplication.tcl9 set slave [srv 0 client]
26 $slave config set repl-timeout 5
29 $slave slaveof $master_host $master_port
33 [string match *handshake* [$slave role]]
63 test {Set instance A as slave of B} {
66 [lindex [$A role] 0] eq {slave} &&
102 [lindex [$B role] 0] eq {slave} &&
140 } {slave}
167 test {ROLE in master reports master with a slave} {
177 test {ROLE in slave reports slave in connected state} {
[all …]
H A Dreplication-2.tcl3 test {First server should have role slave after SLAVEOF} {
7 } {slave}
38 test {No write if min-slaves-max-lag is > of the slave lag} {
H A Dreplication-3.tcl3 test {First server should have role slave after SLAVEOF} {
38 test {First server should have role slave after SLAVEOF} {
/redis-3.2.3/src/
H A Dreplication.c43 void putSlaveOnline(client *slave);
635 client *slave; in syncCommand() local
641 slave = ln->value; in syncCommand()
646 if (ln && ((c->slave_capa & slave->slave_capa) == slave->slave_capa)) { in syncCommand()
790 freeClient(slave); in putSlaveOnline()
799 client *slave = privdata; in sendBulkToSlave() local
809 nwritten = write(fd,slave->replpreamble,sdslen(slave->replpreamble)); in sendBulkToSlave()
828 lseek(slave->repldbfd,slave->repldboff,SEEK_SET); in sendBulkToSlave()
833 freeClient(slave); in sendBulkToSlave()
846 if (slave->repldboff == slave->repldbsize) { in sendBulkToSlave()
[all …]
H A Dsentinel.c1270 sentinelRedisInstance *slave; in sentinelRedisInstanceLookupSlave() local
1278 return slave; in sentinelRedisInstanceLookupSlave()
1501 sentinelRedisInstance *slave; in sentinelResetMasterAndChangeAddress() local
1506 if (slave) sentinelEvent(LL_NOTICE,"+slave",slave,"%@"); in sentinelResetMasterAndChangeAddress()
1654 sentinelRedisInstance *slave; in sentinelHandleConfiguration() local
2004 sentinelRedisInstance *slave; in sentinelRefreshInstanceInfo() local
3942 instance[instances++] = slave; in sentinelSelectSlave()
3993 if (slave == NULL) { in sentinelFailoverSelectSlave()
3998 slave->flags |= SRI_PROMOTED; in sentinelFailoverSelectSlave()
3999 ri->promoted_slave = slave; in sentinelFailoverSelectSlave()
[all …]
H A Drdb.c1525 client *slave = ln->value; in backgroundSaveDoneHandlerSocket() local
1535 if (slave->id == ok_slaves[2*j+1]) { in backgroundSaveDoneHandlerSocket()
1543 replicationGetSlaveName(slave), in backgroundSaveDoneHandlerSocket()
1546 freeClient(slave); in backgroundSaveDoneHandlerSocket()
1552 anetNonBlock(NULL,slave->fd); in backgroundSaveDoneHandlerSocket()
1553 anetSendTimeout(NULL,slave->fd,0); in backgroundSaveDoneHandlerSocket()
1609 client *slave = ln->value; in rdbSaveToSlavesSockets() local
1612 clientids[numfds] = slave->id; in rdbSaveToSlavesSockets()
1613 fds[numfds++] = slave->fd; in rdbSaveToSlavesSockets()
1618 anetBlock(NULL,slave->fd); in rdbSaveToSlavesSockets()
[all …]
H A Dredis-trib.rb753 slave = node
756 slave = interleaved.shift
758 slave.set_as_replica(m.info[:name])
761 puts "Adding replica #{slave} to #{m}"
H A Dnetworking.c1838 client *slave = listNodeValue(ln); in flushSlavesOutputBuffers() local
1847 events = aeGetFileEvents(server.el,slave->fd); in flushSlavesOutputBuffers()
1849 slave->replstate == SLAVE_STATE_ONLINE && in flushSlavesOutputBuffers()
1850 clientHasPendingReplies(slave)) in flushSlavesOutputBuffers()
1852 writeToClient(slave->fd,slave,0); in flushSlavesOutputBuffers()
H A Dserver.c3194 client *slave = listNodeValue(ln); in genRedisInfoString() local
3196 char ip[NET_IP_STR_LEN], *slaveip = slave->slave_ip; in genRedisInfoString()
3201 if (anetPeerToString(slave->fd,ip,sizeof(ip),&port) == -1) in genRedisInfoString()
3205 switch(slave->replstate) { in genRedisInfoString()
3218 if (slave->replstate == SLAVE_STATE_ONLINE) in genRedisInfoString()
3219 lag = time(NULL) - slave->repl_ack_time; in genRedisInfoString()
3224 slaveid,slaveip,slave->slave_listening_port,state, in genRedisInfoString()
3225 slave->repl_ack_off, lag); in genRedisInfoString()
3462 client *slave = listNodeValue(ln); in freeMemoryIfNeeded() local
3463 unsigned long obuf_bytes = getClientOutputBufferMemoryUsage(slave); in freeMemoryIfNeeded()
H A Dcluster.c61 int clusterNodeAddSlave(clusterNode *master, clusterNode *slave);
777 int clusterNodeRemoveSlave(clusterNode *master, clusterNode *slave) { in clusterNodeRemoveSlave() argument
781 if (master->slaves[j] == slave) { in clusterNodeRemoveSlave()
796 int clusterNodeAddSlave(clusterNode *master, clusterNode *slave) { in clusterNodeAddSlave() argument
801 if (master->slaves[j] == slave) return C_ERR; in clusterNodeAddSlave()
804 master->slaves[master->numslaves] = slave; in clusterNodeAddSlave()
H A Dserver.h1253 int replicationSetupSlaveForFullResync(client *slave, long long offset);
/redis-3.2.3/tests/cluster/tests/
H A D03-failover-loop.tcl26 set slave {}
31 set slave $id
34 if {$slave eq {}} {
49 set slave_config_epoch [CI $slave cluster_my_epoch]
69 test "Wait failover by #$slave with old epoch $slave_config_epoch" {
71 [CI $slave cluster_my_epoch] > $slave_config_epoch
73 fail "No failover detected, epoch is still [CI $slave cluster_my_epoch]"
95 [RI $tokill role] eq {slave}
H A D11-manual-takeover.tcl55 [RI 0 role] eq {slave} && [RI 1 role] eq {slave} && [RI 2 role] eq {slave}
H A D10-manual-failover.tcl18 assert {[RI 5 role] eq {slave}}
91 [RI 0 role] eq {slave}
114 assert {[RI 5 role] eq {slave}}
161 assert {[RI 5 role] eq {slave}}
H A D02-failover.tcl18 assert {[RI 5 role] eq {slave}}
61 [RI 0 role] eq {slave}
H A D08-update-msg.tcl27 assert {[RI 5 role] eq {slave}}
78 [RI 0 role] eq {slave}
H A D06-slave-stop-cond.tcl68 assert {[RI 5 role] eq {slave}}
H A D04-resharding.tcl151 if {$myrole eq {slave}} continue
/redis-3.2.3/
H A Dredis.conf285 slave-serve-stale-data yes
301 slave-read-only yes
414 slave-priority 100
1028 client-output-buffer-limit slave 256mb 64mb 60
H A D00-RELEASENOTES61 a slave is able to fail over its master reducing certain delays.
85 1. Now slaves support the slave-announce-ip and slave-announce-port options.
86 Using these features a slave can be reported by the master `INFO` output
120 Ability of slave to announce arbitrary ip/port to master.
250 when it is reachable again, as the slave of the new master. This was due
425 | fix check when can't send the command to the promoted slave
787 the past a slave could migrate only to a master that used to have slaves
789 if a new slave gets at least a slot, and at least one other master in the
790 cluster has a slave, then the new master is considered a valid target for
791 replica migration. So if it will be orphaned and there is a spare slave
[all …]
/redis-3.2.3/tests/assets/
H A Ddefault.conf22 slave-serve-stale-data yes
/redis-3.2.3/tests/
H A Dinstances.tcl205 if {[RI $id role] eq {slave}} {
/redis-3.2.3/tests/unit/
H A Dscripting.tcl553 [s -1 role] eq {slave} &&
636 [s -1 role] eq {slave} &&