Fix crash

openworkload · Jul 13, 2024 · 143ff1d · 143ff1d
1 parent ffb0e4b
commit 143ff1d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/src/lib/wm_api.erl b/src/lib/wm_api.erl
@@ -171,9 +171,9 @@ split_rpc_msg(Msg) ->
     ArgT = tl(List),
     {Arg0, list_to_tuple(ArgT)}.
 
--spec cast_all_nodes_process(atom(), string(), list(), atom()) -> atom().
+-spec cast_all_nodes_process(atom(), string(), list(), atom()) -> boolean().
 cast_all_nodes_process(_, _, [], _) ->
-    ok;
+    true;
 cast_all_nodes_process(Mod, Msg, [Addr = {"localhost", Port} | Nodes], Wait) when is_integer(Port) ->
     case wm_conf:g(parent_api_port, {?DEFAULT_PARENT_API_PORT, integer}) of
         Port ->

diff --git a/src/lib/wm_factory.erl b/src/lib/wm_factory.erl
@@ -132,7 +132,8 @@ handle_cast({task_nodes, ModuleTaskId, Nodes}, MState) ->
     {ModuleTaskId, MState2} = start_module(ModuleTaskId, [], Nodes, MState),
     {noreply, MState2};
 handle_cast({send_confirm, ModuleTaskId, Msg, Nodes}, MState) ->
-    ok = do_send_confirm(ModuleTaskId, Msg, Nodes),
+    Result = do_send_confirm(ModuleTaskId, Msg, Nodes),
+    ?LOG_DEBUG("Send-confirm result: ~p (task: ~p, nodes = ~p)", [Result, ModuleTaskId, Nodes]),
     {noreply, MState};
 handle_cast({subscribe, ModuleTaskId, EventType}, MState) ->
     wm_event:subscribe_async(EventType, node(), MState#mstate.regname),