Merge pull request #10748 from ci/ct-flap-eviction
test(evict): fix flapping testcase
This commit is contained in:
commit
e4701a71da
|
@ -159,8 +159,6 @@ t_explicit_session_takeover(Config) ->
|
||||||
]),
|
]),
|
||||||
{ok, _, _} = emqtt:subscribe(C0, <<"t1">>),
|
{ok, _, _} = emqtt:subscribe(C0, <<"t1">>),
|
||||||
|
|
||||||
ok = rpc:call(Node1, emqx_eviction_agent, enable, [test_eviction, undefined]),
|
|
||||||
|
|
||||||
?assertEqual(
|
?assertEqual(
|
||||||
1,
|
1,
|
||||||
rpc:call(Node1, emqx_eviction_agent, connection_count, [])
|
rpc:call(Node1, emqx_eviction_agent, connection_count, [])
|
||||||
|
@ -168,6 +166,8 @@ t_explicit_session_takeover(Config) ->
|
||||||
|
|
||||||
[ChanPid] = rpc:call(Node1, emqx_cm, lookup_channels, [<<"client_with_session">>]),
|
[ChanPid] = rpc:call(Node1, emqx_cm, lookup_channels, [<<"client_with_session">>]),
|
||||||
|
|
||||||
|
ok = rpc:call(Node1, emqx_eviction_agent, enable, [test_eviction, undefined]),
|
||||||
|
|
||||||
?assertWaitEvent(
|
?assertWaitEvent(
|
||||||
begin
|
begin
|
||||||
ok = rpc:call(Node1, emqx_eviction_agent, evict_connections, [1]),
|
ok = rpc:call(Node1, emqx_eviction_agent, evict_connections, [1]),
|
||||||
|
|
Loading…
Reference in New Issue