umgeher/cowboy
0
Fork 0
mirror of https://github.com/ninenines/cowboy.git synced 2025-07-14 12:20:24 +00:00
Code Issues Wiki Activity

fixed cowboy_clock inbox overflow if system clock was changed

Browse source
This commit is contained in:
Alex Kovalev 2015-03-26 11:15:05 +03:00
parent 3d9078018d
commit c05143aba8
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/cowboy_clock.erl
View file

@ -65,7 +65,7 @@ init([]) ->
named_table, {read_concurrency, true}]), named_table, {read_concurrency, true}]),
T = erlang:universaltime(), T = erlang:universaltime(),
B = update_rfc1123(<<>>, undefined, T), B = update_rfc1123(<<>>, undefined, T),
{ok, TRef} = timer:send_interval(1000, update), TRef = erlang:send_after(1000, self(), update),
ets:insert(?MODULE, {rfc1123, B}), ets:insert(?MODULE, {rfc1123, B}),
{ok, #state{universaltime=T, rfc1123=B, tref=TRef}}. {ok, #state{universaltime=T, rfc1123=B, tref=TRef}}.
@ -83,10 +83,12 @@ handle_cast(_Msg, State) ->
{noreply, State}. {noreply, State}.
-spec handle_info(any(), State) -> {noreply, State} when State::#state{}. -spec handle_info(any(), State) -> {noreply, State} when State::#state{}.
handle_info(update, #state{universaltime=Prev, rfc1123=B1, tref=TRef}) -> handle_info(update, #state{universaltime=Prev, rfc1123=B1, tref=TRef0}) ->
erlang:cancel_timer(TRef0),
T = erlang:universaltime(), T = erlang:universaltime(),
B2 = update_rfc1123(B1, Prev, T), B2 = update_rfc1123(B1, Prev, T),
ets:insert(?MODULE, {rfc1123, B2}), ets:insert(?MODULE, {rfc1123, B2}),
TRef = erlang:send_after(1000, self(), update),
{noreply, #state{universaltime=T, rfc1123=B2, tref=TRef}}; {noreply, #state{universaltime=T, rfc1123=B2, tref=TRef}};
handle_info(_Info, State) -> handle_info(_Info, State) ->
{noreply, State}. {noreply, State}.