Home
last modified time | relevance | path

Searched refs:reploffset (Results 1 – 4 of 4) sorted by relevance

/redis-3.2.3/src/
H A Dblocked.c161 addReplyLongLong(c,replicationCountAcksByOffset(c->bpop.reploffset)); in replyToBlockedClientTimedOut()
H A Dreplication.c2158 c->bpop.reploffset = offset; in waitCommand()
2195 if (last_offset && last_offset > c->bpop.reploffset && in processClientsWaitingReplicas()
2201 int numreplicas = replicationCountAcksByOffset(c->bpop.reploffset); in processClientsWaitingReplicas()
2204 last_offset = c->bpop.reploffset; in processClientsWaitingReplicas()
H A Dserver.h544 long long reploffset; /* Replication offset to reach. */ member
H A Dnetworking.c120 c->bpop.reploffset = 0; in createClient()