yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

getstate -> getstat

This commit is contained in:
Ery Lee 2015-01-10 16:54:04 +08:00
parent b351f7c452
commit 5f0c0df458
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqtt/src/emqtt_keepalive.erl
View File

@ -32,7 +32,7 @@
%% @doc create a keepalive. %% @doc create a keepalive.
%% %%
new(Socket, TimeoutSec, TimeoutMsg) when TimeoutSec > 0 -> new(Socket, TimeoutSec, TimeoutMsg) when TimeoutSec > 0 ->
{ok, [{recv_oct, RecvOct}]} = inet:getstate(Socket, [recv_oct]), {ok, [{recv_oct, RecvOct}]} = inet:getstat(Socket, [recv_oct]),
Ref = erlang:send_after(TimeoutSec*1000, self(), TimeoutMsg), Ref = erlang:send_after(TimeoutSec*1000, self(), TimeoutMsg),
#keepalive { socket = Socket, #keepalive { socket = Socket,
recv_oct = RecvOct, recv_oct = RecvOct,
@ -48,7 +48,7 @@ resume(KeepAlive = #keepalive { socket = Socket,
timeout_sec = TimeoutSec, timeout_sec = TimeoutSec,
timeout_msg = TimeoutMsg, timeout_msg = TimeoutMsg,
timer_ref = Ref }) -> timer_ref = Ref }) ->
{ok, [{recv_oct, NewRecvOct}]} = inet:getstate(Socket, [recv_oct]), {ok, [{recv_oct, NewRecvOct}]} = inet:getstat(Socket, [recv_oct]),
if if
NewRecvOct =:= RecvOct -> NewRecvOct =:= RecvOct ->
timeout; timeout;