Explorar o código

fix(buffer worker): flush late replies to simple internal buffer queries

Fixes https://emqx.atlassian.net/browse/EMQX-13243
Thales Macedo Garitezi hai 1 ano
pai
achega
e86c596b06
Modificáronse 1 ficheiros con 8 adicións e 1 borrados
  1. 8 1
      apps/emqx_resource/src/emqx_resource_buffer_worker.erl

+ 8 - 1
apps/emqx_resource/src/emqx_resource_buffer_worker.erl

@@ -232,7 +232,14 @@ simple_sync_internal_buffer_query(Id, Request, QueryOpts0) ->
                 end
         end
     after
-        _ = unalias(ReplyAlias)
+        _ = unalias(ReplyAlias),
+        receive
+            {ReplyAlias, _Response} ->
+                %% stale response
+                ok
+        after 0 ->
+            ok
+        end
     end.
 
 simple_sync_query_opts() ->