From 6db7ff1218f4d622457574acb67e0371fe4603ba Mon Sep 17 00:00:00 2001 From: SisMaker <156736github> Date: Thu, 30 Dec 2021 22:00:10 +0800 Subject: [PATCH] =?UTF-8?q?ft=EF=BC=9A=E5=88=9D=E5=A7=8B=E5=8C=96=E9=98=9F?= =?UTF-8?q?=E5=88=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/Faw/fwFMgr.erl | 3 +++ src/eFaw.erl | 1 + 2 files changed, 4 insertions(+) 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.