Skip to content

Commit 5a6429a

Browse files
authored
Fix clustered key (#124)
1 parent 26ddcdb commit 5a6429a

File tree

2 files changed

+11
-3
lines changed

2 files changed

+11
-3
lines changed

src/mero.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -79,8 +79,8 @@ get(ClusterName, Key, Timeout) ->
7979
case gets(ClusterName, Key, Timeout) of
8080
{error, Reason} ->
8181
{error, Reason};
82-
{Key, Value, _CAS} ->
83-
{Key, Value}
82+
{NKey, Value, _CAS} ->
83+
{NKey, Value}
8484
end.
8585

8686
get(ClusterName, Key) ->

test/mero_SUITE.erl

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@
3838
increase_counter_clustered_key/1, increment/1, mdelete/1, multiget_defineds/1,
3939
multiget_defineds_clustered_keys/1, multiget_undefineds/1, set/1, undefined_counter/1,
4040
mincrease_counter/1, cas/1, madd/1, mset/1, mcas/1, state_ok/1, state_error/1,
41-
state_timeout/1]).
41+
state_timeout/1, get_clustered_key/1]).
4242

4343
%%%=============================================================================
4444
%%% common_test callbacks
@@ -53,6 +53,7 @@ groups() ->
5353
[add,
5454
delete,
5555
get_undefineds,
56+
get_clustered_key,
5657
increase_counter,
5758
increase_counter_clustered_key,
5859
increment,
@@ -71,6 +72,7 @@ groups() ->
7172
[add,
7273
delete,
7374
get_undefineds,
75+
get_clustered_key,
7476
increase_counter,
7577
increase_counter_clustered_key,
7678
%% mincrease_counter,
@@ -264,6 +266,12 @@ get_undefineds(_Conf) ->
264266
{Key2, undefined} = mero:get(cluster, Key2, 1000),
265267
{Key3, undefined} = mero:get(cluster, Key3, 1000).
266268

269+
get_clustered_key(_) ->
270+
Key = key(),
271+
ClusteredKey = {<<"1">>, Key},
272+
?assertEqual(ok, mero:set(cluster, ClusteredKey, <<"Adroll">>, 11111, 1000)),
273+
?assertEqual({Key, <<"Adroll">>}, mero:get(cluster, ClusteredKey, 1000)).
274+
267275
multiget_undefineds(_Conf) ->
268276
[] = mero:mget(cluster, [], 1000),
269277

0 commit comments

Comments
 (0)