Searched refs:reploff (Results 1 – 4 of 4) sorted by relevance
1083 server.master->reploff = server.master_initial_offset; in replicationCreateMasterClient()1084 server.master->read_reploff = server.master->reploff; in replicationCreateMasterClient()1089 if (server.master->reploff == -1) in replicationCreateMasterClient()1310 server.master_repl_offset = server.master->reploff; in readSyncBulkPayload()1464 snprintf(psync_offset,sizeof(psync_offset),"%lld", server.cached_master->reploff+1); in slaveTryPartialResynchronization()2127 addReplyLongLong(c,server.master ? server.master->reploff : -1); in roleCommand()2142 addReplyBulkLongLong(c,c->reploff); in replicationSendAck()2180 server.master->read_reploff = server.master->reploff; in replicationCacheMaster()2524 offset = server.master->reploff; in replicationGetSlaveOffset()2526 offset = server.cached_master->reploff; in replicationGetSlaveOffset()
130 c->reploff = 0; in createClient()1473 c->reploff = c->read_reploff - sdslen(c->querybuf) + c->qb_pos; in processInputBuffer()1507 size_t prev_offset = c->reploff; in processInputBufferAndReplicate()1509 size_t applied = c->reploff - prev_offset; in processInputBufferAndReplicate()
3503 slave_repl_offset = server.master->reploff; in genRedisInfoString()3505 slave_repl_offset = server.cached_master->reploff; in genRedisInfoString()
749 long long reploff; /* Applied replication offset if this is a master. */ member