chore: set_lable for debugging and log pool/id for zombie ehttpc

emqx · Feb 7, 2025 · ffb0759 · ffb0759
1 parent eafe388
commit ffb0759
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 3 deletions.
diff --git a/src/ehttpc.app.src b/src/ehttpc.app.src
@@ -1,6 +1,6 @@
 {application, ehttpc, [
     {description, "HTTP Client for Erlang/OTP"},
-    {vsn, "0.7.0"},
+    {vsn, "0.7.1"},
     {registered, []},
     {applications, [
         kernel,

diff --git a/src/ehttpc.erl b/src/ehttpc.erl
@@ -262,6 +262,13 @@ init([Pool, Id, Opts0]) ->
         max_inactive = MaxInactive
     },
     true = gproc_pool:connect_worker(ehttpc:name(Pool), {Pool, Id}),
+
+    case erlang:function_exported(proc_lib, set_label, 1) of
+        true ->
+            proc_lib:set_label({ehttpc, Pool, Id});
+        false ->
+            ignore
+    end,
     {ok, start_check_inactive_timer(State)}.
 
 handle_call({health_check, _}, _From, State = #state{gun_state = up}) ->
@@ -736,7 +743,9 @@ maybe_shoot(
                     ]),
                     inactive_duration_threshold => MaxInactive,
                     inflight_requests => SentCount,
-                    connection_pid => Client
+                    connection_pid => Client,
+                    pool => State#state.pool,
+                    id => State#state.id
                 },
                 State
             ),

diff --git a/src/ehttpc_worker_sup.erl b/src/ehttpc_worker_sup.erl
@@ -28,7 +28,7 @@ start_link(Pool, Opts) ->
 init([Pool, Opts]) ->
     WorkerSpec = fun(Id) ->
         #{
-            id => {worker, Id},
+            id => {Pool, Id},
             start => {ehttpc, start_link, [Pool, Id, Opts]},
             restart => transient,
             shutdown => 5000,