Compare commits

...

2 Commits

Author SHA1 Message Date
Ulf Wiger
0a76bada43 bump zx patch vsn 2025-08-20 20:44:55 +02:00
Ulf Wiger
36a11575d2 Add missing demonitor() calls 2025-08-20 20:43:22 +02:00
3 changed files with 5 additions and 2 deletions

View File

@ -1,6 +1,6 @@
{application,gmhive_client, {application,gmhive_client,
[{description,"Gajumaru Hive Client"}, [{description,"Gajumaru Hive Client"},
{vsn,"0.4.5"}, {vsn,"0.4.6"},
{registered,[]}, {registered,[]},
{applications,[kernel,stdlib,sasl,gproc,inets,ssl,enoise, {applications,[kernel,stdlib,sasl,gproc,inets,ssl,enoise,
gmconfig,gmhive_protocol,gmhive_worker]}, gmconfig,gmhive_protocol,gmhive_worker]},

View File

@ -129,12 +129,15 @@ call_connector(Req0) ->
gmhc_connector:send(ViaId, #{call => Req#{ id => Id }}), gmhc_connector:send(ViaId, #{call => Req#{ id => Id }}),
receive receive
{from_pool, #{reply := #{ id := Id, result := Result }}} -> {from_pool, #{reply := #{ id := Id, result := Result }}} ->
erlang:demonitor(MRef),
Result; Result;
{from_pool, #{error := #{ id := Id } = Error}} -> {from_pool, #{error := #{ id := Id } = Error}} ->
erlang:demonitor(MRef),
{error, maps:remove(id, Error)}; {error, maps:remove(id, Error)};
{'DOWN', MRef, _, _, _} -> {'DOWN', MRef, _, _, _} ->
{error, no_connection} {error, no_connection}
after 5000 -> after 5000 ->
erlang:demonitor(MRef),
{error, {timeout, process_info(self(), messages)}} {error, {timeout, process_info(self(), messages)}}
end end
end. end.

View File

@ -4,7 +4,7 @@
{prefix,"gmhc"}. {prefix,"gmhc"}.
{author,"Ulf Wiger, QPQ AG"}. {author,"Ulf Wiger, QPQ AG"}.
{desc,"Gajumaru Hive Client"}. {desc,"Gajumaru Hive Client"}.
{package_id,{"uwiger","gmhive_client",{0,4,5}}}. {package_id,{"uwiger","gmhive_client",{0,4,6}}}.
{deps,[{"uwiger","gmcuckoo",{1,2,3}}, {deps,[{"uwiger","gmcuckoo",{1,2,3}},
{"uwiger","gmhive_worker",{0,3,0}}, {"uwiger","gmhive_worker",{0,3,0}},
{"otpr","eblake2",{1,0,1}}, {"otpr","eblake2",{1,0,1}},