Lines Matching refs:offset

309 long long addReplyReplicationBacklog(client *c, long long offset) {  in addReplyReplicationBacklog()  argument
312 serverLog(LL_DEBUG, "[PSYNC] Slave request offset: %lld", offset); in addReplyReplicationBacklog()
329 skip = offset - server.repl_backlog_off; in addReplyReplicationBacklog()
387 int replicationSetupSlaveForFullResync(client *slave, long long offset) { in replicationSetupSlaveForFullResync() argument
391 slave->psync_initial_offset = offset; in replicationSetupSlaveForFullResync()
402 server.runid,offset); in replicationSetupSlaveForFullResync()
742 long long offset; in replconfCommand() local
745 if ((getLongLongFromObject(c->argv[j+1], &offset) != C_OK)) in replconfCommand()
747 if (offset > c->repl_ack_off) in replconfCommand()
748 c->repl_ack_off = offset; in replconfCommand()
1327 char *runid = NULL, *offset = NULL; in slaveTryPartialResynchronization() local
1334 offset = strchr(runid,' '); in slaveTryPartialResynchronization()
1335 if (offset) offset++; in slaveTryPartialResynchronization()
1337 if (!runid || !offset || (offset-runid-1) != CONFIG_RUN_ID_SIZE) { in slaveTryPartialResynchronization()
1346 memcpy(server.repl_master_runid, runid, offset-runid-1); in slaveTryPartialResynchronization()
1348 server.repl_master_initial_offset = strtoll(offset,NULL,10); in slaveTryPartialResynchronization()
2120 int replicationCountAcksByOffset(long long offset) { in replicationCountAcksByOffset() argument
2130 if (slave->repl_ack_off >= offset) count++; in replicationCountAcksByOffset()
2140 long long offset = c->woff; in waitCommand() local
2158 c->bpop.reploffset = offset; in waitCommand()
2216 long long offset = 0; in replicationGetSlaveOffset() local
2220 offset = server.master->reploff; in replicationGetSlaveOffset()
2222 offset = server.cached_master->reploff; in replicationGetSlaveOffset()
2229 if (offset < 0) offset = 0; in replicationGetSlaveOffset()
2230 return offset; in replicationGetSlaveOffset()