Compare commits
No commits in common. "0a76bada43994bf53e871f46f4a38ba4a61e82a0" and "5bc0fc5ff83f7953cd097924fdc07a4a73931c7e" have entirely different histories.
0a76bada43
...
5bc0fc5ff8
@ -1,6 +1,6 @@
|
|||||||
{application,gmhive_client,
|
{application,gmhive_client,
|
||||||
[{description,"Gajumaru Hive Client"},
|
[{description,"Gajumaru Hive Client"},
|
||||||
{vsn,"0.4.6"},
|
{vsn,"0.4.5"},
|
||||||
{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]},
|
||||||
|
|||||||
@ -129,15 +129,12 @@ 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.
|
||||||
|
|||||||
@ -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,6}}}.
|
{package_id,{"uwiger","gmhive_client",{0,4,5}}}.
|
||||||
{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}},
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user