Parcourir la source

ft: 同步进程退出时 状态保存

master
SisMaker il y a 4 ans
Parent
révision
e715aa92fb
1 fichiers modifiés avec 5 ajouts et 5 suppressions
  1. +5
    -5
      src/sync/esSyncSrv.erl

+ 5
- 5
src/sync/esSyncSrv.erl Voir le fichier

@ -137,8 +137,8 @@ handleCall(miGetOnCSync, _, #state{onCSyncFun = OnCSyncFun} = State, _From) ->
{reply, OnCSyncFun, State};
handleCall({miSetOnCSync, Fun}, _, State, _From) ->
{reply, ok, State#state{onCSyncFun = Fun}};
handleCall(miCurInfo, _, State, _Form) ->
{reply, {erlang:get(), State}, State};
handleCall(miCurInfo, Status, State, _Form) ->
{reply, {Status, erlang:get(), State}, State};
handleCall(_Request, _, _State, _From) ->
kpS_S.
@ -212,13 +212,13 @@ handleInfo({Port, {data, Data}}, Status, #state{srcFiles = Srcs, hrlFiles = Hrls
end;
handleInfo({_Port, closed}, running, _State) ->
esUtils:logErrors("esSyncSrv receive port closed ~n"),
kpS_S;
{nextS, port_close, _State};
handleInfo({'EXIT', _Port, Reason}, running, _State) ->
esUtils:logErrors("esSyncSrv receive port exit Reason:~p ~n", [Reason]),
kpS_S;
{nextS, {port_EXIT, Reason}, _State};
handleInfo({_Port, {exit_status, Status}}, running, _State) ->
esUtils:logErrors("esSyncSrv receive port exit_status Status:~p ~n", [Status]),
kpS_S;
{nextS, {port_exit_status, Status}, _State};
handleInfo(_Msg, _, _State) ->
esUtils:logErrors("esSyncSrv receive unexpect msg:~p ~n", [_Msg]),
kpS_S.

Chargement…
Annuler
Enregistrer