valitydev/epg_connector
14
0
Fork 0
mirror of https://github.com/valitydev/epg_connector.git synced 2024-11-06 08:15:23 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

TD-927: add connections log

Browse Source
This commit is contained in:
ttt161 2024-09-18 09:08:10 +03:00
parent fb23b8dfaf
commit a507052d66
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/epg_pool_wrk.erl
View File

@ -29,9 +29,10 @@ handle_cast(_Request, State = #epg_pool_wrk_state{}) ->
handle_info( handle_info(
{'EXIT', Pid, _Info}, {'EXIT', Pid, _Info},
State = #epg_pool_wrk_state{pool = _Pool, connection = Pid} State = #epg_pool_wrk_state{pool = Pool, connection = Pid, params = #{database := DB}}
) -> ) ->
%epg_pool_mgr:remove(Pool, self(), Pid), %epg_pool_mgr:remove(Pool, self(), Pid),
logger:error("db connection lost. pool: ~p. database: ~p", [Pool, DB]),
reconnect_timer(), reconnect_timer(),
{noreply, State#epg_pool_wrk_state{connection = undefined, monitor = undefined}}; {noreply, State#epg_pool_wrk_state{connection = undefined, monitor = undefined}};
@ -50,10 +51,11 @@ code_change(_OldVsn, State = #epg_pool_wrk_state{}, _Extra) ->
reconnect_timer() -> reconnect_timer() ->
erlang:start_timer(5000, self(), reconnect). erlang:start_timer(5000, self(), reconnect).
connect(#epg_pool_wrk_state{pool = Pool, params = Params} = State) -> connect(#epg_pool_wrk_state{pool = Pool, params = #{database := DB} = Params} = State) ->
try epgsql:connect(Params) of try epgsql:connect(Params) of
{ok, Connection} -> {ok, Connection} ->
epg_pool_mgr:add(Pool, self(), Connection), epg_pool_mgr:add(Pool, self(), Connection),
logger:info("db connection established. pool: ~p. database: ~p", [Pool, DB]),
State#epg_pool_wrk_state{connection = Connection}; State#epg_pool_wrk_state{connection = Connection};
{error, _Reason} -> {error, _Reason} ->
reconnect_timer(), reconnect_timer(),