Home
last modified time | relevance | path

Searched refs:slaves (Results 1 – 15 of 15) sorted by relevance

/redis-3.2.3/tests/integration/
H A Dreplication.tcl169 lassign $res role offset slaves
172 assert {[llength $slaves] == 1}
173 lassign [lindex $slaves 0] master_host master_port slave_offset
192 set slaves {}
199 lappend slaves [srv 0 client]
201 lappend slaves [srv 0 client]
203 lappend slaves [srv 0 client]
249 [$master dbsize] == [[lindex $slaves 2] dbsize]
256 set digest0 [[lindex $slaves 0] debug digest]
257 set digest1 [[lindex $slaves 1] debug digest]
[all …]
H A Dreplication-2.tcl20 test {No write if min-slaves-to-write is < attached slaves} {
51 test {min-slaves-to-write is ignored by slaves} {
/redis-3.2.3/tests/cluster/
H A Dcluster.tcl92 proc cluster_allocate_slaves {masters slaves} { argument
93 for {set j 0} {$j < $slaves} {incr j} {
102 proc create_cluster {masters slaves} { argument
104 if {$slaves} {
105 cluster_allocate_slaves $masters $slaves
/redis-3.2.3/src/
H A Dreplication.c207 listRewind(slaves,&li); in replicationFeedSlaves()
247 listRewind(server.slaves,&li); in replicationFeedSlaves()
462 listAddNodeTail(server.slaves,c); in masterTryPartialResynchronization()
626 listAddNodeTail(server.slaves,c); in syncCommand()
874 listRewind(server.slaves,&li); in updateSlavesWaitingBgsave()
1824 int slaves = 0; in roleCommand() local
1845 slaves++; in roleCommand()
1989 listRewind(server.slaves,&li); in refreshGoodSlavesCount()
2125 listRewind(server.slaves,&li); in replicationCountAcksByOffset()
2303 listRewind(server.slaves,&li); in replicationCron()
[all …]
H A Dsentinel.c1242 dictRelease(ri->slaves); in releaseSentinelRedisInstance()
1400 dictRelease(ri->slaves); in sentinelResetMaster()
1462 sentinelAddr **slaves = NULL; in sentinelResetMasterAndChangeAddress() local
1472 di = dictGetIterator(master->slaves); in sentinelResetMasterAndChangeAddress()
1477 slaves = zrealloc(slaves,sizeof(sentinelAddr*)*(numslaves+1)); in sentinelResetMasterAndChangeAddress()
1487 slaves = zrealloc(slaves,sizeof(sentinelAddr*)*(numslaves+1)); in sentinelResetMasterAndChangeAddress()
1505 releaseSentinelAddr(slaves[j]); in sentinelResetMasterAndChangeAddress()
1508 zfree(slaves); in sentinelResetMasterAndChangeAddress()
3265 dictSize(ri->slaves), in sentinelInfoCommand()
3923 di = dictGetIterator(master->slaves); in sentinelSelectSlave()
[all …]
H A Dcluster.c666 node->slaves = NULL; in createClusterNode()
781 if (master->slaves[j] == slave) { in clusterNodeRemoveSlave()
784 memmove(master->slaves+j,master->slaves+(j+1), in clusterNodeRemoveSlave()
802 master->slaves = zrealloc(master->slaves, in clusterNodeAddSlave()
804 master->slaves[master->numslaves] = slave; in clusterNodeAddSlave()
826 n->slaves[j]->slaveof = NULL; in freeClusterNode()
839 zfree(n->slaves); in freeClusterNode()
2591 if (master->slaves[j] != myself && in clusterGetSlaveRank()
3365 int slaves = 0; in clusterMastersHaveSlaves() local
3370 slaves += node->numslaves; in clusterMastersHaveSlaves()
[all …]
H A Dserver.c1160 listLength(server.slaves), in serverCron()
1867 server.slaves = listCreate(); in initServer()
2127 replicationFeedSlaves(server.slaves,dbid,argv,argc); in propagate()
2921 listLength(server.clients)-listLength(server.slaves), in genRedisInfoString()
3176 listLength(server.slaves)); in genRedisInfoString()
3187 if (listLength(server.slaves)) { in genRedisInfoString()
3192 listRewind(server.slaves,&li); in genRedisInfoString()
3450 int slaves = listLength(server.slaves); in freeMemoryIfNeeded() local
3456 if (slaves) { in freeMemoryIfNeeded()
3460 listRewind(server.slaves,&li); in freeMemoryIfNeeded()
[all …]
H A Dcluster.h90 struct clusterNode **slaves; /* pointers to slave nodes */ member
H A Drdb.c1523 listRewind(server.slaves,&li); in backgroundSaveDoneHandlerSocket()
1600 fds = zmalloc(sizeof(int)*listLength(server.slaves)); in rdbSaveToSlavesSockets()
1604 clientids = zmalloc(sizeof(uint64_t)*listLength(server.slaves)); in rdbSaveToSlavesSockets()
1607 listRewind(server.slaves,&li); in rdbSaveToSlavesSockets()
1703 listRewind(server.slaves,&li); in rdbSaveToSlavesSockets()
H A Dnetworking.c737 while (listLength(server.slaves)) { in disconnectSlaves()
738 listNode *ln = listFirst(server.slaves); in disconnectSlaves()
846 list *l = (c->flags & CLIENT_MONITOR) ? server.monitors : server.slaves; in freeClient()
853 if (c->flags & CLIENT_SLAVE && listLength(server.slaves) == 0) in freeClient()
1836 listRewind(server.slaves,&li); in flushSlavesOutputBuffers()
H A Dserver.h739 list *slaves, *monitors; /* List of slaves and MONITORs */ member
1232 void replicationFeedSlaves(list *slaves, int dictid, robj **argv, int argc);
H A Ddb.c890 replicationFeedSlaves(server.slaves,db->id,argv,2); in propagateExpire()
/redis-3.2.3/tests/cluster/tests/
H A D04-resharding.tcl150 lassign $role myrole myoffset slaves
/redis-3.2.3/
H A D00-RELEASENOTES59 3. Redis Sentinel now checks slaves INFO state more often when disconnected.
85 1. Now slaves support the slave-announce-ip and slave-announce-port options.
301 reconfigure back old masters to slaves after they are reachable again
787 the past a slave could migrate only to a master that used to have slaves
1163 to other nodes, the master remains empty and the slaves migrate away
1166 no way to tell it had slaves in the past.
1169 new rule. When a new or old master which is empty and without slaves,
1171 slaves, they are automatically considered to be targets for replicas
1651 slaves and AOF only selected parts of a script. (Design by
1670 * [NEW] Better consistency behavior between masters and slaves for expired
[all …]
/redis-3.2.3/tests/unit/
H A Dscripting.tcl397 test {EVAL processes writes from AOF in read-only slaves} {