Lines Matching refs:psync_offset

364     long long psync_offset = server.master_repl_offset;  in getPsyncInitialOffset()  local
367 if (server.repl_backlog == NULL) psync_offset++; in getPsyncInitialOffset()
368 return psync_offset; in getPsyncInitialOffset()
417 long long psync_offset, psync_len; in masterTryPartialResynchronization() local
439 if (getLongLongFromObjectOrReply(c,c->argv[2],&psync_offset,NULL) != in masterTryPartialResynchronization()
442 psync_offset < server.repl_backlog_off || in masterTryPartialResynchronization()
443 psync_offset > (server.repl_backlog_off + server.repl_backlog_histlen)) in masterTryPartialResynchronization()
446 …lave %s for lack of backlog (Slave request was: %lld).", replicationGetSlaveName(c), psync_offset); in masterTryPartialResynchronization()
447 if (psync_offset > server.master_repl_offset) { in masterTryPartialResynchronization()
471 psync_len = addReplyReplicationBacklog(c,psync_offset); in masterTryPartialResynchronization()
475 psync_len, psync_offset); in masterTryPartialResynchronization()
1282 char psync_offset[32]; in slaveTryPartialResynchronization() local
1296 snprintf(psync_offset,sizeof(psync_offset),"%lld", server.cached_master->reploff+1); in slaveTryPartialResynchronization()
1297 …verLog(LL_NOTICE,"Trying a partial resynchronization (request %s:%s).", psync_runid, psync_offset); in slaveTryPartialResynchronization()
1301 memcpy(psync_offset,"-1",3); in slaveTryPartialResynchronization()
1305 reply = sendSynchronousCommand(SYNC_CMD_WRITE,fd,"PSYNC",psync_runid,psync_offset,NULL); in slaveTryPartialResynchronization()