diff options
Diffstat (limited to 'src/ejabberd_riak.erl')
| -rw-r--r-- | src/ejabberd_riak.erl | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/ejabberd_riak.erl b/src/ejabberd_riak.erl index 90bdb4c06..82ffe5e3d 100644 --- a/src/ejabberd_riak.erl +++ b/src/ejabberd_riak.erl @@ -73,7 +73,13 @@ start_link(Num, Server, Port, _StartInterval, Options) -> %% @private is_connected() -> - catch riakc_pb_socket:is_connected(get_random_pid()). + lists:all( + fun({_Id, Pid, _Type, _Modules}) when is_pid(Pid) -> + case catch riakc_pb_socket:is_connected(get_random_pid()) of + true -> true; + _ -> false + end + end, supervisor:which_children(ejabberd_riak_sup)). %% @private get_proc(I) -> |