Home
last modified time | relevance | path

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

/f-stack/app/redis-5.0.5/src/
H A Dreplication.c2462 c->bpop.reploffset = offset; in waitCommand()
2499 if (last_offset && last_offset > c->bpop.reploffset && in processClientsWaitingReplicas()
2505 int numreplicas = replicationCountAcksByOffset(c->bpop.reploffset); in processClientsWaitingReplicas()
2508 last_offset = c->bpop.reploffset; in processClientsWaitingReplicas()
H A Dblocked.c192 addReplyLongLong(c,replicationCountAcksByOffset(c->bpop.reploffset)); in replyToBlockedClientTimedOut()
H A Dnetworking.c150 c->bpop.reploffset = 0; in createClient()
H A Dserver.h689 long long reploffset; /* Replication offset to reach. */ member