From dff4a14be5536fbcbceb998999db94f6b383208a Mon Sep 17 00:00:00 2001 From: Ricardo Azpeitia Pimentel Date: Wed, 15 Oct 2025 13:04:41 -0500 Subject: [PATCH] Fix clustered key --- src/mero.erl | 4 ++-- test/mero_SUITE.erl | 10 +++++++++- 2 files changed, 11 insertions(+), 3 deletions(-) diff --git a/src/mero.erl b/src/mero.erl index c09060b..0f31052 100644 --- a/src/mero.erl +++ b/src/mero.erl @@ -79,8 +79,8 @@ get(ClusterName, Key, Timeout) -> case gets(ClusterName, Key, Timeout) of {error, Reason} -> {error, Reason}; - {Key, Value, _CAS} -> - {Key, Value} + {NKey, Value, _CAS} -> + {NKey, Value} end. get(ClusterName, Key) -> diff --git a/test/mero_SUITE.erl b/test/mero_SUITE.erl index 38a4cc9..e416ee8 100644 --- a/test/mero_SUITE.erl +++ b/test/mero_SUITE.erl @@ -38,7 +38,7 @@ increase_counter_clustered_key/1, increment/1, mdelete/1, multiget_defineds/1, multiget_defineds_clustered_keys/1, multiget_undefineds/1, set/1, undefined_counter/1, mincrease_counter/1, cas/1, madd/1, mset/1, mcas/1, state_ok/1, state_error/1, - state_timeout/1]). + state_timeout/1, get_clustered_key/1]). %%%============================================================================= %%% common_test callbacks @@ -53,6 +53,7 @@ groups() -> [add, delete, get_undefineds, + get_clustered_key, increase_counter, increase_counter_clustered_key, increment, @@ -71,6 +72,7 @@ groups() -> [add, delete, get_undefineds, + get_clustered_key, increase_counter, increase_counter_clustered_key, %% mincrease_counter, @@ -264,6 +266,12 @@ get_undefineds(_Conf) -> {Key2, undefined} = mero:get(cluster, Key2, 1000), {Key3, undefined} = mero:get(cluster, Key3, 1000). +get_clustered_key(_) -> + Key = key(), + ClusteredKey = {<<"1">>, Key}, + ?assertEqual(ok, mero:set(cluster, ClusteredKey, <<"Adroll">>, 11111, 1000)), + ?assertEqual({Key, <<"Adroll">>}, mero:get(cluster, ClusteredKey, 1000)). + multiget_undefineds(_Conf) -> [] = mero:mget(cluster, [], 1000),