diff --git a/src/Faw/fwFMgr.erl b/src/Faw/fwFMgr.erl index 63c16cb..9aa3583 100644 --- a/src/Faw/fwFMgr.erl +++ b/src/Faw/fwFMgr.erl @@ -27,6 +27,9 @@ start_link() -> init(_Args) -> {ok, #{}}. +handleCall({mNewQueue, FName}, _State, _FROM) -> + Ret = fwQueue:new(FName), + {reply, Ret}; handleCall(_Msg, _State, _FROM) -> ?ERR("~p call receive unexpect msg ~p ~n ", [?MODULE, _Msg]), {reply, ok}. diff --git a/src/eFaw.erl b/src/eFaw.erl index 657a84f..704a1e0 100644 --- a/src/eFaw.erl +++ b/src/eFaw.erl @@ -43,6 +43,7 @@ openF(FName, Kvs) -> modules => [fwWSup] }, Ret = supervisor:start_child(eFaw_sup, FChildSpec), + FName = gen_srv:call(fwFMgr, {mNewQueue, FName}), fwKvsToBeam:load(FName, initCfg(Kvs)), hireW(FName:getV(?wFCnt), FName, false), Ret.