diff --git a/src/lib/wm_api.erl b/src/lib/wm_api.erl index 3ecd8be..b504701 100644 --- 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 index 10698f0..b4adf74 100644 --- 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),