This is an automated email from the ASF dual-hosted git repository.
rnewson pushed a commit to branch auto-delete-3
in repository https://gitbox.apache.org/repos/asf/couchdb.git
The following commit(s) were added to refs/heads/auto-delete-3 by this push:
new db2d1ff89 don't make peer checkpoint for non-clustered replications
db2d1ff89 is described below
commit db2d1ff891b337b363b933c71c6c77ad9a407370
Author: Robert Newson <[email protected]>
AuthorDate: Tue May 6 15:58:12 2025 +0100
don't make peer checkpoint for non-clustered replications
---
.../src/couch_replicator_scheduler_job.erl | 16 ++++++++++++++--
1 file changed, 14 insertions(+), 2 deletions(-)
diff --git a/src/couch_replicator/src/couch_replicator_scheduler_job.erl
b/src/couch_replicator/src/couch_replicator_scheduler_job.erl
index add67ac28..0b14564c0 100644
--- a/src/couch_replicator/src/couch_replicator_scheduler_job.erl
+++ b/src/couch_replicator/src/couch_replicator_scheduler_job.erl
@@ -887,7 +887,14 @@ do_checkpoint(State) ->
{TgtRevPos, TgtRevId} = update_checkpoint(
Target, TargetLog#doc{body = NewRepHistory}, target
),
- update_checkpoint(Source, peer_checkpoint_doc(Source, BaseId,
NewSeq), source),
+ if
+ is_binary(NewSeq) ->
+ update_checkpoint(
+ Source, peer_checkpoint_doc(Source, BaseId,
NewSeq), source
+ );
+ true ->
+ ok
+ end,
NewState = State#rep_state{
checkpoint_history = NewRepHistory,
committed_seq = NewTsSeq,
@@ -930,7 +937,12 @@ create_peer_checkpoint_doc_if_missing(#httpdb{} = Db,
BaseId, SourceSeq) when
end;
{error, Reason} ->
throw({checkpoint_commit_failure, Reason})
- end.
+ end;
+create_peer_checkpoint_doc_if_missing(#httpdb{} = _Db, BaseId, SourceSeq) when
+ is_list(BaseId), is_integer(SourceSeq)
+->
+ %% ignored
+ ok.
peer_checkpoint_doc(#httpdb{} = Db, BaseId, UpdateSeq) ->
fabric_drop_seq:peer_checkpoint_doc(
