From 65f468f7068365bdf0345f542655700ec1e29cb0 Mon Sep 17 00:00:00 2001
From: JimMoen <LnJimMoen@outlook.com>
Date: Thu, 23 Mar 2023 16:23:56 +0800
Subject: [PATCH] fix: for connection used ecpool, let worker do health check
 fun

let it be same with ecpool:pick_and_do/3 for checkfun use format as {M,F,A}
---
 apps/emqx_plugin_libs/src/emqx_plugin_libs_pool.erl | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/apps/emqx_plugin_libs/src/emqx_plugin_libs_pool.erl b/apps/emqx_plugin_libs/src/emqx_plugin_libs_pool.erl
index 289d39032..9b286f360 100644
--- a/apps/emqx_plugin_libs/src/emqx_plugin_libs_pool.erl
+++ b/apps/emqx_plugin_libs/src/emqx_plugin_libs_pool.erl
@@ -67,13 +67,14 @@ stop_pool(Name) ->
 health_check_ecpool_workers(PoolName, CheckFunc) ->
     health_check_ecpool_workers(PoolName, CheckFunc, ?HEALTH_CHECK_TIMEOUT).
 
-health_check_ecpool_workers(PoolName, CheckFunc, Timeout) when is_function(CheckFunc) ->
+health_check_ecpool_workers(PoolName, CheckFunc, Timeout) ->
     Workers = [Worker || {_WorkerName, Worker} <- ecpool:workers(PoolName)],
     DoPerWorker =
         fun(Worker) ->
             case ecpool_worker:client(Worker) of
                 {ok, Conn} ->
-                    erlang:is_process_alive(Conn) andalso CheckFunc(Conn);
+                    erlang:is_process_alive(Conn) andalso
+                        ecpool_worker:exec(Worker, CheckFunc, Timeout);
                 _ ->
                     false
             end