Skip to content

Commit

Permalink
Add test for reaping tombs, and reflecting API changes associated wit… (
Browse files Browse the repository at this point in the history
#4)

* Add test for reaping tombs, and reflecting API changes associated with  change

* Extend test to cover protocols and failure

And add to group

* Must have tictacaae enabled

But exchange tick set so that it will never run

* Update nextgenrepl_reaptombs.erl

Remove rogue config item

* Update to test with bucket types

* Remove rogue whitespace

ProtocolVersionError was not matching due to rogue white space

* Update nextgenrepl_reaptombs.erl

* Update rebar.config
  • Loading branch information
martinsumner committed Nov 14, 2023
1 parent 6e20985 commit 4e8b1bc
Show file tree
Hide file tree
Showing 7 changed files with 579 additions and 17 deletions.
1 change: 1 addition & 0 deletions groups/nextgenrepl
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ nextgenrepl_bouncingtomb
nextgenrepl_deletemodes
nextgenrepl_deletewithfailure
nextgenrepl_external_reconcile
nextgenrepl_reaptombs
nextgenrepl_rtq_auto
nextgenrepl_rtq_autocrdt
nextgenrepl_rtq_autotypes
Expand Down
5 changes: 4 additions & 1 deletion src/make_certs.erl
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
-module(make_certs).
-compile([export_all, nowarn_export_all]).

-export([all/1, all/2, rootCA/2, intermediateCA/3, endusers/3, enduser/3, revoke/3, gencrl/2, verify/3]).
-export([all/1, all/2, rootCA/2, intermediateCA/3, endusers/3, enduser/3, revoke/3, gencrl/2, verify/3, version/0]).

-record(dn, {commonName,
organizationalUnitName = "Basho Engineering",
Expand All @@ -32,6 +32,9 @@

-define(OpenSSLCmd, "openssl").

version() ->
os:cmd(?OpenSSLCmd ++ " version").

all([DataDir, PrivDir]) ->
all(DataDir, PrivDir).

Expand Down
4 changes: 2 additions & 2 deletions tests/nextgenrepl_deletewithfailure.erl
Original file line number Diff line number Diff line change
Expand Up @@ -217,7 +217,7 @@ test_repl(Protocol, [ClusterA, ClusterB]) ->
all,
count}),
lager:info("Counted ~w active keys on B1 all time", [KB]),
{ok, {keys, TBL}} = aae_fold(NodeB1,
{ok, {keysclocks, TBL}} = aae_fold(NodeB1,
Protocol,
{find_tombs,
?TEST_BUCKET, all,
Expand Down Expand Up @@ -468,7 +468,7 @@ fullsync_check(Protocol, {SrcNode, SrcNVal, SnkCluster},
AAEResult.

length_aae_fold(Node, Protocol, Query) ->
{ok, {keys, List}} = aae_fold(Node, Protocol, Query),
{ok, {_, List}} = aae_fold(Node, Protocol, Query),
length(List).

aae_fold(Node, Protocol, Query) ->
Expand Down
Loading

0 comments on commit 4e8b1bc

Please sign in to comment.