From 4651c2d485a70e18499aa37cc3c564667f19b7e1 Mon Sep 17 00:00:00 2001 From: Christopher Date: Thu, 16 Apr 2020 11:45:06 -0500 Subject: [PATCH] handle updating currupted call index --- lib/router/realms/session.ex | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/lib/router/realms/session.ex b/lib/router/realms/session.ex index 22636bf..f82dde3 100644 --- a/lib/router/realms/session.ex +++ b/lib/router/realms/session.ex @@ -98,10 +98,16 @@ defmodule Wampex.Router.Realms.Session do current_id + 1 end - defp update_round_robin({id, [values] = v}, value) do + defp update_round_robin({id, v}, value) do Logger.info("Update Round Robin: #{inspect(id)} -> #{inspect(v)}: #{inspect(value)}") - case values + 1 do + val = + case v do + [values] -> values + [_ | t] -> Enum.reduce(t, 0, fn a, _acc -> a end) + end + + case val + 1 do ni when ni < value -> Logger.info("Incrementing round robin: #{inspect(id)} to #{inspect(ni)}") {id, [ni]} -- 2.45.3