From 4cdae9f1bca0ebb54c781116be3d428698b9cecc Mon Sep 17 00:00:00 2001 From: joeri dijkstra Date: Tue, 28 Oct 2025 14:41:23 +0100 Subject: [PATCH 1/2] fix: refresh error spam on direct_state (no lb) --- lib/grpc/client/connection.ex | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/lib/grpc/client/connection.ex b/lib/grpc/client/connection.ex index 558545fb..a7d96a2b 100644 --- a/lib/grpc/client/connection.ex +++ b/lib/grpc/client/connection.ex @@ -273,7 +273,7 @@ defmodule GRPC.Client.Connection do :refresh, %{lb_mod: lb_mod, lb_state: lb_state, real_channels: channels, virtual_channel: vc} = state - ) do + ) when not is_nil(lb_mod) do {:ok, {prefer_host, prefer_port}, new_lb_state} = lb_mod.pick(lb_state) channel_key = "#{prefer_host}:#{prefer_port}" @@ -294,6 +294,8 @@ defmodule GRPC.Client.Connection do end end + def handle_info(:refresh, state), do: {:noreply, state} + def handle_info({:DOWN, _ref, :process, pid, reason}, state) do Logger.warning( "#{inspect(__MODULE__)} received :DOWN from #{inspect(pid)} with reason: #{inspect(reason)}" From 477e84f9e54c53b0e140a715260ad50b449d8799 Mon Sep 17 00:00:00 2001 From: joeri dijkstra Date: Wed, 29 Oct 2025 14:09:49 +0100 Subject: [PATCH 2/2] chore: formatting connection module --- lib/grpc/client/connection.ex | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/lib/grpc/client/connection.ex b/lib/grpc/client/connection.ex index a7d96a2b..0ce01076 100644 --- a/lib/grpc/client/connection.ex +++ b/lib/grpc/client/connection.ex @@ -273,7 +273,8 @@ defmodule GRPC.Client.Connection do :refresh, %{lb_mod: lb_mod, lb_state: lb_state, real_channels: channels, virtual_channel: vc} = state - ) when not is_nil(lb_mod) do + ) + when not is_nil(lb_mod) do {:ok, {prefer_host, prefer_port}, new_lb_state} = lb_mod.pick(lb_state) channel_key = "#{prefer_host}:#{prefer_port}"