From: Christopher Date: Sun, 5 Apr 2020 20:33:36 +0000 (-0500) Subject: handle no live callees X-Git-Url: http://git.entropealabs.com/?a=commitdiff_plain;h=60e05352f2e3867eecaa16a81d5a6a23b5afc526;p=wampex_router.git handle no live callees --- diff --git a/lib/router/session.ex b/lib/router/session.ex index 97555fc..fe5cbeb 100644 --- a/lib/router/session.ex +++ b/lib/router/session.ex @@ -733,7 +733,7 @@ defmodule Wampex.Router.Session do defp get_live_callee(_proxy, [], _index, 0), do: {:error, :no_live_callees} defp get_live_callee(_proxy, [], _index, _), do: {:error, :no_live_callees} - defp get_live_callee(proxy, callees, index, tries) do + defp get_live_callee(proxy, callees, index, tries) when is_list(callees) do {_id, {pid, node}} = c = Enum.at(callees, index) case GenServer.call({proxy, node}, {:is_up, pid}) do @@ -751,6 +751,8 @@ defmodule Wampex.Router.Session do end end + defp get_live_callee(_proxy, _, _index, _), do: {:error, :no_live_callees} + defp send_to_peer(msg, transport, pid) do transport.send_request(pid, remove_nil_values(msg)) end