yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(emqx_rule_utils): http connectivity check ipv6 support

This commit is contained in:
Zaiming Shi 2021-04-27 22:11:16 +02:00 committed by Zaiming (Stone) Shi
parent 078ca67268
commit fbe15859f5
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_rule_engine/src/emqx_rule_utils.erl
View File

@ -204,7 +204,7 @@ http_connectivity(Url) ->
http_connectivity(Url, Timeout) -> http_connectivity(Url, Timeout) ->
case emqx_http_lib:uri_parse(Url) of case emqx_http_lib:uri_parse(Url) of
{ok, #{host := Host, port := Port}} -> {ok, #{host := Host, port := Port}} ->
tcp_connectivity(str(Host), Port, Timeout); tcp_connectivity(Host, Port, Timeout);
{error, Reason} -> {error, Reason} ->
{error, Reason} {error, Reason}
end. end.
@ -220,7 +220,7 @@ tcp_connectivity(Host, Port) ->
Timeout :: integer()) Timeout :: integer())
-> ok | {error, Reason :: term()}). -> ok | {error, Reason :: term()}).
tcp_connectivity(Host, Port, Timeout) -> tcp_connectivity(Host, Port, Timeout) ->
case gen_tcp:connect(Host, Port, [], Timeout) of case gen_tcp:connect(Host, Port, emqx_misc:ipv6_probe([]), Timeout) of
{ok, Sock} -> gen_tcp:close(Sock), ok; {ok, Sock} -> gen_tcp:close(Sock), ok;
{error, Reason} -> {error, Reason} {error, Reason} -> {error, Reason}
end. end.