|
|
@@ -40,7 +40,7 @@ groups() ->
|
|
|
|
|
|
%% due to the poorly implemented driver or other reasons
|
|
|
%% if we mix these cases with others, this suite will become flaky.
|
|
|
- Flaky = [t_get_status, t_write_failure, t_write_timeout],
|
|
|
+ Flaky = [t_get_status, t_write_failure],
|
|
|
TCs = TCs0 -- Flaky,
|
|
|
|
|
|
[
|
|
|
@@ -383,25 +383,6 @@ t_write_failure(Config) ->
|
|
|
end),
|
|
|
ok.
|
|
|
|
|
|
-t_write_timeout(Config) ->
|
|
|
- ProxyName = ?config(proxy_name, Config),
|
|
|
- ProxyPort = ?config(proxy_port, Config),
|
|
|
- ProxyHost = ?config(proxy_host, Config),
|
|
|
- {{ok, _}, {ok, _}} =
|
|
|
- ?wait_async_action(
|
|
|
- create_bridge(Config),
|
|
|
- #{?snk_kind := resource_connected_enter},
|
|
|
- 20_000
|
|
|
- ),
|
|
|
- SentData = #{id => emqx_misc:gen_id(), payload => ?PAYLOAD},
|
|
|
- emqx_common_test_helpers:with_failure(timeout, ProxyName, ProxyHost, ProxyPort, fun() ->
|
|
|
- ?assertMatch(
|
|
|
- {error, {resource_error, #{reason := timeout}}},
|
|
|
- query_resource(Config, {send_message, SentData})
|
|
|
- )
|
|
|
- end),
|
|
|
- ok.
|
|
|
-
|
|
|
t_simple_query(Config) ->
|
|
|
?assertMatch(
|
|
|
{ok, _},
|