(couchdb) branch auto-delete-3 updated: silently ignore peer checkpoint calls on non-shards

[rnewson]

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 7ba1e945d silently ignore peer checkpoint calls on non-shards
7ba1e945d is described below

commit 7ba1e945daf9400f6011ad83e06cb0d2aec6a42c
Author: Robert Newson <rnew...@apache.org>
AuthorDate: Tue May 6 15:07:53 2025 +0100

    silently ignore peer checkpoint calls on non-shards
---
 src/fabric/src/fabric_drop_seq.erl | 36 ++++++++++++++++++++++++++++++++----
 1 file changed, 32 insertions(+), 4 deletions(-)

diff --git a/src/fabric/src/fabric_drop_seq.erl 
b/src/fabric/src/fabric_drop_seq.erl
index 2ecfe6441..33c9096d1 100644
--- a/src/fabric/src/fabric_drop_seq.erl
+++ b/src/fabric/src/fabric_drop_seq.erl
@@ -301,13 +301,27 @@ latest_shard_sync_checkpoints(ShardSyncHistory) ->
         ShardSyncHistory
     ).
 
-create_peer_checkpoint_doc_if_missing(DbName, Subtype, Source, PeerId, 
UpdateSeq) when
+create_peer_checkpoint_doc_if_missing(
+    <<"shards/", _/binary>> = DbName, Subtype, Source, PeerId, UpdateSeq
+) when
     is_binary(DbName), is_binary(PeerId), is_integer(UpdateSeq)
 ->
     create_peer_checkpoint_doc_if_missing(
         DbName, Subtype, Source, PeerId, pack_seq(DbName, UpdateSeq)
     );
-create_peer_checkpoint_doc_if_missing(DbName, Subtype, Source, PeerId, 
UpdateSeq) when
+create_peer_checkpoint_doc_if_missing(
+    DbName, Subtype, Source, PeerId, UpdateSeq
+) when
+    is_binary(DbName),
+    is_binary(Subtype),
+    is_binary(Source),
+    is_binary(PeerId),
+    is_integer(UpdateSeq)
+->
+    ok;
+create_peer_checkpoint_doc_if_missing(
+    <<"shards/", _/binary>> = DbName, Subtype, Source, PeerId, UpdateSeq
+) when
     is_binary(DbName),
     is_binary(Subtype),
     is_binary(Source),
@@ -333,7 +347,9 @@ create_peer_checkpoint_doc_if_missing(DbName, Subtype, 
Source, PeerId, UpdateSeq
             Else
     end.
 
-update_peer_checkpoint_doc(DbName, Subtype, Source, PeerId, UpdateSeq) when
+update_peer_checkpoint_doc(
+    <<"shards/", _/binary>> = DbName, Subtype, Source, PeerId, UpdateSeq
+) when
     is_binary(DbName),
     is_binary(Subtype),
     is_binary(Source),
@@ -341,7 +357,19 @@ update_peer_checkpoint_doc(DbName, Subtype, Source, 
PeerId, UpdateSeq) when
     is_integer(UpdateSeq)
 ->
     update_peer_checkpoint_doc(DbName, Subtype, Source, PeerId, 
pack_seq(DbName, UpdateSeq));
-update_peer_checkpoint_doc(DbName, Subtype, Source, PeerId, UpdateSeq) when
+update_peer_checkpoint_doc(
+    DbName, Subtype, Source, PeerId, UpdateSeq
+) when
+    is_binary(DbName),
+    is_binary(Subtype),
+    is_binary(Source),
+    is_binary(PeerId),
+    is_integer(UpdateSeq)
+->
+    ok;
+update_peer_checkpoint_doc(
+    <<"shards/", _/binary>> = DbName, Subtype, Source, PeerId, UpdateSeq
+) when
     is_binary(DbName),
     is_binary(Subtype),
     is_binary(Source),