diff options
| author | Evgeniy Khramtsov <ekhramtsov@process-one.net> | 2014-07-09 22:49:23 +0400 |
|---|---|---|
| committer | Evgeniy Khramtsov <ekhramtsov@process-one.net> | 2014-07-10 13:55:24 +0400 |
| commit | 2fe8e0dea5bb2aea7c728c44d3ab9d19fcb5e332 (patch) | |
| tree | de7995774fe70253f3fc201b05558f0726990b57 /src | |
| parent | Don't forget to shutdown rooms before starting the testing suite (diff) | |
Make it possible to check Riak connection status
Diffstat (limited to 'src')
| -rw-r--r-- | src/ejabberd_riak.erl | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/ejabberd_riak.erl b/src/ejabberd_riak.erl index 07dbf3a87..25cb2792e 100644 --- a/src/ejabberd_riak.erl +++ b/src/ejabberd_riak.erl @@ -30,7 +30,7 @@ -export([start_link/4, get_proc/1, make_bucket/1, put/1, put/2, get/1, get/2, get_by_index/3, delete/1, delete/2, count_by_index/3, get_by_index_range/4, - get_keys/1, get_keys_by_index/3, + get_keys/1, get_keys_by_index/3, is_connected/0, count/1, delete_by_index/3]). %% For debugging -export([get_tables/0]). @@ -65,6 +65,10 @@ start_link(Num, Server, Port, _StartInterval) -> gen_server:start_link({local, get_proc(Num)}, ?MODULE, [Server, Port], []). %% @private +is_connected() -> + catch riakc_pb_socket:is_connected(get_random_pid()). + +%% @private get_proc(I) -> jlib:binary_to_atom( iolist_to_binary( |