Skip to content

Commit

Permalink
FIXUP
Browse files Browse the repository at this point in the history
  • Loading branch information
whatyouhide committed Aug 9, 2023
1 parent 2e1b1a0 commit d859de4
Showing 1 changed file with 1 addition and 15 deletions.
16 changes: 1 addition & 15 deletions test/xandra/cluster/control_connection_test.exs
Original file line number Diff line number Diff line change
Expand Up @@ -413,7 +413,7 @@ defmodule Xandra.Cluster.ControlConnectionTest do
}}
end

test "performs healthcheck and sends node down message if not registered",
test "performs healthcheck",
%{mirror_ref: mirror_ref, registry: registry, start_options: start_options} do
telemetry_ref =
:telemetry_test.attach_event_handlers(self(), [[:xandra, :cluster, :change_event]])
Expand Down Expand Up @@ -457,21 +457,7 @@ defmodule Xandra.Cluster.ControlConnectionTest do
{:started_pool, %Host{address: {127, 0, 0, 1}, port: @port, data_center: "datacenter1"}}
)

send(
ctrl_conn,
{:started_pool, %Host{address: {192, 168, 1, 1}, port: @port, data_center: "datacenter1"}}
)

refute_receive {^mirror_ref, {:host_down, %Host{address: {127, 0, 0, 1}}}}, 600
assert_receive {^mirror_ref, {:host_down, %Host{address: {192, 168, 1, 1}}}}

assert_receive {[:xandra, :cluster, :change_event], ^telemetry_ref, %{},
%{
event_type: :host_down,
changed: true,
source: :xandra,
host: %Host{address: {192, 168, 1, 1}}
}}
end

defp start_control_connection!(start_options, overrides \\ []) do
Expand Down

0 comments on commit d859de4

Please sign in to comment.