diff --git a/ebin/gmhive_client.app b/ebin/gmhive_client.app index a3b99a8..2ffc191 100644 --- a/ebin/gmhive_client.app +++ b/ebin/gmhive_client.app @@ -1,6 +1,6 @@ {application,gmhive_client, [{description,"Gajumaru Hive Client"}, - {vsn,"0.4.4"}, + {vsn,"0.4.5"}, {registered,[]}, {applications,[kernel,stdlib,sasl,gproc,inets,ssl,enoise, gmconfig,gmhive_protocol,gmhive_worker]}, diff --git a/src/gmhc_server.erl b/src/gmhc_server.erl index af16c4e..ce7400d 100644 --- a/src/gmhc_server.erl +++ b/src/gmhc_server.erl @@ -107,13 +107,16 @@ handle_cast({from_pool, #{via := Connector, %% We could check whether we have already received the candidate ... %% For now, stop all workers, restart with new candidate try - % Most of the time we don't want to stop the worker. If we do, though, then - % we need to do it more carefully than this, or memory usage will triple. - % Workers1 = stop_workers(Workers), - {Workers2, Cand1} = assign_nonces(Workers, Cand), - #st{candidate = Cand2} = S1 = maybe_request_nonces(S#st{candidate = Cand1}), - NewWorkers = [spawn_worker(W, Cand2) || W <- Workers2], - {noreply, S1#st{workers = NewWorkers}} + %% Most of the time we don't want to stop the worker. If we do, though, then + %% we need to do it more carefully than this, or memory usage will triple. + %% Workers1 = stop_workers(Workers), + %% + %% Nonces may be [], in which case we need to request new nonces first. + #st{candidate = Cand1} = S1 = maybe_request_nonces(S#st{candidate = Cand}), + {Workers2, Cand2} = assign_nonces(Workers, Cand1), + #st{candidate = Cand3} = S2 = maybe_request_nonces(S1#st{candidate = Cand2}), + NewWorkers = [spawn_worker(W, Cand3) || W <- Workers2], + {noreply, S2#st{workers = NewWorkers}} catch Cat:Err:St -> ?LOG_ERROR("CAUGHT ~p:~p / ~p", [Cat, Err, St]), diff --git a/zomp.meta b/zomp.meta index 93a4a7a..b85d6d4 100644 --- a/zomp.meta +++ b/zomp.meta @@ -2,9 +2,9 @@ {type,app}. {modules,[]}. {prefix,"gmhc"}. -{desc,"Gajumaru Hive Client"}. {author,"Ulf Wiger, QPQ AG"}. -{package_id,{"uwiger","gmhive_client",{0,4,4}}}. +{desc,"Gajumaru Hive Client"}. +{package_id,{"uwiger","gmhive_client",{0,4,5}}}. {deps,[{"uwiger","gmcuckoo",{1,2,3}}, {"uwiger","gmhive_worker",{0,3,0}}, {"otpr","eblake2",{1,0,1}},