Skip to content

Commit d6def01

Browse files
committed
fixing timeout in topology gen_server
1 parent 9f03329 commit d6def01

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

lib/mongo/monitor.ex

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,7 @@ defmodule Mongo.Monitor do
9595
else
9696
server_description = is_master(state.connection_pid, state.server_description, state.opts)
9797

98-
:ok = GenServer.call(state.topology_pid, {:server_description, server_description}, 30_000)
98+
:ok = GenServer.cast(state.topology_pid, {:server_description, server_description})
9999
{:noreply, %{state | server_description: server_description}, state.heartbeat_frequency_ms}
100100
end
101101
end

lib/mongo/topology.ex

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ defmodule Mongo.Topology do
116116
end
117117

118118
# see https://github.com/mongodb/specifications/blob/master/source/server-discovery-and-monitoring/server-discovery-and-monitoring.rst#updating-the-topologydescription
119-
def handle_call({:server_description, server_description}, _from, state) do
119+
def handle_cast({:server_description, server_description}, state) do
120120
new_state = handle_server_description(state, server_description)
121121
if state.topology != new_state.topology do
122122
:ok = Mongo.Events.notify(%TopologyDescriptionChangedEvent{
@@ -125,7 +125,7 @@ defmodule Mongo.Topology do
125125
new_description: new_state.topology
126126
})
127127
end
128-
{:reply, :ok, new_state}
128+
{:noreply, new_state}
129129
end
130130

131131
def handle_call(:wait_for_connection, _from, %{connection_pools: pools} = state) when map_size(pools) > 0 do

0 commit comments

Comments
 (0)