Browse Source

fix kvs:dir() in riak backend

Maxim Sokhatsky 10 years ago
parent
commit
5ab4127cf2
1 changed files with 2 additions and 1 deletions
  1. 2 1
      src/store_riak.erl

+ 2 - 1
src/store_riak.erl

@@ -19,7 +19,8 @@ join(Ring) -> riak_core:join(Ring).
 initialize() -> riak:client_connect(node()).
 
 dir() ->
-    {ok,Buckets} = riak_client:list_buckets(),
+    {ok,C}=riak:local_client(),
+    {ok,Buckets} = C:list_buckets(),
     [{table,binary_to_list(X)}||X<-Buckets].
 
 riak_clean(Table) when is_list(Table)->