]> Entropealabs - wampex_router.git/commitdiff
handle no live callees
authorChristopher <chris@entropealabs.com>
Sun, 5 Apr 2020 20:33:36 +0000 (15:33 -0500)
committerChristopher <chris@entropealabs.com>
Sun, 5 Apr 2020 20:33:36 +0000 (15:33 -0500)
lib/router/session.ex

index 97555fceddcc0d3d249250b92ff9f7d0d99f5e7b..fe5cbeb8c73570cc3c44a48f58224c048035e432 100644 (file)
@@ -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